grpc

type Empty ¶

type Empty struct {
}

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

func (*Empty) ProtoMessage()

func (m *Empty) Reset()

func (m *Empty) String() string

type Service ¶

type Service struct{}

@todo The GET/PUT req/res cycle is suboptimal under the hood currently. Put Messages get marshalled in the client, unmarshalled on the server, then stored. Get Messages get marshalled on the server, and unmarshalled in the client. Ideally we could skip the Put unmarshalling and Get marshalling on the server, limit messages to just the raw payload (passing keys as metadata instead), and store the already marshalled payloads directly, to skip double encoding. Note that this would require a custom codec and ideally just for the ItemsStore, so the protos would need to be split accordingly and the service would likely not be able to use most of the auto generated defs.

func (s *Service) Delete(ctx context.Context, in *StoreDeleteRequest) (*Empty, error)

func (s *Service) Get(ctx context.Context, in *StoreGetRequest) (*StoreGetResponse, error)

func (s *Service) Put(ctx context.Context, in *StorePutRequest) (*Empty, error)

type StoreClient ¶

type StoreClient interface {
	Get(ctx context.Context, in *StoreGetRequest, opts ...grpc1.CallOption) (*StoreGetResponse, error)
	Put(ctx context.Context, in *StorePutRequest, opts ...grpc1.CallOption) (*Empty, error)
	Delete(ctx context.Context, in *StoreDeleteRequest, opts ...grpc1.CallOption) (*Empty, error)
}

func NewStoreClient(cc *grpc1.ClientConn) StoreClient

type StoreDeleteRequest ¶

type StoreDeleteRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
}

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

func (m *StoreDeleteRequest) GetKey() string

func (*StoreDeleteRequest) ProtoMessage()

func (m *StoreDeleteRequest) Reset()

func (m *StoreDeleteRequest) String() string

type StoreGetRequest ¶

type StoreGetRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
}

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

func (m *StoreGetRequest) GetKey() string

func (*StoreGetRequest) ProtoMessage()

func (m *StoreGetRequest) Reset()

func (m *StoreGetRequest) String() string

type StoreGetResponse ¶

type StoreGetResponse struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

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

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

func (*StoreGetResponse) ProtoMessage()

func (m *StoreGetResponse) Reset()

func (m *StoreGetResponse) String() string

type StorePutRequest ¶

type StorePutRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

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

func (m *StorePutRequest) GetKey() string

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

func (*StorePutRequest) ProtoMessage()

func (m *StorePutRequest) Reset()

func (m *StorePutRequest) String() string

type StoreServer ¶

type StoreServer interface {
	Get(context.Context, *StoreGetRequest) (*StoreGetResponse, error)
	Put(context.Context, *StorePutRequest) (*Empty, error)
	Delete(context.Context, *StoreDeleteRequest) (*Empty, error)
}