groupproto

package
v0.0.0-...-4de1a88 Latest Latest
Warning

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

 Go to latest Published: May 5, 2017 License: Apache-2.0 Imports: 5 Imported by: 4

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: 

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterGroupStoreServer 

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

Types

type DeleteRequest 

type DeleteRequest struct {
	RPCID          uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"`
	KeyA           uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"`
	KeyB           uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"`
	ChildKeyA      uint64 `protobuf:"varint,4,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"`
	ChildKeyB      uint64 `protobuf:"varint,5,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"`
	TimestampMicro int64  `protobuf:"varint,6,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetChildKeyA 

func (m *DeleteRequest) GetChildKeyA() uint64

func (*DeleteRequest) GetChildKeyB 

func (m *DeleteRequest) GetChildKeyB() uint64

func (*DeleteRequest) GetKeyA 

func (m *DeleteRequest) GetKeyA() uint64

func (*DeleteRequest) GetKeyB 

func (m *DeleteRequest) GetKeyB() uint64

func (*DeleteRequest) GetRPCID 

func (m *DeleteRequest) GetRPCID() uint32

func (*DeleteRequest) GetTimestampMicro 

func (m *DeleteRequest) GetTimestampMicro() int64

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

type DeleteResponse 

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

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) GetErr 

func (m *DeleteResponse) GetErr() string

func (*DeleteResponse) GetRPCID 

func (m *DeleteResponse) GetRPCID() uint32

func (*DeleteResponse) GetTimestampMicro 

func (m *DeleteResponse) GetTimestampMicro() int64

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

type GroupStoreClient 

type GroupStoreClient interface {
	Delete(ctx context.Context, opts ...grpc.CallOption) (GroupStore_DeleteClient, error)
	LookupGroup(ctx context.Context, opts ...grpc.CallOption) (GroupStore_LookupGroupClient, error)
	Lookup(ctx context.Context, opts ...grpc.CallOption) (GroupStore_LookupClient, error)
	ReadGroup(ctx context.Context, opts ...grpc.CallOption) (GroupStore_ReadGroupClient, error)
	Read(ctx context.Context, opts ...grpc.CallOption) (GroupStore_ReadClient, error)
	Write(ctx context.Context, opts ...grpc.CallOption) (GroupStore_WriteClient, error)
}

func NewGroupStoreClient 

func NewGroupStoreClient(cc *grpc.ClientConn) GroupStoreClient

type GroupStoreServer 

type GroupStoreServer interface {
	Delete(GroupStore_DeleteServer) error
	LookupGroup(GroupStore_LookupGroupServer) error
	Lookup(GroupStore_LookupServer) error
	ReadGroup(GroupStore_ReadGroupServer) error
	Read(GroupStore_ReadServer) error
	Write(GroupStore_WriteServer) error
}

type GroupStore_DeleteClient 

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

type GroupStore_DeleteServer 

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

type GroupStore_LookupClient 

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

type GroupStore_LookupGroupClient 

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

type GroupStore_LookupGroupServer 

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

type GroupStore_LookupServer 

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

type GroupStore_ReadClient 

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

type GroupStore_ReadGroupClient 

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

type GroupStore_ReadGroupServer 

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

type GroupStore_ReadServer 

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

type GroupStore_WriteClient 

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

type GroupStore_WriteServer 

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

type LookupGroupItem 

type LookupGroupItem struct {
	RPCID          uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"`
	ChildKeyA      uint64 `protobuf:"varint,2,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"`
	ChildKeyB      uint64 `protobuf:"varint,3,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"`
	TimestampMicro int64  `protobuf:"varint,4,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"`
	Length         uint32 `protobuf:"varint,5,opt,name=Length" json:"Length,omitempty"`
}

func (*LookupGroupItem) Descriptor 

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

func (*LookupGroupItem) GetChildKeyA 

func (m *LookupGroupItem) GetChildKeyA() uint64

func (*LookupGroupItem) GetChildKeyB 

func (m *LookupGroupItem) GetChildKeyB() uint64

func (*LookupGroupItem) GetLength 

func (m *LookupGroupItem) GetLength() uint32

func (*LookupGroupItem) GetRPCID 

func (m *LookupGroupItem) GetRPCID() uint32

func (*LookupGroupItem) GetTimestampMicro 

func (m *LookupGroupItem) GetTimestampMicro() int64

func (*LookupGroupItem) ProtoMessage 

func (*LookupGroupItem) ProtoMessage()

func (*LookupGroupItem) Reset 

func (m *LookupGroupItem) Reset()

func (*LookupGroupItem) String 

func (m *LookupGroupItem) String() string

type LookupGroupRequest 

type LookupGroupRequest struct {
	RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"`
	KeyA  uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"`
	KeyB  uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"`
}

func (*LookupGroupRequest) Descriptor 

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

func (*LookupGroupRequest) GetKeyA 

func (m *LookupGroupRequest) GetKeyA() uint64

func (*LookupGroupRequest) GetKeyB 

func (m *LookupGroupRequest) GetKeyB() uint64

func (*LookupGroupRequest) GetRPCID 

func (m *LookupGroupRequest) GetRPCID() uint32

func (*LookupGroupRequest) ProtoMessage 

func (*LookupGroupRequest) ProtoMessage()

func (*LookupGroupRequest) Reset 

func (m *LookupGroupRequest) Reset()

func (*LookupGroupRequest) String 

func (m *LookupGroupRequest) String() string

type LookupGroupResponse 

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

func (*LookupGroupResponse) Descriptor 

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

func (*LookupGroupResponse) GetErr 

func (m *LookupGroupResponse) GetErr() string

func (*LookupGroupResponse) GetItems 

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

func (*LookupGroupResponse) GetRPCID 

func (m *LookupGroupResponse) GetRPCID() uint32

func (*LookupGroupResponse) ProtoMessage 

func (*LookupGroupResponse) ProtoMessage()

func (*LookupGroupResponse) Reset 

func (m *LookupGroupResponse) Reset()

func (*LookupGroupResponse) String 

func (m *LookupGroupResponse) String() string

type LookupRequest 

type LookupRequest struct {
	RPCID     uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"`
	KeyA      uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"`
	KeyB      uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"`
	ChildKeyA uint64 `protobuf:"varint,4,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"`
	ChildKeyB uint64 `protobuf:"varint,5,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"`
}

func (*LookupRequest) Descriptor 

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

func (*LookupRequest) GetChildKeyA 

func (m *LookupRequest) GetChildKeyA() uint64

func (*LookupRequest) GetChildKeyB 

func (m *LookupRequest) GetChildKeyB() uint64

func (*LookupRequest) GetKeyA 

func (m *LookupRequest) GetKeyA() uint64

func (*LookupRequest) GetKeyB 

func (m *LookupRequest) GetKeyB() uint64

func (*LookupRequest) GetRPCID 

func (m *LookupRequest) GetRPCID() uint32

func (*LookupRequest) ProtoMessage 

func (*LookupRequest) ProtoMessage()

func (*LookupRequest) Reset 

func (m *LookupRequest) Reset()

func (*LookupRequest) String 

func (m *LookupRequest) String() string

type LookupResponse 

type LookupResponse struct {
	RPCID          uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"`
	TimestampMicro int64  `protobuf:"varint,2,opt,name=TimestampMicro" json:"TimestampMicro,omitempty"`
	Length         uint32 `protobuf:"varint,3,opt,name=Length" json:"Length,omitempty"`
	Err            string `protobuf:"bytes,4,opt,name=Err" json:"Err,omitempty"`
}

func (*LookupResponse) Descriptor 

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

func (*LookupResponse) GetErr 

func (m *LookupResponse) GetErr() string

func (*LookupResponse) GetLength 

func (m *LookupResponse) GetLength() uint32

func (*LookupResponse) GetRPCID 

func (m *LookupResponse) GetRPCID() uint32

func (*LookupResponse) GetTimestampMicro 

func (m *LookupResponse) GetTimestampMicro() int64

func (*LookupResponse) ProtoMessage 

func (*LookupResponse) ProtoMessage()

func (*LookupResponse) Reset 

func (m *LookupResponse) Reset()

func (*LookupResponse) String 

func (m *LookupResponse) String() string

type ReadGroupItem 

type ReadGroupItem struct {
	RPCID          uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"`
	ChildKeyA      uint64 `protobuf:"varint,2,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"`
	ChildKeyB      uint64 `protobuf:"varint,3,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"`
	TimestampMicro int64  `protobuf:"varint,4,opt,name=TimestampMicro" 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) GetChildKeyA 

func (m *ReadGroupItem) GetChildKeyA() uint64

func (*ReadGroupItem) GetChildKeyB 

func (m *ReadGroupItem) GetChildKeyB() uint64

func (*ReadGroupItem) GetRPCID 

func (m *ReadGroupItem) GetRPCID() uint32

func (*ReadGroupItem) GetTimestampMicro 

func (m *ReadGroupItem) GetTimestampMicro() int64

func (*ReadGroupItem) GetValue 

func (m *ReadGroupItem) GetValue() []byte

func (*ReadGroupItem) ProtoMessage 

func (*ReadGroupItem) ProtoMessage()

func (*ReadGroupItem) Reset 

func (m *ReadGroupItem) Reset()

func (*ReadGroupItem) String 

func (m *ReadGroupItem) String() string

type ReadGroupRequest 

type ReadGroupRequest struct {
	RPCID uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"`
	KeyA  uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"`
	KeyB  uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"`
}

func (*ReadGroupRequest) Descriptor 

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

func (*ReadGroupRequest) GetKeyA 

func (m *ReadGroupRequest) GetKeyA() uint64

func (*ReadGroupRequest) GetKeyB 

func (m *ReadGroupRequest) GetKeyB() uint64

func (*ReadGroupRequest) GetRPCID 

func (m *ReadGroupRequest) GetRPCID() uint32

func (*ReadGroupRequest) ProtoMessage 

func (*ReadGroupRequest) ProtoMessage()

func (*ReadGroupRequest) Reset 

func (m *ReadGroupRequest) Reset()

func (*ReadGroupRequest) String 

func (m *ReadGroupRequest) String() string

type ReadGroupResponse 

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

func (*ReadGroupResponse) Descriptor 

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

func (*ReadGroupResponse) GetErr 

func (m *ReadGroupResponse) GetErr() string

func (*ReadGroupResponse) GetItems 

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

func (*ReadGroupResponse) GetRPCID 

func (m *ReadGroupResponse) GetRPCID() uint32

func (*ReadGroupResponse) ProtoMessage 

func (*ReadGroupResponse) ProtoMessage()

func (*ReadGroupResponse) Reset 

func (m *ReadGroupResponse) Reset()

func (*ReadGroupResponse) String 

func (m *ReadGroupResponse) String() string

type ReadRequest 

type ReadRequest struct {
	RPCID     uint32 `protobuf:"varint,1,opt,name=RPCID" json:"RPCID,omitempty"`
	KeyA      uint64 `protobuf:"varint,2,opt,name=KeyA" json:"KeyA,omitempty"`
	KeyB      uint64 `protobuf:"varint,3,opt,name=KeyB" json:"KeyB,omitempty"`
	ChildKeyA uint64 `protobuf:"varint,4,opt,name=ChildKeyA" json:"ChildKeyA,omitempty"`
	ChildKeyB uint64 `protobuf:"varint,5,opt,name=ChildKeyB" json:"ChildKeyB,omitempty"`
}

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) GetChildKeyA 

func (m *ReadRequest) GetChildKeyA() uint64

func (*ReadRequest) GetChildKeyB 

func (m *ReadRequest) GetChildKeyB() uint64

func (*ReadRequest) GetKeyA 

func (m *ReadRequest) GetKeyA() uint64

func (*ReadRequest) GetKeyB 

func (m *ReadRequest) GetKeyB() uint64

func (*ReadRequest) GetRPCID 

func (m *ReadRequest) GetRPCID() uint32

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) String 

func (m *ReadRequest) String() string

type ReadResponse 

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

func (*ReadResponse) Descriptor 

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

func (*ReadResponse) GetErr 

func (m *ReadResponse) GetErr() string

func (*ReadResponse) GetRPCID 

func (m *ReadResponse) GetRPCID() uint32

func (*ReadResponse) GetTimestampMicro 

func (m *ReadResponse) GetTimestampMicro() int64

func (*ReadResponse) GetValue 

func (m *ReadResponse) GetValue() []byte

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) String 

func (m *ReadResponse) String() string

type WriteRequest 

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

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetChildKeyA 

func (m *WriteRequest) GetChildKeyA() uint64

func (*WriteRequest) GetChildKeyB 

func (m *WriteRequest) GetChildKeyB() uint64

func (*WriteRequest) GetKeyA 

func (m *WriteRequest) GetKeyA() uint64

func (*WriteRequest) GetKeyB 

func (m *WriteRequest) GetKeyB() uint64

func (*WriteRequest) GetRPCID 

func (m *WriteRequest) GetRPCID() uint32

func (*WriteRequest) GetTimestampMicro 

func (m *WriteRequest) GetTimestampMicro() int64

func (*WriteRequest) GetValue 

func (m *WriteRequest) GetValue() []byte

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

type WriteResponse 

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

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) GetErr 

func (m *WriteResponse) GetErr() string

func (*WriteResponse) GetRPCID 

func (m *WriteResponse) GetRPCID() uint32

func (*WriteResponse) GetTimestampMicro 

func (m *WriteResponse) GetTimestampMicro() int64

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) String 

func (m *WriteResponse) String() string

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.