Documentation ¶
Index ¶
- Variables
- func DeregisterConfigEnhancedServer(s grpc.ServiceRegistrar, name string)
- func RegisterConfigEnhancedServer(s grpc.ServiceRegistrar, srv NamedConfigServer)
- func RegisterConfigServer(s grpc.ServiceRegistrar, srv ConfigServer)
- type ConfigClient
- type ConfigEnhancedServer
- func (m ConfigEnhancedServer) Delete(ctx context.Context, r *DeleteRequest) (*DeleteResponse, error)
- func (m ConfigEnhancedServer) Get(ctx context.Context, r *GetRequest) (*GetResponse, error)
- func (m ConfigEnhancedServer) Set(ctx context.Context, r *SetRequest) (*SetResponse, error)
- func (m ConfigEnhancedServer) Watch(r *WatchRequest, s Config_WatchServer) error
- type ConfigServer
- type ConfigStub
- type ConfigStub_WatchStreamer
- type Config_WatchClient
- type Config_WatchServer
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRequest) GetNamespace() string
- func (x *DeleteRequest) GetPath() string
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (x *DeleteRequest) String() string
- func (this *DeleteRequest) Validate() error
- type DeleteResponse
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRequest) GetNamespace() string
- func (x *GetRequest) GetOptions() *Options
- func (x *GetRequest) GetPath() string
- func (*GetRequest) ProtoMessage()
- func (x *GetRequest) ProtoReflect() protoreflect.Message
- func (x *GetRequest) Reset()
- func (x *GetRequest) String() string
- func (this *GetRequest) Validate() error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetResponse) GetValue() *Value
- func (*GetResponse) ProtoMessage()
- func (x *GetResponse) ProtoReflect() protoreflect.Message
- func (x *GetResponse) Reset()
- func (x *GetResponse) String() string
- func (this *GetResponse) Validate() error
- type NamedConfigServer
- type Options
- type SetRequest
- func (*SetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetRequest) GetNamespace() string
- func (x *SetRequest) GetOptions() *Options
- func (x *SetRequest) GetPath() string
- func (x *SetRequest) GetValue() *Value
- func (*SetRequest) ProtoMessage()
- func (x *SetRequest) ProtoReflect() protoreflect.Message
- func (x *SetRequest) Reset()
- func (x *SetRequest) String() string
- func (this *SetRequest) Validate() error
- type SetResponse
- type UnimplementedConfigServer
- func (UnimplementedConfigServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (UnimplementedConfigServer) Get(context.Context, *GetRequest) (*GetResponse, error)
- func (UnimplementedConfigServer) Set(context.Context, *SetRequest) (*SetResponse, error)
- func (UnimplementedConfigServer) Watch(*WatchRequest, Config_WatchServer) error
- type UnsafeConfigServer
- type Value
- type WatchRequest
- func (*WatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchRequest) GetNamespace() string
- func (x *WatchRequest) GetOptions() *Options
- func (x *WatchRequest) GetPath() string
- func (*WatchRequest) ProtoMessage()
- func (x *WatchRequest) ProtoReflect() protoreflect.Message
- func (x *WatchRequest) Reset()
- func (x *WatchRequest) String() string
- func (this *WatchRequest) Validate() error
- type WatchResponse
- func (*WatchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WatchResponse) GetValue() *Value
- func (*WatchResponse) ProtoMessage()
- func (x *WatchResponse) ProtoReflect() protoreflect.Message
- func (x *WatchResponse) Reset()
- func (x *WatchResponse) String() string
- func (this *WatchResponse) Validate() error
Constants ¶
This section is empty.
Variables ¶
var Config_ServiceDesc = grpc.ServiceDesc{ ServiceName: "config.Config", HandlerType: (*ConfigServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _Config_Get_Handler, }, { MethodName: "Set", Handler: _Config_Set_Handler, }, { MethodName: "Delete", Handler: _Config_Delete_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Watch", Handler: _Config_Watch_Handler, ServerStreams: true, }, }, Metadata: "cells-config.proto", }
Config_ServiceDesc is the grpc.ServiceDesc for Config service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_cells_config_proto protoreflect.FileDescriptor
Functions ¶
func DeregisterConfigEnhancedServer ¶
func DeregisterConfigEnhancedServer(s grpc.ServiceRegistrar, name string)
func RegisterConfigEnhancedServer ¶
func RegisterConfigEnhancedServer(s grpc.ServiceRegistrar, srv NamedConfigServer)
func RegisterConfigServer ¶
func RegisterConfigServer(s grpc.ServiceRegistrar, srv ConfigServer)
Types ¶
type ConfigClient ¶
type ConfigClient interface { Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Config_WatchClient, error) }
ConfigClient is the client API for Config service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewConfigClient ¶
func NewConfigClient(cc grpc.ClientConnInterface) ConfigClient
type ConfigEnhancedServer ¶
type ConfigEnhancedServer map[string]NamedConfigServer
func (ConfigEnhancedServer) Delete ¶
func (m ConfigEnhancedServer) Delete(ctx context.Context, r *DeleteRequest) (*DeleteResponse, error)
func (ConfigEnhancedServer) Get ¶
func (m ConfigEnhancedServer) Get(ctx context.Context, r *GetRequest) (*GetResponse, error)
func (ConfigEnhancedServer) Set ¶
func (m ConfigEnhancedServer) Set(ctx context.Context, r *SetRequest) (*SetResponse, error)
func (ConfigEnhancedServer) Watch ¶
func (m ConfigEnhancedServer) Watch(r *WatchRequest, s Config_WatchServer) error
type ConfigServer ¶
type ConfigServer interface { Get(context.Context, *GetRequest) (*GetResponse, error) Set(context.Context, *SetRequest) (*SetResponse, error) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) Watch(*WatchRequest, Config_WatchServer) error // contains filtered or unexported methods }
ConfigServer is the server API for Config service. All implementations must embed UnimplementedConfigServer for forward compatibility
type ConfigStub ¶ added in v4.0.1
type ConfigStub struct {
ConfigServer
}
func (*ConfigStub) Invoke ¶ added in v4.0.1
func (s *ConfigStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*ConfigStub) NewStream ¶ added in v4.0.1
func (s *ConfigStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type ConfigStub_WatchStreamer ¶ added in v4.0.1
type ConfigStub_WatchStreamer struct {
stubs.ClientServerStreamerCore
}
func (*ConfigStub_WatchStreamer) Send ¶ added in v4.0.1
func (s *ConfigStub_WatchStreamer) Send(response *WatchResponse) error
type Config_WatchClient ¶
type Config_WatchClient interface { Recv() (*WatchResponse, error) grpc.ClientStream }
type Config_WatchServer ¶
type Config_WatchServer interface { Send(*WatchResponse) error grpc.ServerStream }
type DeleteRequest ¶
type DeleteRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetNamespace ¶
func (x *DeleteRequest) GetNamespace() string
func (*DeleteRequest) GetPath ¶
func (x *DeleteRequest) GetPath() string
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
func (*DeleteRequest) Validate ¶
func (this *DeleteRequest) Validate() error
type DeleteResponse ¶
type DeleteResponse struct {
// contains filtered or unexported fields
}
func (*DeleteResponse) Descriptor
deprecated
func (*DeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶
func (x *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (x *DeleteResponse) String() string
func (*DeleteResponse) Validate ¶
func (this *DeleteResponse) Validate() error
type GetRequest ¶
type GetRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` Options *Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetNamespace ¶
func (x *GetRequest) GetNamespace() string
func (*GetRequest) GetOptions ¶
func (x *GetRequest) GetOptions() *Options
func (*GetRequest) GetPath ¶
func (x *GetRequest) GetPath() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
func (*GetRequest) Validate ¶
func (this *GetRequest) Validate() error
type GetResponse ¶
type GetResponse struct { Value *Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetValue ¶
func (x *GetResponse) GetValue() *Value
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) String ¶
func (x *GetResponse) String() string
func (*GetResponse) Validate ¶
func (this *GetResponse) Validate() error
type NamedConfigServer ¶
type NamedConfigServer interface { ConfigServer Name() string }
type Options ¶
type Options struct { // Is it an encrypted value? Secret bool `protobuf:"varint,1,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
func (*Options) Descriptor
deprecated
func (*Options) ProtoMessage ¶
func (*Options) ProtoMessage()
func (*Options) ProtoReflect ¶
func (x *Options) ProtoReflect() protoreflect.Message
type SetRequest ¶
type SetRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` Value *Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Options *Options `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*SetRequest) Descriptor
deprecated
func (*SetRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.
func (*SetRequest) GetNamespace ¶
func (x *SetRequest) GetNamespace() string
func (*SetRequest) GetOptions ¶
func (x *SetRequest) GetOptions() *Options
func (*SetRequest) GetPath ¶
func (x *SetRequest) GetPath() string
func (*SetRequest) GetValue ¶
func (x *SetRequest) GetValue() *Value
func (*SetRequest) ProtoMessage ¶
func (*SetRequest) ProtoMessage()
func (*SetRequest) ProtoReflect ¶
func (x *SetRequest) ProtoReflect() protoreflect.Message
func (*SetRequest) Reset ¶
func (x *SetRequest) Reset()
func (*SetRequest) String ¶
func (x *SetRequest) String() string
func (*SetRequest) Validate ¶
func (this *SetRequest) Validate() error
type SetResponse ¶
type SetResponse struct {
// contains filtered or unexported fields
}
func (*SetResponse) Descriptor
deprecated
func (*SetResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.
func (*SetResponse) ProtoMessage ¶
func (*SetResponse) ProtoMessage()
func (*SetResponse) ProtoReflect ¶
func (x *SetResponse) ProtoReflect() protoreflect.Message
func (*SetResponse) Reset ¶
func (x *SetResponse) Reset()
func (*SetResponse) String ¶
func (x *SetResponse) String() string
func (*SetResponse) Validate ¶
func (this *SetResponse) Validate() error
type UnimplementedConfigServer ¶
type UnimplementedConfigServer struct { }
UnimplementedConfigServer must be embedded to have forward compatible implementations.
func (UnimplementedConfigServer) Delete ¶
func (UnimplementedConfigServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (UnimplementedConfigServer) Get ¶
func (UnimplementedConfigServer) Get(context.Context, *GetRequest) (*GetResponse, error)
func (UnimplementedConfigServer) Set ¶
func (UnimplementedConfigServer) Set(context.Context, *SetRequest) (*SetResponse, error)
func (UnimplementedConfigServer) Watch ¶
func (UnimplementedConfigServer) Watch(*WatchRequest, Config_WatchServer) error
type UnsafeConfigServer ¶
type UnsafeConfigServer interface {
// contains filtered or unexported methods
}
UnsafeConfigServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConfigServer will result in compilation errors.
type Value ¶
type Value struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"` // contains filtered or unexported fields }
func (*Value) Descriptor
deprecated
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) ProtoReflect ¶
func (x *Value) ProtoReflect() protoreflect.Message
type WatchRequest ¶
type WatchRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` Options *Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*WatchRequest) Descriptor
deprecated
func (*WatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.
func (*WatchRequest) GetNamespace ¶
func (x *WatchRequest) GetNamespace() string
func (*WatchRequest) GetOptions ¶
func (x *WatchRequest) GetOptions() *Options
func (*WatchRequest) GetPath ¶
func (x *WatchRequest) GetPath() string
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) ProtoReflect ¶
func (x *WatchRequest) ProtoReflect() protoreflect.Message
func (*WatchRequest) Reset ¶
func (x *WatchRequest) Reset()
func (*WatchRequest) String ¶
func (x *WatchRequest) String() string
func (*WatchRequest) Validate ¶
func (this *WatchRequest) Validate() error
type WatchResponse ¶
type WatchResponse struct { Value *Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*WatchResponse) Descriptor
deprecated
func (*WatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.
func (*WatchResponse) GetValue ¶
func (x *WatchResponse) GetValue() *Value
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) ProtoReflect ¶
func (x *WatchResponse) ProtoReflect() protoreflect.Message
func (*WatchResponse) Reset ¶
func (x *WatchResponse) Reset()
func (*WatchResponse) String ¶
func (x *WatchResponse) String() string
func (*WatchResponse) Validate ¶
func (this *WatchResponse) Validate() error