Golang transport.MCResponse类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中github.com/couchbase/indexing/secondary/dcp/transport.MCResponse类的典型用法代码示例。如果您正苦于以下问题：Golang MCResponse类的具体用法？Golang MCResponse怎么用？Golang MCResponse使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了MCResponse类的7个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: sendAck

func (mc *Client) sendAck(pkt *transport.MCRequest) (int, error) {
	res := transport.MCResponse{
		Opcode: pkt.Opcode,
		Opaque: pkt.Opaque,
		Status: transport.SUCCESS,
	}
	return res.Transmit(mc.conn)
}

开发者ID:jchris，项目名称:indexing，代码行数:8，代码来源:tap_feed.go

示例2: BenchmarkTransmitResNull

func BenchmarkTransmitResNull(b *testing.B) {
	res := transport.MCResponse{
		Opcode: transport.SET,
		Cas:    938424885,
		Opaque: 7242,
		Status: 824,
		Key:    []byte("somekey"),
		Body:   []byte("somevalue"),
	}

	b.SetBytes(int64(res.Size()))

	for i := 0; i < b.N; i++ {
		_, err := transmitResponse(ioutil.Discard, &res)
		if err != nil {
			b.Fatalf("Error transmitting request: %v", err)
		}
	}
}

开发者ID:jchris，项目名称:indexing，代码行数:19，代码来源:server_test.go

示例3: TestTransmitRes

func TestTransmitRes(t *testing.T) {
	b := &bytes.Buffer{}
	buf := bufio.NewWriter(b)

	res := transport.MCResponse{
		Opcode: transport.SET,
		Cas:    938424885,
		Opaque: 7242,
		Status: 0x338,
		Key:    []byte("somekey"),
		Body:   []byte("somevalue"),
	}

	_, err := transmitResponse(buf, &res)
	if err != nil {
		t.Fatalf("Error transmitting request: %v", err)
	}

	buf.Flush()

	expected := []byte{
		transport.RES_MAGIC, byte(transport.SET),
		0x0, 0x7, // length of key
		0x0,       // extra length
		0x0,       // reserved
		0x3, 0x38, // Status
		0x0, 0x0, 0x0, 0x10, // Length of value
		0x0, 0x0, 0x1c, 0x4a, // opaque
		0x0, 0x0, 0x0, 0x0, 0x37, 0xef, 0x3a, 0x35, // CAS
		's', 'o', 'm', 'e', 'k', 'e', 'y',
		's', 'o', 'm', 'e', 'v', 'a', 'l', 'u', 'e'}

	if len(b.Bytes()) != res.Size() {
		t.Fatalf("Expected %v bytes, got %v", res.Size(),
			len(b.Bytes()))
	}

	if !reflect.DeepEqual(b.Bytes(), expected) {
		t.Fatalf("Expected:\n%#v\n  -- got -- \n%#v",
			expected, b.Bytes())
	}
}

开发者ID:jchris，项目名称:indexing，代码行数:42，代码来源:server_test.go

示例4: BenchmarkReceive

func BenchmarkReceive(b *testing.B) {
	res := transport.MCResponse{
		Opcode: transport.SET,
		Cas:    938424885,
		Opaque: 7242,
		Status: 824,
		Key:    []byte("somekey"),
		Body:   []byte("somevalue"),
	}

	datum := res.Bytes()
	datum[0] = transport.REQ_MAGIC
	b.SetBytes(int64(len(datum)))

	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		_, err := ReadPacket(bytes.NewReader(datum))
		if err != nil {
			b.Fatalf("Failed to read: %v", err)
		}
	}
}

开发者ID:jchris，项目名称:indexing，代码行数:22，代码来源:server_test.go

示例5: BenchmarkTransmitRes

func BenchmarkTransmitRes(b *testing.B) {
	bout := &bytes.Buffer{}

	res := transport.MCResponse{
		Opcode: transport.SET,
		Cas:    938424885,
		Opaque: 7242,
		Status: 824,
		Key:    []byte("somekey"),
		Body:   []byte("somevalue"),
	}

	b.SetBytes(int64(res.Size()))

	for i := 0; i < b.N; i++ {
		bout.Reset()
		buf := bufio.NewWriterSize(bout, res.Size()*2)
		_, err := transmitResponse(buf, &res)
		if err != nil {
			b.Fatalf("Error transmitting request: %v", err)
		}
	}
}

开发者ID:jchris，项目名称:indexing，代码行数:23，代码来源:server_test.go

示例6: transmitResponse

func transmitResponse(o io.Writer, res *transport.MCResponse) (int, error) {
	return res.Transmit(o)
}

开发者ID:jchris，项目名称:indexing，代码行数:3，代码来源:mc_conn_handler.go

示例7: notFound

func notFound(req *transport.MCRequest, s *storage) *transport.MCResponse {
	var response transport.MCResponse
	response.Status = transport.UNKNOWN_COMMAND
	return &response
}

开发者ID:jchris，项目名称:indexing，代码行数:5，代码来源:mc_storage.go

注：本文中的github.com/couchbase/indexing/secondary/dcp/transport.MCResponse类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。