groupproto

package
v0.0.0-...-fca1d3b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 31, 2016 License: Apache-2.0 Imports: 6 Imported by: 16

Documentation

Overview

Package groupproto is a generated protocol buffer package.

It is generated from these files: 

group_api.proto

It has these top-level messages: 

EmptyMsg
WriteRequest
LookupRequest
ReadRequest
DeleteRequest
LookupGroupRequest
ReadGroupRequest
WriteResponse
LookupResponse
LookupGroupResponse
LookupGroupItem
ReadGroupResponse
ReadGroupItem
ReadResponse
DeleteResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthGroupApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGroupApi   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterGroupStoreServer 

func RegisterGroupStoreServer(s *grpc.Server, srv GroupStoreServer)

Types

type DeleteRequest 

type DeleteRequest struct {
	Rpcid          uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	KeyA           uint64 `protobuf:"varint,2,opt,name=keyA,proto3" json:"keyA,omitempty"`
	KeyB           uint64 `protobuf:"varint,3,opt,name=keyB,proto3" json:"keyB,omitempty"`
	ChildKeyA      uint64 `protobuf:"varint,4,opt,name=childKeyA,proto3" json:"childKeyA,omitempty"`
	ChildKeyB      uint64 `protobuf:"varint,5,opt,name=childKeyB,proto3" json:"childKeyB,omitempty"`
	TimestampMicro int64  `protobuf:"varint,6,opt,name=timestampMicro,proto3" json:"timestampMicro,omitempty"`
}

func (*DeleteRequest) Descriptor 

func (*DeleteRequest) Descriptor() ([]byte, []int)

func (*DeleteRequest) Marshal 

func (m *DeleteRequest) Marshal() (data []byte, err error)

func (*DeleteRequest) MarshalTo 

func (m *DeleteRequest) MarshalTo(data []byte) (int, error)

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

func (m *DeleteRequest) Size() (n int)

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

func (m *DeleteRequest) Unmarshal(data []byte) error

type DeleteResponse 

type DeleteResponse struct {
	Rpcid          uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	TimestampMicro int64  `protobuf:"varint,2,opt,name=timestampMicro,proto3" json:"timestampMicro,omitempty"`
	Err            string `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
}

func (*DeleteResponse) Descriptor 

func (*DeleteResponse) Descriptor() ([]byte, []int)

func (*DeleteResponse) Marshal 

func (m *DeleteResponse) Marshal() (data []byte, err error)

func (*DeleteResponse) MarshalTo 

func (m *DeleteResponse) MarshalTo(data []byte) (int, error)

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

func (m *DeleteResponse) Size() (n int)

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

func (m *DeleteResponse) Unmarshal(data []byte) error

type EmptyMsg 

type EmptyMsg struct {
}

func (*EmptyMsg) Descriptor 

func (*EmptyMsg) Descriptor() ([]byte, []int)

func (*EmptyMsg) Marshal 

func (m *EmptyMsg) Marshal() (data []byte, err error)

func (*EmptyMsg) MarshalTo 

func (m *EmptyMsg) MarshalTo(data []byte) (int, error)

func (*EmptyMsg) ProtoMessage 

func (*EmptyMsg) ProtoMessage()

func (*EmptyMsg) Reset 

func (m *EmptyMsg) Reset()

func (*EmptyMsg) Size 

func (m *EmptyMsg) Size() (n int)

func (*EmptyMsg) String 

func (m *EmptyMsg) String() string

func (*EmptyMsg) Unmarshal 

func (m *EmptyMsg) Unmarshal(data []byte) error

type GroupStoreClient 

type GroupStoreClient interface {
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	StreamWrite(ctx context.Context, opts ...grpc.CallOption) (GroupStore_StreamWriteClient, error)
	Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error)
	StreamLookup(ctx context.Context, opts ...grpc.CallOption) (GroupStore_StreamLookupClient, error)
	LookupGroup(ctx context.Context, in *LookupGroupRequest, opts ...grpc.CallOption) (*LookupGroupResponse, error)
	StreamLookupGroup(ctx context.Context, opts ...grpc.CallOption) (GroupStore_StreamLookupGroupClient, error)
	ReadGroup(ctx context.Context, in *ReadGroupRequest, opts ...grpc.CallOption) (*ReadGroupResponse, error)
	StreamReadGroup(ctx context.Context, opts ...grpc.CallOption) (GroupStore_StreamReadGroupClient, error)
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	StreamRead(ctx context.Context, opts ...grpc.CallOption) (GroupStore_StreamReadClient, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	StreamDelete(ctx context.Context, opts ...grpc.CallOption) (GroupStore_StreamDeleteClient, error)
}

func NewGroupStoreClient 

func NewGroupStoreClient(cc *grpc.ClientConn) GroupStoreClient

type GroupStoreServer 

type GroupStoreServer interface {
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	StreamWrite(GroupStore_StreamWriteServer) error
	Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
	StreamLookup(GroupStore_StreamLookupServer) error
	LookupGroup(context.Context, *LookupGroupRequest) (*LookupGroupResponse, error)
	StreamLookupGroup(GroupStore_StreamLookupGroupServer) error
	ReadGroup(context.Context, *ReadGroupRequest) (*ReadGroupResponse, error)
	StreamReadGroup(GroupStore_StreamReadGroupServer) error
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	StreamRead(GroupStore_StreamReadServer) error
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	StreamDelete(GroupStore_StreamDeleteServer) error
}

type GroupStore_StreamDeleteClient 

type GroupStore_StreamDeleteClient interface {
	Send(*DeleteRequest) error
	Recv() (*DeleteResponse, error)
	grpc.ClientStream
}

type GroupStore_StreamDeleteServer 

type GroupStore_StreamDeleteServer interface {
	Send(*DeleteResponse) error
	Recv() (*DeleteRequest, error)
	grpc.ServerStream
}

type GroupStore_StreamLookupClient 

type GroupStore_StreamLookupClient interface {
	Send(*LookupRequest) error
	Recv() (*LookupResponse, error)
	grpc.ClientStream
}

type GroupStore_StreamLookupGroupClient 

type GroupStore_StreamLookupGroupClient interface {
	Send(*LookupGroupRequest) error
	Recv() (*LookupGroupResponse, error)
	grpc.ClientStream
}

type GroupStore_StreamLookupGroupServer 

type GroupStore_StreamLookupGroupServer interface {
	Send(*LookupGroupResponse) error
	Recv() (*LookupGroupRequest, error)
	grpc.ServerStream
}

type GroupStore_StreamLookupServer 

type GroupStore_StreamLookupServer interface {
	Send(*LookupResponse) error
	Recv() (*LookupRequest, error)
	grpc.ServerStream
}

type GroupStore_StreamReadClient 

type GroupStore_StreamReadClient interface {
	Send(*ReadRequest) error
	Recv() (*ReadResponse, error)
	grpc.ClientStream
}

type GroupStore_StreamReadGroupClient 

type GroupStore_StreamReadGroupClient interface {
	Send(*ReadGroupRequest) error
	Recv() (*ReadGroupResponse, error)
	grpc.ClientStream
}

type GroupStore_StreamReadGroupServer 

type GroupStore_StreamReadGroupServer interface {
	Send(*ReadGroupResponse) error
	Recv() (*ReadGroupRequest, error)
	grpc.ServerStream
}

type GroupStore_StreamReadServer 

type GroupStore_StreamReadServer interface {
	Send(*ReadResponse) error
	Recv() (*ReadRequest, error)
	grpc.ServerStream
}

type GroupStore_StreamWriteClient 

type GroupStore_StreamWriteClient interface {
	Send(*WriteRequest) error
	Recv() (*WriteResponse, error)
	grpc.ClientStream
}

type GroupStore_StreamWriteServer 

type GroupStore_StreamWriteServer interface {
	Send(*WriteResponse) error
	Recv() (*WriteRequest, error)
	grpc.ServerStream
}

type LookupGroupItem 

type LookupGroupItem struct {
	Rpcid          uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	ChildKeyA      uint64 `protobuf:"varint,2,opt,name=childKeyA,proto3" json:"childKeyA,omitempty"`
	ChildKeyB      uint64 `protobuf:"varint,3,opt,name=childKeyB,proto3" json:"childKeyB,omitempty"`
	TimestampMicro int64  `protobuf:"varint,4,opt,name=timestampMicro,proto3" json:"timestampMicro,omitempty"`
	Length         uint32 `protobuf:"varint,5,opt,name=length,proto3" json:"length,omitempty"`
}

func (*LookupGroupItem) Descriptor 

func (*LookupGroupItem) Descriptor() ([]byte, []int)

func (*LookupGroupItem) Marshal 

func (m *LookupGroupItem) Marshal() (data []byte, err error)

func (*LookupGroupItem) MarshalTo 

func (m *LookupGroupItem) MarshalTo(data []byte) (int, error)

func (*LookupGroupItem) ProtoMessage 

func (*LookupGroupItem) ProtoMessage()

func (*LookupGroupItem) Reset 

func (m *LookupGroupItem) Reset()

func (*LookupGroupItem) Size 

func (m *LookupGroupItem) Size() (n int)

func (*LookupGroupItem) String 

func (m *LookupGroupItem) String() string

func (*LookupGroupItem) Unmarshal 

func (m *LookupGroupItem) Unmarshal(data []byte) error

type LookupGroupRequest 

type LookupGroupRequest struct {
	Rpcid uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	KeyA  uint64 `protobuf:"varint,2,opt,name=keyA,proto3" json:"keyA,omitempty"`
	KeyB  uint64 `protobuf:"varint,3,opt,name=keyB,proto3" json:"keyB,omitempty"`
}

func (*LookupGroupRequest) Descriptor 

func (*LookupGroupRequest) Descriptor() ([]byte, []int)

func (*LookupGroupRequest) Marshal 

func (m *LookupGroupRequest) Marshal() (data []byte, err error)

func (*LookupGroupRequest) MarshalTo 

func (m *LookupGroupRequest) MarshalTo(data []byte) (int, error)

func (*LookupGroupRequest) ProtoMessage 

func (*LookupGroupRequest) ProtoMessage()

func (*LookupGroupRequest) Reset 

func (m *LookupGroupRequest) Reset()

func (*LookupGroupRequest) Size 

func (m *LookupGroupRequest) Size() (n int)

func (*LookupGroupRequest) String 

func (m *LookupGroupRequest) String() string

func (*LookupGroupRequest) Unmarshal 

func (m *LookupGroupRequest) Unmarshal(data []byte) error

type LookupGroupResponse 

type LookupGroupResponse struct {
	Rpcid uint32             `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	Items []*LookupGroupItem `protobuf:"bytes,2,rep,name=items" json:"items,omitempty"`
	Err   string             `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
}

func (*LookupGroupResponse) Descriptor 

func (*LookupGroupResponse) Descriptor() ([]byte, []int)

func (*LookupGroupResponse) GetItems 

func (m *LookupGroupResponse) GetItems() []*LookupGroupItem

func (*LookupGroupResponse) Marshal 

func (m *LookupGroupResponse) Marshal() (data []byte, err error)

func (*LookupGroupResponse) MarshalTo 

func (m *LookupGroupResponse) MarshalTo(data []byte) (int, error)

func (*LookupGroupResponse) ProtoMessage 

func (*LookupGroupResponse) ProtoMessage()

func (*LookupGroupResponse) Reset 

func (m *LookupGroupResponse) Reset()

func (*LookupGroupResponse) Size 

func (m *LookupGroupResponse) Size() (n int)

func (*LookupGroupResponse) String 

func (m *LookupGroupResponse) String() string

func (*LookupGroupResponse) Unmarshal 

func (m *LookupGroupResponse) Unmarshal(data []byte) error

type LookupRequest 

type LookupRequest struct {
	Rpcid     uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	KeyA      uint64 `protobuf:"varint,2,opt,name=keyA,proto3" json:"keyA,omitempty"`
	KeyB      uint64 `protobuf:"varint,3,opt,name=keyB,proto3" json:"keyB,omitempty"`
	ChildKeyA uint64 `protobuf:"varint,4,opt,name=childKeyA,proto3" json:"childKeyA,omitempty"`
	ChildKeyB uint64 `protobuf:"varint,5,opt,name=childKeyB,proto3" json:"childKeyB,omitempty"`
}

func (*LookupRequest) Descriptor 

func (*LookupRequest) Descriptor() ([]byte, []int)

func (*LookupRequest) Marshal 

func (m *LookupRequest) Marshal() (data []byte, err error)

func (*LookupRequest) MarshalTo 

func (m *LookupRequest) MarshalTo(data []byte) (int, error)

func (*LookupRequest) ProtoMessage 

func (*LookupRequest) ProtoMessage()

func (*LookupRequest) Reset 

func (m *LookupRequest) Reset()

func (*LookupRequest) Size 

func (m *LookupRequest) Size() (n int)

func (*LookupRequest) String 

func (m *LookupRequest) String() string

func (*LookupRequest) Unmarshal 

func (m *LookupRequest) Unmarshal(data []byte) error

type LookupResponse 

type LookupResponse struct {
	Rpcid          uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	TimestampMicro int64  `protobuf:"varint,2,opt,name=timestampMicro,proto3" json:"timestampMicro,omitempty"`
	Length         uint32 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	Err            string `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
}

func (*LookupResponse) Descriptor 

func (*LookupResponse) Descriptor() ([]byte, []int)

func (*LookupResponse) Marshal 

func (m *LookupResponse) Marshal() (data []byte, err error)

func (*LookupResponse) MarshalTo 

func (m *LookupResponse) MarshalTo(data []byte) (int, error)

func (*LookupResponse) ProtoMessage 

func (*LookupResponse) ProtoMessage()

func (*LookupResponse) Reset 

func (m *LookupResponse) Reset()

func (*LookupResponse) Size 

func (m *LookupResponse) Size() (n int)

func (*LookupResponse) String 

func (m *LookupResponse) String() string

func (*LookupResponse) Unmarshal 

func (m *LookupResponse) Unmarshal(data []byte) error

type ReadGroupItem 

type ReadGroupItem struct {
	Rpcid          uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	ChildKeyA      uint64 `protobuf:"varint,2,opt,name=childKeyA,proto3" json:"childKeyA,omitempty"`
	ChildKeyB      uint64 `protobuf:"varint,3,opt,name=childKeyB,proto3" json:"childKeyB,omitempty"`
	TimestampMicro int64  `protobuf:"varint,4,opt,name=timestampMicro,proto3" json:"timestampMicro,omitempty"`
	Value          []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ReadGroupItem) Descriptor 

func (*ReadGroupItem) Descriptor() ([]byte, []int)

func (*ReadGroupItem) Marshal 

func (m *ReadGroupItem) Marshal() (data []byte, err error)

func (*ReadGroupItem) MarshalTo 

func (m *ReadGroupItem) MarshalTo(data []byte) (int, error)

func (*ReadGroupItem) ProtoMessage 

func (*ReadGroupItem) ProtoMessage()

func (*ReadGroupItem) Reset 

func (m *ReadGroupItem) Reset()

func (*ReadGroupItem) Size 

func (m *ReadGroupItem) Size() (n int)

func (*ReadGroupItem) String 

func (m *ReadGroupItem) String() string

func (*ReadGroupItem) Unmarshal 

func (m *ReadGroupItem) Unmarshal(data []byte) error

type ReadGroupRequest 

type ReadGroupRequest struct {
	Rpcid uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	KeyA  uint64 `protobuf:"varint,2,opt,name=keyA,proto3" json:"keyA,omitempty"`
	KeyB  uint64 `protobuf:"varint,3,opt,name=keyB,proto3" json:"keyB,omitempty"`
}

func (*ReadGroupRequest) Descriptor 

func (*ReadGroupRequest) Descriptor() ([]byte, []int)

func (*ReadGroupRequest) Marshal 

func (m *ReadGroupRequest) Marshal() (data []byte, err error)

func (*ReadGroupRequest) MarshalTo 

func (m *ReadGroupRequest) MarshalTo(data []byte) (int, error)

func (*ReadGroupRequest) ProtoMessage 

func (*ReadGroupRequest) ProtoMessage()

func (*ReadGroupRequest) Reset 

func (m *ReadGroupRequest) Reset()

func (*ReadGroupRequest) Size 

func (m *ReadGroupRequest) Size() (n int)

func (*ReadGroupRequest) String 

func (m *ReadGroupRequest) String() string

func (*ReadGroupRequest) Unmarshal 

func (m *ReadGroupRequest) Unmarshal(data []byte) error

type ReadGroupResponse 

type ReadGroupResponse struct {
	Rpcid uint32           `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	Items []*ReadGroupItem `protobuf:"bytes,2,rep,name=items" json:"items,omitempty"`
	Err   string           `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
}

func (*ReadGroupResponse) Descriptor 

func (*ReadGroupResponse) Descriptor() ([]byte, []int)

func (*ReadGroupResponse) GetItems 

func (m *ReadGroupResponse) GetItems() []*ReadGroupItem

func (*ReadGroupResponse) Marshal 

func (m *ReadGroupResponse) Marshal() (data []byte, err error)

func (*ReadGroupResponse) MarshalTo 

func (m *ReadGroupResponse) MarshalTo(data []byte) (int, error)

func (*ReadGroupResponse) ProtoMessage 

func (*ReadGroupResponse) ProtoMessage()

func (*ReadGroupResponse) Reset 

func (m *ReadGroupResponse) Reset()

func (*ReadGroupResponse) Size 

func (m *ReadGroupResponse) Size() (n int)

func (*ReadGroupResponse) String 

func (m *ReadGroupResponse) String() string

func (*ReadGroupResponse) Unmarshal 

func (m *ReadGroupResponse) Unmarshal(data []byte) error

type ReadRequest 

type ReadRequest struct {
	Rpcid     uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	KeyA      uint64 `protobuf:"varint,2,opt,name=keyA,proto3" json:"keyA,omitempty"`
	KeyB      uint64 `protobuf:"varint,3,opt,name=keyB,proto3" json:"keyB,omitempty"`
	ChildKeyA uint64 `protobuf:"varint,4,opt,name=childKeyA,proto3" json:"childKeyA,omitempty"`
	ChildKeyB uint64 `protobuf:"varint,5,opt,name=childKeyB,proto3" json:"childKeyB,omitempty"`
}

func (*ReadRequest) Descriptor 

func (*ReadRequest) Descriptor() ([]byte, []int)

func (*ReadRequest) Marshal 

func (m *ReadRequest) Marshal() (data []byte, err error)

func (*ReadRequest) MarshalTo 

func (m *ReadRequest) MarshalTo(data []byte) (int, error)

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) Size 

func (m *ReadRequest) Size() (n int)

func (*ReadRequest) String 

func (m *ReadRequest) String() string

func (*ReadRequest) Unmarshal 

func (m *ReadRequest) Unmarshal(data []byte) error

type ReadResponse 

type ReadResponse struct {
	Rpcid          uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	TimestampMicro int64  `protobuf:"varint,2,opt,name=timestampMicro,proto3" json:"timestampMicro,omitempty"`
	Value          []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Err            string `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
}

func (*ReadResponse) Descriptor 

func (*ReadResponse) Descriptor() ([]byte, []int)

func (*ReadResponse) Marshal 

func (m *ReadResponse) Marshal() (data []byte, err error)

func (*ReadResponse) MarshalTo 

func (m *ReadResponse) MarshalTo(data []byte) (int, error)

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) Size 

func (m *ReadResponse) Size() (n int)

func (*ReadResponse) String 

func (m *ReadResponse) String() string

func (*ReadResponse) Unmarshal 

func (m *ReadResponse) Unmarshal(data []byte) error

type WriteRequest 

type WriteRequest struct {
	Rpcid          uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	KeyA           uint64 `protobuf:"varint,2,opt,name=keyA,proto3" json:"keyA,omitempty"`
	KeyB           uint64 `protobuf:"varint,3,opt,name=keyB,proto3" json:"keyB,omitempty"`
	ChildKeyA      uint64 `protobuf:"varint,4,opt,name=childKeyA,proto3" json:"childKeyA,omitempty"`
	ChildKeyB      uint64 `protobuf:"varint,5,opt,name=childKeyB,proto3" json:"childKeyB,omitempty"`
	Value          []byte `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
	TimestampMicro int64  `protobuf:"varint,7,opt,name=timestampMicro,proto3" json:"timestampMicro,omitempty"`
}

func (*WriteRequest) Descriptor 

func (*WriteRequest) Descriptor() ([]byte, []int)

func (*WriteRequest) Marshal 

func (m *WriteRequest) Marshal() (data []byte, err error)

func (*WriteRequest) MarshalTo 

func (m *WriteRequest) MarshalTo(data []byte) (int, error)

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

func (m *WriteRequest) Size() (n int)

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

func (m *WriteRequest) Unmarshal(data []byte) error

type WriteResponse 

type WriteResponse struct {
	Rpcid          uint32 `protobuf:"varint,1,opt,name=rpcid,proto3" json:"rpcid,omitempty"`
	TimestampMicro int64  `protobuf:"varint,2,opt,name=timestampMicro,proto3" json:"timestampMicro,omitempty"`
	Err            string `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
}

func (*WriteResponse) Descriptor 

func (*WriteResponse) Descriptor() ([]byte, []int)

func (*WriteResponse) Marshal 

func (m *WriteResponse) Marshal() (data []byte, err error)

func (*WriteResponse) MarshalTo 

func (m *WriteResponse) MarshalTo(data []byte) (int, error)

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) Size 

func (m *WriteResponse) Size() (n int)

func (*WriteResponse) String 

func (m *WriteResponse) String() string

func (*WriteResponse) Unmarshal 

func (m *WriteResponse) Unmarshal(data []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.