Documentation ¶
Overview ¶
Package pb is a generated protocol buffer package.
It is generated from these files:
github.com/eliquious/hraftd/pb/schema.proto
It has these top-level messages:
SetRequest DeleteRequest GetRequest JoinRequest GetResponse SetResponse DeleteResponse JoinResponse Command StreamResponse
Index ¶
- Variables
- func RegisterKeyValueServer(s *grpc.Server, srv KeyValueServer)
- type Command
- func (*Command) Descriptor() ([]byte, []int)
- func (this *Command) Equal(that interface{}) bool
- func (m *Command) Marshal() (data []byte, err error)
- func (m *Command) MarshalTo(data []byte) (int, error)
- func (*Command) ProtoMessage()
- func (m *Command) Reset()
- func (m *Command) Size() (n int)
- func (this *Command) String() string
- func (m *Command) Unmarshal(data []byte) error
- func (this *Command) VerboseEqual(that interface{}) error
- type CommandOp
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- func (this *DeleteRequest) Equal(that interface{}) bool
- func (m *DeleteRequest) Marshal() (data []byte, err error)
- func (m *DeleteRequest) MarshalTo(data []byte) (int, error)
- func (*DeleteRequest) ProtoMessage()
- func (m *DeleteRequest) Reset()
- func (m *DeleteRequest) Size() (n int)
- func (this *DeleteRequest) String() string
- func (m *DeleteRequest) Unmarshal(data []byte) error
- func (this *DeleteRequest) VerboseEqual(that interface{}) error
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)
- func (this *DeleteResponse) Equal(that interface{}) bool
- func (m *DeleteResponse) Marshal() (data []byte, err error)
- func (m *DeleteResponse) MarshalTo(data []byte) (int, error)
- func (*DeleteResponse) ProtoMessage()
- func (m *DeleteResponse) Reset()
- func (m *DeleteResponse) Size() (n int)
- func (this *DeleteResponse) String() string
- func (m *DeleteResponse) Unmarshal(data []byte) error
- func (this *DeleteResponse) VerboseEqual(that interface{}) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (this *GetRequest) Equal(that interface{}) bool
- func (m *GetRequest) Marshal() (data []byte, err error)
- func (m *GetRequest) MarshalTo(data []byte) (int, error)
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) Size() (n int)
- func (this *GetRequest) String() string
- func (m *GetRequest) Unmarshal(data []byte) error
- func (this *GetRequest) VerboseEqual(that interface{}) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (this *GetResponse) Equal(that interface{}) bool
- func (m *GetResponse) Marshal() (data []byte, err error)
- func (m *GetResponse) MarshalTo(data []byte) (int, error)
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) Size() (n int)
- func (this *GetResponse) String() string
- func (m *GetResponse) Unmarshal(data []byte) error
- func (this *GetResponse) VerboseEqual(that interface{}) error
- type JoinRequest
- func (*JoinRequest) Descriptor() ([]byte, []int)
- func (this *JoinRequest) Equal(that interface{}) bool
- func (m *JoinRequest) Marshal() (data []byte, err error)
- func (m *JoinRequest) MarshalTo(data []byte) (int, error)
- func (*JoinRequest) ProtoMessage()
- func (m *JoinRequest) Reset()
- func (m *JoinRequest) Size() (n int)
- func (this *JoinRequest) String() string
- func (m *JoinRequest) Unmarshal(data []byte) error
- func (this *JoinRequest) VerboseEqual(that interface{}) error
- type JoinResponse
- func (*JoinResponse) Descriptor() ([]byte, []int)
- func (this *JoinResponse) Equal(that interface{}) bool
- func (m *JoinResponse) Marshal() (data []byte, err error)
- func (m *JoinResponse) MarshalTo(data []byte) (int, error)
- func (*JoinResponse) ProtoMessage()
- func (m *JoinResponse) Reset()
- func (m *JoinResponse) Size() (n int)
- func (this *JoinResponse) String() string
- func (m *JoinResponse) Unmarshal(data []byte) error
- func (this *JoinResponse) VerboseEqual(that interface{}) error
- type KeyValueClient
- type KeyValueServer
- type KeyValue_StreamClient
- type KeyValue_StreamServer
- type SetRequest
- func (*SetRequest) Descriptor() ([]byte, []int)
- func (this *SetRequest) Equal(that interface{}) bool
- func (m *SetRequest) Marshal() (data []byte, err error)
- func (m *SetRequest) MarshalTo(data []byte) (int, error)
- func (*SetRequest) ProtoMessage()
- func (m *SetRequest) Reset()
- func (m *SetRequest) Size() (n int)
- func (this *SetRequest) String() string
- func (m *SetRequest) Unmarshal(data []byte) error
- func (this *SetRequest) VerboseEqual(that interface{}) error
- type SetResponse
- func (*SetResponse) Descriptor() ([]byte, []int)
- func (this *SetResponse) Equal(that interface{}) bool
- func (m *SetResponse) Marshal() (data []byte, err error)
- func (m *SetResponse) MarshalTo(data []byte) (int, error)
- func (*SetResponse) ProtoMessage()
- func (m *SetResponse) Reset()
- func (m *SetResponse) Size() (n int)
- func (this *SetResponse) String() string
- func (m *SetResponse) Unmarshal(data []byte) error
- func (this *SetResponse) VerboseEqual(that interface{}) error
- type StreamResponse
- func (*StreamResponse) Descriptor() ([]byte, []int)
- func (this *StreamResponse) Equal(that interface{}) bool
- func (m *StreamResponse) Marshal() (data []byte, err error)
- func (m *StreamResponse) MarshalTo(data []byte) (int, error)
- func (*StreamResponse) ProtoMessage()
- func (m *StreamResponse) Reset()
- func (m *StreamResponse) Size() (n int)
- func (this *StreamResponse) String() string
- func (m *StreamResponse) Unmarshal(data []byte) error
- func (this *StreamResponse) VerboseEqual(that interface{}) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthSchema = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSchema = fmt.Errorf("proto: integer overflow") )
View Source
var CommandOp_name = map[int32]string{
0: "UNKNOWN",
1: "GET",
2: "SET",
3: "DELETE",
}
View Source
var CommandOp_value = map[string]int32{
"UNKNOWN": 0,
"GET": 1,
"SET": 2,
"DELETE": 3,
}
Functions ¶
func RegisterKeyValueServer ¶
func RegisterKeyValueServer(s *grpc.Server, srv KeyValueServer)
Types ¶
type Command ¶
type Command struct { Op CommandOp `protobuf:"varint,1,opt,name=Op,json=op,proto3,enum=pb.CommandOp" json:"Op,omitempty"` Key string `protobuf:"bytes,2,opt,name=Key,json=key,proto3" json:"Key,omitempty"` Value string `protobuf:"bytes,3,opt,name=Value,json=value,proto3" json:"Value,omitempty"` }
func NewPopulatedCommand ¶
func (*Command) Descriptor ¶
func (*Command) ProtoMessage ¶
func (*Command) ProtoMessage()
func (*Command) VerboseEqual ¶
type DeleteRequest ¶
type DeleteRequest struct {
Key string `protobuf:"bytes,1,opt,name=Key,json=key,proto3" json:"Key,omitempty"`
}
func NewPopulatedDeleteRequest ¶
func NewPopulatedDeleteRequest(r randySchema, easy bool) *DeleteRequest
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) Equal ¶
func (this *DeleteRequest) Equal(that interface{}) bool
func (*DeleteRequest) Marshal ¶
func (m *DeleteRequest) Marshal() (data []byte, err 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 (this *DeleteRequest) String() string
func (*DeleteRequest) Unmarshal ¶
func (m *DeleteRequest) Unmarshal(data []byte) error
func (*DeleteRequest) VerboseEqual ¶
func (this *DeleteRequest) VerboseEqual(that interface{}) error
type DeleteResponse ¶
type DeleteResponse struct { }
func NewPopulatedDeleteResponse ¶
func NewPopulatedDeleteResponse(r randySchema, easy bool) *DeleteResponse
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) Equal ¶
func (this *DeleteResponse) Equal(that interface{}) bool
func (*DeleteResponse) Marshal ¶
func (m *DeleteResponse) Marshal() (data []byte, err 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 (this *DeleteResponse) String() string
func (*DeleteResponse) Unmarshal ¶
func (m *DeleteResponse) Unmarshal(data []byte) error
func (*DeleteResponse) VerboseEqual ¶
func (this *DeleteResponse) VerboseEqual(that interface{}) error
type GetRequest ¶
type GetRequest struct {
Key string `protobuf:"bytes,1,opt,name=Key,json=key,proto3" json:"Key,omitempty"`
}
func NewPopulatedGetRequest ¶
func NewPopulatedGetRequest(r randySchema, easy bool) *GetRequest
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) Equal ¶
func (this *GetRequest) Equal(that interface{}) bool
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (data []byte, err error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) Size ¶
func (m *GetRequest) Size() (n int)
func (*GetRequest) String ¶
func (this *GetRequest) String() string
func (*GetRequest) Unmarshal ¶
func (m *GetRequest) Unmarshal(data []byte) error
func (*GetRequest) VerboseEqual ¶
func (this *GetRequest) VerboseEqual(that interface{}) error
type GetResponse ¶
type GetResponse struct {
Value string `protobuf:"bytes,1,opt,name=Value,json=value,proto3" json:"Value,omitempty"`
}
func NewPopulatedGetResponse ¶
func NewPopulatedGetResponse(r randySchema, easy bool) *GetResponse
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) Equal ¶
func (this *GetResponse) Equal(that interface{}) bool
func (*GetResponse) Marshal ¶
func (m *GetResponse) Marshal() (data []byte, err error)
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) Size ¶
func (m *GetResponse) Size() (n int)
func (*GetResponse) String ¶
func (this *GetResponse) String() string
func (*GetResponse) Unmarshal ¶
func (m *GetResponse) Unmarshal(data []byte) error
func (*GetResponse) VerboseEqual ¶
func (this *GetResponse) VerboseEqual(that interface{}) error
type JoinRequest ¶
type JoinRequest struct {
RemoteAddr string `protobuf:"bytes,1,opt,name=RemoteAddr,json=remoteAddr,proto3" json:"RemoteAddr,omitempty"`
}
func NewPopulatedJoinRequest ¶
func NewPopulatedJoinRequest(r randySchema, easy bool) *JoinRequest
func (*JoinRequest) Descriptor ¶
func (*JoinRequest) Descriptor() ([]byte, []int)
func (*JoinRequest) Equal ¶
func (this *JoinRequest) Equal(that interface{}) bool
func (*JoinRequest) Marshal ¶
func (m *JoinRequest) Marshal() (data []byte, err error)
func (*JoinRequest) ProtoMessage ¶
func (*JoinRequest) ProtoMessage()
func (*JoinRequest) Reset ¶
func (m *JoinRequest) Reset()
func (*JoinRequest) Size ¶
func (m *JoinRequest) Size() (n int)
func (*JoinRequest) String ¶
func (this *JoinRequest) String() string
func (*JoinRequest) Unmarshal ¶
func (m *JoinRequest) Unmarshal(data []byte) error
func (*JoinRequest) VerboseEqual ¶
func (this *JoinRequest) VerboseEqual(that interface{}) error
type JoinResponse ¶
type JoinResponse struct { }
func NewPopulatedJoinResponse ¶
func NewPopulatedJoinResponse(r randySchema, easy bool) *JoinResponse
func (*JoinResponse) Descriptor ¶
func (*JoinResponse) Descriptor() ([]byte, []int)
func (*JoinResponse) Equal ¶
func (this *JoinResponse) Equal(that interface{}) bool
func (*JoinResponse) Marshal ¶
func (m *JoinResponse) Marshal() (data []byte, err error)
func (*JoinResponse) ProtoMessage ¶
func (*JoinResponse) ProtoMessage()
func (*JoinResponse) Reset ¶
func (m *JoinResponse) Reset()
func (*JoinResponse) Size ¶
func (m *JoinResponse) Size() (n int)
func (*JoinResponse) String ¶
func (this *JoinResponse) String() string
func (*JoinResponse) Unmarshal ¶
func (m *JoinResponse) Unmarshal(data []byte) error
func (*JoinResponse) VerboseEqual ¶
func (this *JoinResponse) VerboseEqual(that interface{}) error
type KeyValueClient ¶
type KeyValueClient interface { Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error) Stream(ctx context.Context, opts ...grpc.CallOption) (KeyValue_StreamClient, error) }
func NewKeyValueClient ¶
func NewKeyValueClient(cc *grpc.ClientConn) KeyValueClient
type KeyValueServer ¶
type KeyValueServer interface { Set(context.Context, *SetRequest) (*SetResponse, error) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) Get(context.Context, *GetRequest) (*GetResponse, error) Join(context.Context, *JoinRequest) (*JoinResponse, error) Stream(KeyValue_StreamServer) error }
type KeyValue_StreamClient ¶
type KeyValue_StreamClient interface { Send(*Command) error Recv() (*StreamResponse, error) grpc.ClientStream }
type KeyValue_StreamServer ¶
type KeyValue_StreamServer interface { Send(*StreamResponse) error Recv() (*Command, error) grpc.ServerStream }
type SetRequest ¶
type SetRequest struct { Key string `protobuf:"bytes,1,opt,name=Key,json=key,proto3" json:"Key,omitempty"` Value string `protobuf:"bytes,2,opt,name=Value,json=value,proto3" json:"Value,omitempty"` }
func NewPopulatedSetRequest ¶
func NewPopulatedSetRequest(r randySchema, easy bool) *SetRequest
func (*SetRequest) Descriptor ¶
func (*SetRequest) Descriptor() ([]byte, []int)
func (*SetRequest) Equal ¶
func (this *SetRequest) Equal(that interface{}) bool
func (*SetRequest) Marshal ¶
func (m *SetRequest) Marshal() (data []byte, err error)
func (*SetRequest) ProtoMessage ¶
func (*SetRequest) ProtoMessage()
func (*SetRequest) Reset ¶
func (m *SetRequest) Reset()
func (*SetRequest) Size ¶
func (m *SetRequest) Size() (n int)
func (*SetRequest) String ¶
func (this *SetRequest) String() string
func (*SetRequest) Unmarshal ¶
func (m *SetRequest) Unmarshal(data []byte) error
func (*SetRequest) VerboseEqual ¶
func (this *SetRequest) VerboseEqual(that interface{}) error
type SetResponse ¶
type SetResponse struct { }
func NewPopulatedSetResponse ¶
func NewPopulatedSetResponse(r randySchema, easy bool) *SetResponse
func (*SetResponse) Descriptor ¶
func (*SetResponse) Descriptor() ([]byte, []int)
func (*SetResponse) Equal ¶
func (this *SetResponse) Equal(that interface{}) bool
func (*SetResponse) Marshal ¶
func (m *SetResponse) Marshal() (data []byte, err error)
func (*SetResponse) ProtoMessage ¶
func (*SetResponse) ProtoMessage()
func (*SetResponse) Reset ¶
func (m *SetResponse) Reset()
func (*SetResponse) Size ¶
func (m *SetResponse) Size() (n int)
func (*SetResponse) String ¶
func (this *SetResponse) String() string
func (*SetResponse) Unmarshal ¶
func (m *SetResponse) Unmarshal(data []byte) error
func (*SetResponse) VerboseEqual ¶
func (this *SetResponse) VerboseEqual(that interface{}) error
type StreamResponse ¶
type StreamResponse struct { }
func NewPopulatedStreamResponse ¶
func NewPopulatedStreamResponse(r randySchema, easy bool) *StreamResponse
func (*StreamResponse) Descriptor ¶
func (*StreamResponse) Descriptor() ([]byte, []int)
func (*StreamResponse) Equal ¶
func (this *StreamResponse) Equal(that interface{}) bool
func (*StreamResponse) Marshal ¶
func (m *StreamResponse) Marshal() (data []byte, err error)
func (*StreamResponse) ProtoMessage ¶
func (*StreamResponse) ProtoMessage()
func (*StreamResponse) Reset ¶
func (m *StreamResponse) Reset()
func (*StreamResponse) Size ¶
func (m *StreamResponse) Size() (n int)
func (*StreamResponse) String ¶
func (this *StreamResponse) String() string
func (*StreamResponse) Unmarshal ¶
func (m *StreamResponse) Unmarshal(data []byte) error
func (*StreamResponse) VerboseEqual ¶
func (this *StreamResponse) VerboseEqual(that interface{}) error
Click to show internal directories.
Click to hide internal directories.