proto

package
v0.1.6 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2019 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterCacheServer 

func RegisterCacheServer(s *grpc.Server, srv CacheServer)

func RegisterCounterServer 

func RegisterCounterServer(s *grpc.Server, srv CounterServer)

func RegisterFlagServer 

func RegisterFlagServer(s *grpc.Server, srv FlagServer)

func RegisterKVServer 

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

func RegisterSetServer 

func RegisterSetServer(s *grpc.Server, srv SetServer)

Types

type CacheClient 

type CacheClient interface {
	CacheGet(ctx context.Context, in *CacheGetRequest, opts ...grpc.CallOption) (*CacheGetResponse, error)
	CacheSet(ctx context.Context, in *CacheSetRequest, opts ...grpc.CallOption) (*Empty, error)
}

CacheClient is the client API for Cache service.

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

func NewCacheClient 

func NewCacheClient(cc *grpc.ClientConn) CacheClient

type CacheGetRequest 

type CacheGetRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CacheGetRequest) Descriptor 

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

func (*CacheGetRequest) GetKey 

func (m *CacheGetRequest) GetKey() string

func (*CacheGetRequest) ProtoMessage 

func (*CacheGetRequest) ProtoMessage()

func (*CacheGetRequest) Reset 

func (m *CacheGetRequest) Reset()

func (*CacheGetRequest) String 

func (m *CacheGetRequest) String() string

func (*CacheGetRequest) XXX_DiscardUnknown 

func (m *CacheGetRequest) XXX_DiscardUnknown()

func (*CacheGetRequest) XXX_Marshal 

func (m *CacheGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CacheGetRequest) XXX_Merge 

func (m *CacheGetRequest) XXX_Merge(src proto.Message)

func (*CacheGetRequest) XXX_Size 

func (m *CacheGetRequest) XXX_Size() int

func (*CacheGetRequest) XXX_Unmarshal 

func (m *CacheGetRequest) XXX_Unmarshal(b []byte) error

type CacheGetResponse 

type CacheGetResponse struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CacheGetResponse) Descriptor 

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

func (*CacheGetResponse) GetValue 

func (m *CacheGetResponse) GetValue() string

func (*CacheGetResponse) ProtoMessage 

func (*CacheGetResponse) ProtoMessage()

func (*CacheGetResponse) Reset 

func (m *CacheGetResponse) Reset()

func (*CacheGetResponse) String 

func (m *CacheGetResponse) String() string

func (*CacheGetResponse) XXX_DiscardUnknown 

func (m *CacheGetResponse) XXX_DiscardUnknown()

func (*CacheGetResponse) XXX_Marshal 

func (m *CacheGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CacheGetResponse) XXX_Merge 

func (m *CacheGetResponse) XXX_Merge(src proto.Message)

func (*CacheGetResponse) XXX_Size 

func (m *CacheGetResponse) XXX_Size() int

func (*CacheGetResponse) XXX_Unmarshal 

func (m *CacheGetResponse) XXX_Unmarshal(b []byte) error

type CacheItem 

type CacheItem struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Ttl                  int32    `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CacheItem) Descriptor 

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

func (*CacheItem) GetTtl 

func (m *CacheItem) GetTtl() int32

func (*CacheItem) GetValue 

func (m *CacheItem) GetValue() string

func (*CacheItem) ProtoMessage 

func (*CacheItem) ProtoMessage()

func (*CacheItem) Reset 

func (m *CacheItem) Reset()

func (*CacheItem) String 

func (m *CacheItem) String() string

func (*CacheItem) XXX_DiscardUnknown 

func (m *CacheItem) XXX_DiscardUnknown()

func (*CacheItem) XXX_Marshal 

func (m *CacheItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CacheItem) XXX_Merge 

func (m *CacheItem) XXX_Merge(src proto.Message)

func (*CacheItem) XXX_Size 

func (m *CacheItem) XXX_Size() int

func (*CacheItem) XXX_Unmarshal 

func (m *CacheItem) XXX_Unmarshal(b []byte) error

type CacheServer 

type CacheServer interface {
	CacheGet(context.Context, *CacheGetRequest) (*CacheGetResponse, error)
	CacheSet(context.Context, *CacheSetRequest) (*Empty, error)
}

CacheServer is the server API for Cache service.

type CacheSetRequest 

type CacheSetRequest struct {
	Key                  string     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Item                 *CacheItem `protobuf:"bytes,2,opt,name=item,proto3" json:"item,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CacheSetRequest) Descriptor 

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

func (*CacheSetRequest) GetItem 

func (m *CacheSetRequest) GetItem() *CacheItem

func (*CacheSetRequest) GetKey 

func (m *CacheSetRequest) GetKey() string

func (*CacheSetRequest) ProtoMessage 

func (*CacheSetRequest) ProtoMessage()

func (*CacheSetRequest) Reset 

func (m *CacheSetRequest) Reset()

func (*CacheSetRequest) String 

func (m *CacheSetRequest) String() string

func (*CacheSetRequest) XXX_DiscardUnknown 

func (m *CacheSetRequest) XXX_DiscardUnknown()

func (*CacheSetRequest) XXX_Marshal 

func (m *CacheSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CacheSetRequest) XXX_Merge 

func (m *CacheSetRequest) XXX_Merge(src proto.Message)

func (*CacheSetRequest) XXX_Size 

func (m *CacheSetRequest) XXX_Size() int

func (*CacheSetRequest) XXX_Unmarshal 

func (m *CacheSetRequest) XXX_Unmarshal(b []byte) error

type CounterClient 

type CounterClient interface {
	CounterGet(ctx context.Context, in *GetCounterRequest, opts ...grpc.CallOption) (*GetCounterResponse, error)
	CounterIncrement(ctx context.Context, in *IncrementCounterRequest, opts ...grpc.CallOption) (*GetCounterResponse, error)
}

CounterClient is the client API for Counter service.

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

func NewCounterClient 

func NewCounterClient(cc *grpc.ClientConn) CounterClient

type CounterServer 

type CounterServer interface {
	CounterGet(context.Context, *GetCounterRequest) (*GetCounterResponse, error)
	CounterIncrement(context.Context, *IncrementCounterRequest) (*GetCounterResponse, error)
}

CounterServer is the server API for Counter service.

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge 

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

func (m *Empty) XXX_Unmarshal(b []byte) error

type FlagClient 

type FlagClient interface {
	FlagGet(ctx context.Context, in *FlagGetRequest, opts ...grpc.CallOption) (*FlagResponse, error)
	FlagSet(ctx context.Context, in *FlagSetRequest, opts ...grpc.CallOption) (*Empty, error)
}

FlagClient is the client API for Flag service.

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

func NewFlagClient 

func NewFlagClient(cc *grpc.ClientConn) FlagClient

type FlagGetRequest 

type FlagGetRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FlagGetRequest) Descriptor 

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

func (*FlagGetRequest) GetKey 

func (m *FlagGetRequest) GetKey() string

func (*FlagGetRequest) ProtoMessage 

func (*FlagGetRequest) ProtoMessage()

func (*FlagGetRequest) Reset 

func (m *FlagGetRequest) Reset()

func (*FlagGetRequest) String 

func (m *FlagGetRequest) String() string

func (*FlagGetRequest) XXX_DiscardUnknown 

func (m *FlagGetRequest) XXX_DiscardUnknown()

func (*FlagGetRequest) XXX_Marshal 

func (m *FlagGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlagGetRequest) XXX_Merge 

func (m *FlagGetRequest) XXX_Merge(src proto.Message)

func (*FlagGetRequest) XXX_Size 

func (m *FlagGetRequest) XXX_Size() int

func (*FlagGetRequest) XXX_Unmarshal 

func (m *FlagGetRequest) XXX_Unmarshal(b []byte) error

type FlagResponse 

type FlagResponse struct {
	Value                bool     `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FlagResponse) Descriptor 

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

func (*FlagResponse) GetValue 

func (m *FlagResponse) GetValue() bool

func (*FlagResponse) ProtoMessage 

func (*FlagResponse) ProtoMessage()

func (*FlagResponse) Reset 

func (m *FlagResponse) Reset()

func (*FlagResponse) String 

func (m *FlagResponse) String() string

func (*FlagResponse) XXX_DiscardUnknown 

func (m *FlagResponse) XXX_DiscardUnknown()

func (*FlagResponse) XXX_Marshal 

func (m *FlagResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlagResponse) XXX_Merge 

func (m *FlagResponse) XXX_Merge(src proto.Message)

func (*FlagResponse) XXX_Size 

func (m *FlagResponse) XXX_Size() int

func (*FlagResponse) XXX_Unmarshal 

func (m *FlagResponse) XXX_Unmarshal(b []byte) error

type FlagServer 

type FlagServer interface {
	FlagGet(context.Context, *FlagGetRequest) (*FlagResponse, error)
	FlagSet(context.Context, *FlagSetRequest) (*Empty, error)
}

FlagServer is the server API for Flag service.

type FlagSetRequest 

type FlagSetRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                bool     `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FlagSetRequest) Descriptor 

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

func (*FlagSetRequest) GetKey 

func (m *FlagSetRequest) GetKey() string

func (*FlagSetRequest) GetValue 

func (m *FlagSetRequest) GetValue() bool

func (*FlagSetRequest) ProtoMessage 

func (*FlagSetRequest) ProtoMessage()

func (*FlagSetRequest) Reset 

func (m *FlagSetRequest) Reset()

func (*FlagSetRequest) String 

func (m *FlagSetRequest) String() string

func (*FlagSetRequest) XXX_DiscardUnknown 

func (m *FlagSetRequest) XXX_DiscardUnknown()

func (*FlagSetRequest) XXX_Marshal 

func (m *FlagSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlagSetRequest) XXX_Merge 

func (m *FlagSetRequest) XXX_Merge(src proto.Message)

func (*FlagSetRequest) XXX_Size 

func (m *FlagSetRequest) XXX_Size() int

func (*FlagSetRequest) XXX_Unmarshal 

func (m *FlagSetRequest) XXX_Unmarshal(b []byte) error

type GetCounterRequest 

type GetCounterRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCounterRequest) Descriptor 

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

func (*GetCounterRequest) GetKey 

func (m *GetCounterRequest) GetKey() string

func (*GetCounterRequest) ProtoMessage 

func (*GetCounterRequest) ProtoMessage()

func (*GetCounterRequest) Reset 

func (m *GetCounterRequest) Reset()

func (*GetCounterRequest) String 

func (m *GetCounterRequest) String() string

func (*GetCounterRequest) XXX_DiscardUnknown 

func (m *GetCounterRequest) XXX_DiscardUnknown()

func (*GetCounterRequest) XXX_Marshal 

func (m *GetCounterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCounterRequest) XXX_Merge 

func (m *GetCounterRequest) XXX_Merge(src proto.Message)

func (*GetCounterRequest) XXX_Size 

func (m *GetCounterRequest) XXX_Size() int

func (*GetCounterRequest) XXX_Unmarshal 

func (m *GetCounterRequest) XXX_Unmarshal(b []byte) error

type GetCounterResponse 

type GetCounterResponse struct {
	Value                int64    `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCounterResponse) Descriptor 

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

func (*GetCounterResponse) GetValue 

func (m *GetCounterResponse) GetValue() int64

func (*GetCounterResponse) ProtoMessage 

func (*GetCounterResponse) ProtoMessage()

func (*GetCounterResponse) Reset 

func (m *GetCounterResponse) Reset()

func (*GetCounterResponse) String 

func (m *GetCounterResponse) String() string

func (*GetCounterResponse) XXX_DiscardUnknown 

func (m *GetCounterResponse) XXX_DiscardUnknown()

func (*GetCounterResponse) XXX_Marshal 

func (m *GetCounterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCounterResponse) XXX_Merge 

func (m *GetCounterResponse) XXX_Merge(src proto.Message)

func (*GetCounterResponse) XXX_Size 

func (m *GetCounterResponse) XXX_Size() int

func (*GetCounterResponse) XXX_Unmarshal 

func (m *GetCounterResponse) XXX_Unmarshal(b []byte) error

type GetResponse 

type GetResponse struct {
	Value                *Value   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetValue 

func (m *GetResponse) GetValue() *Value

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetResponse) XXX_Merge 

func (m *GetResponse) XXX_Merge(src proto.Message)

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

func (m *GetResponse) XXX_Unmarshal(b []byte) error

type GetSetRequest 

type GetSetRequest struct {
	Set                  string   `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSetRequest) Descriptor 

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

func (*GetSetRequest) GetSet 

func (m *GetSetRequest) GetSet() string

func (*GetSetRequest) ProtoMessage 

func (*GetSetRequest) ProtoMessage()

func (*GetSetRequest) Reset 

func (m *GetSetRequest) Reset()

func (*GetSetRequest) String 

func (m *GetSetRequest) String() string

func (*GetSetRequest) XXX_DiscardUnknown 

func (m *GetSetRequest) XXX_DiscardUnknown()

func (*GetSetRequest) XXX_Marshal 

func (m *GetSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSetRequest) XXX_Merge 

func (m *GetSetRequest) XXX_Merge(src proto.Message)

func (*GetSetRequest) XXX_Size 

func (m *GetSetRequest) XXX_Size() int

func (*GetSetRequest) XXX_Unmarshal 

func (m *GetSetRequest) XXX_Unmarshal(b []byte) error

type IncrementCounterRequest 

type IncrementCounterRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Amount               int64    `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IncrementCounterRequest) Descriptor 

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

func (*IncrementCounterRequest) GetAmount 

func (m *IncrementCounterRequest) GetAmount() int64

func (*IncrementCounterRequest) GetKey 

func (m *IncrementCounterRequest) GetKey() string

func (*IncrementCounterRequest) ProtoMessage 

func (*IncrementCounterRequest) ProtoMessage()

func (*IncrementCounterRequest) Reset 

func (m *IncrementCounterRequest) Reset()

func (*IncrementCounterRequest) String 

func (m *IncrementCounterRequest) String() string

func (*IncrementCounterRequest) XXX_DiscardUnknown 

func (m *IncrementCounterRequest) XXX_DiscardUnknown()

func (*IncrementCounterRequest) XXX_Marshal 

func (m *IncrementCounterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IncrementCounterRequest) XXX_Merge 

func (m *IncrementCounterRequest) XXX_Merge(src proto.Message)

func (*IncrementCounterRequest) XXX_Size 

func (m *IncrementCounterRequest) XXX_Size() int

func (*IncrementCounterRequest) XXX_Unmarshal 

func (m *IncrementCounterRequest) XXX_Unmarshal(b []byte) error

type KVClient 

type KVClient interface {
	KVGet(ctx context.Context, in *Location, opts ...grpc.CallOption) (*GetResponse, error)
	KVPut(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*Empty, error)
	KVDelete(ctx context.Context, in *Location, opts ...grpc.CallOption) (*Empty, 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.ClientConn) KVClient

type KVServer 

type KVServer interface {
	KVGet(context.Context, *Location) (*GetResponse, error)
	KVPut(context.Context, *PutRequest) (*Empty, error)
	KVDelete(context.Context, *Location) (*Empty, error)
}

KVServer is the server API for KV service.

type Location 

type Location struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Location) Descriptor 

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

func (*Location) GetKey 

func (m *Location) GetKey() string

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) String 

func (m *Location) String() string

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Location) XXX_Merge 

func (m *Location) XXX_Merge(src proto.Message)

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

func (m *Location) XXX_Unmarshal(b []byte) error

type ModifySetRequest 

type ModifySetRequest struct {
	Set                  string   `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"`
	Item                 string   `protobuf:"bytes,2,opt,name=item,proto3" json:"item,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModifySetRequest) Descriptor 

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

func (*ModifySetRequest) GetItem 

func (m *ModifySetRequest) GetItem() string

func (*ModifySetRequest) GetSet 

func (m *ModifySetRequest) GetSet() string

func (*ModifySetRequest) ProtoMessage 

func (*ModifySetRequest) ProtoMessage()

func (*ModifySetRequest) Reset 

func (m *ModifySetRequest) Reset()

func (*ModifySetRequest) String 

func (m *ModifySetRequest) String() string

func (*ModifySetRequest) XXX_DiscardUnknown 

func (m *ModifySetRequest) XXX_DiscardUnknown()

func (*ModifySetRequest) XXX_Marshal 

func (m *ModifySetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifySetRequest) XXX_Merge 

func (m *ModifySetRequest) XXX_Merge(src proto.Message)

func (*ModifySetRequest) XXX_Size 

func (m *ModifySetRequest) XXX_Size() int

func (*ModifySetRequest) XXX_Unmarshal 

func (m *ModifySetRequest) XXX_Unmarshal(b []byte) error

type PutRequest 

type PutRequest struct {
	Location             *Location `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	Value                *Value    `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetLocation 

func (m *PutRequest) GetLocation() *Location

func (*PutRequest) GetValue 

func (m *PutRequest) GetValue() *Value

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) String 

func (m *PutRequest) String() string

func (*PutRequest) XXX_DiscardUnknown 

func (m *PutRequest) XXX_DiscardUnknown()

func (*PutRequest) XXX_Marshal 

func (m *PutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutRequest) XXX_Merge 

func (m *PutRequest) XXX_Merge(src proto.Message)

func (*PutRequest) XXX_Size 

func (m *PutRequest) XXX_Size() int

func (*PutRequest) XXX_Unmarshal 

func (m *PutRequest) XXX_Unmarshal(b []byte) error

type SetClient 

type SetClient interface {
	SetGet(ctx context.Context, in *GetSetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	SetAdd(ctx context.Context, in *ModifySetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	SetRemove(ctx context.Context, in *ModifySetRequest, opts ...grpc.CallOption) (*SetResponse, error)
}

SetClient is the client API for Set service.

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

func NewSetClient 

func NewSetClient(cc *grpc.ClientConn) SetClient

type SetResponse 

type SetResponse struct {
	Items                []string `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetResponse) Descriptor 

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

func (*SetResponse) GetItems 

func (m *SetResponse) GetItems() []string

func (*SetResponse) ProtoMessage 

func (*SetResponse) ProtoMessage()

func (*SetResponse) Reset 

func (m *SetResponse) Reset()

func (*SetResponse) String 

func (m *SetResponse) String() string

func (*SetResponse) XXX_DiscardUnknown 

func (m *SetResponse) XXX_DiscardUnknown()

func (*SetResponse) XXX_Marshal 

func (m *SetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetResponse) XXX_Merge 

func (m *SetResponse) XXX_Merge(src proto.Message)

func (*SetResponse) XXX_Size 

func (m *SetResponse) XXX_Size() int

func (*SetResponse) XXX_Unmarshal 

func (m *SetResponse) XXX_Unmarshal(b []byte) error

type SetServer 

type SetServer interface {
	SetGet(context.Context, *GetSetRequest) (*SetResponse, error)
	SetAdd(context.Context, *ModifySetRequest) (*SetResponse, error)
	SetRemove(context.Context, *ModifySetRequest) (*SetResponse, error)
}

SetServer is the server API for Set service.

type Value 

type Value struct {
	Content              []byte   `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Value) Descriptor 

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

func (*Value) GetContent 

func (m *Value) GetContent() []byte

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) String 

func (m *Value) String() string

func (*Value) XXX_DiscardUnknown 

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal 

func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Value) XXX_Merge 

func (m *Value) XXX_Merge(src proto.Message)

func (*Value) XXX_Size 

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal 

func (m *Value) XXX_Unmarshal(b []byte) 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.