pb

package
v0.0.0-...-a03c61b Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2016 License: MIT Imports: 9 Imported by: 0

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

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 NewPopulatedCommand(r randySchema, easy bool) *Command

func (*Command) Descriptor 

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

func (*Command) Equal 

func (this *Command) Equal(that interface{}) bool

func (*Command) Marshal 

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

func (*Command) MarshalTo 

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

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) Size 

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

func (*Command) String 

func (this *Command) String() string

func (*Command) Unmarshal 

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

func (*Command) VerboseEqual 

func (this *Command) VerboseEqual(that interface{}) error

type CommandOp 

type CommandOp int32
const (
	CommandOp_UNKNOWN CommandOp = 0
	CommandOp_GET     CommandOp = 1
	CommandOp_SET     CommandOp = 2
	CommandOp_DELETE  CommandOp = 3
)

func (CommandOp) EnumDescriptor 

func (CommandOp) EnumDescriptor() ([]byte, []int)

func (CommandOp) String 

func (x CommandOp) String() string

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) 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 (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) 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 (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) MarshalTo 

func (m *GetRequest) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *GetResponse) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *JoinRequest) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *JoinResponse) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *SetRequest) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *SetResponse) MarshalTo(data []byte) (int, 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) MarshalTo 

func (m *StreamResponse) MarshalTo(data []byte) (int, 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

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.