proto

Documentation

Index

• Variables
• func RegisterKVServer(s *grpc.Server, srv KVServer)
• type KVClient
  • func NewKVClient(cc grpc.ClientConnInterface) KVClient
• type KVServer
• type TumboRequest
  • func (*TumboRequest) Descriptor() ([]byte, []int)
  • func (x *TumboRequest) GetKey() string
  • func (*TumboRequest) ProtoMessage()
  • func (x *TumboRequest) ProtoReflect() protoreflect.Message
  • func (x *TumboRequest) Reset()
  • func (x *TumboRequest) String() string
• type TumboResponse
  • func (*TumboResponse) Descriptor() ([]byte, []int)
  • func (x *TumboResponse) GetValue() []byte
  • func (*TumboResponse) ProtoMessage()
  • func (x *TumboResponse) ProtoReflect() protoreflect.Message
  • func (x *TumboResponse) Reset()
  • func (x *TumboResponse) String() string
• type UnimplementedKVServer
  • func (*UnimplementedKVServer) Execute(context.Context, *TumboRequest) (*TumboResponse, error)

Variables

var File_kv_proto protoreflect.FileDescriptor

Functions

func RegisterKVServer

func RegisterKVServer(s *grpc.Server, srv KVServer)

Types

type KVClient

type KVClient interface {
	Execute(ctx context.Context, in *TumboRequest, opts ...grpc.CallOption) (*TumboResponse, error)
}

KVClient is the client API for KV service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewKVClient

func NewKVClient(cc grpc.ClientConnInterface) KVClient

type KVServer

type KVServer interface {
	Execute(context.Context, *TumboRequest) (*TumboResponse, error)
}

KVServer is the server API for KV service.

type TumboRequest

type TumboRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*TumboRequest) Descriptor

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

Deprecated: Use TumboRequest.ProtoReflect.Descriptor instead.

func (*TumboRequest) GetKey

func (x *TumboRequest) GetKey() string

func (*TumboRequest) ProtoMessage

func (*TumboRequest) ProtoMessage()

func (*TumboRequest) ProtoReflect

func (x *TumboRequest) ProtoReflect() protoreflect.Message

func (*TumboRequest) Reset

func (x *TumboRequest) Reset()

func (*TumboRequest) String

func (x *TumboRequest) String() string

type TumboResponse

type TumboResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TumboResponse) Descriptor

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

Deprecated: Use TumboResponse.ProtoReflect.Descriptor instead.

func (*TumboResponse) GetValue

func (x *TumboResponse) GetValue() []byte

func (*TumboResponse) ProtoMessage

func (*TumboResponse) ProtoMessage()

func (*TumboResponse) ProtoReflect

func (x *TumboResponse) ProtoReflect() protoreflect.Message

func (*TumboResponse) Reset

func (x *TumboResponse) Reset()

func (*TumboResponse) String

func (x *TumboResponse) String() string

type UnimplementedKVServer

type UnimplementedKVServer struct {
}

UnimplementedKVServer can be embedded to have forward compatible implementations.

func (*UnimplementedKVServer) Execute

func (*UnimplementedKVServer) Execute(context.Context, *TumboRequest) (*TumboResponse, error)