Documentation
¶
Index ¶
- Variables
- func NewServer(kv kv.KV, ps pubsub.PubSub, logger zerolog.Logger) *server
- func RegisterGonfigServer(s *grpc.Server, srv GonfigServer)
- type GetConfigRequest
- type GetConfigResponse
- type GonfigClient
- type GonfigServer
- type Gonfig_WatchConfigClient
- type Gonfig_WatchConfigServer
- type UnimplementedGonfigServer
- type WatchConfigRequest
- func (*WatchConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchConfigRequest) GetConfigPath() string
- func (*WatchConfigRequest) ProtoMessage()
- func (x *WatchConfigRequest) ProtoReflect() protoreflect.Message
- func (x *WatchConfigRequest) Reset()
- func (x *WatchConfigRequest) String() string
- type WatchConfigResponse
- func (*WatchConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WatchConfigResponse) GetEvent() string
- func (x *WatchConfigResponse) GetSubscriptionID() string
- func (*WatchConfigResponse) ProtoMessage()
- func (x *WatchConfigResponse) ProtoReflect() protoreflect.Message
- func (x *WatchConfigResponse) Reset()
- func (x *WatchConfigResponse) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_api_proto protoreflect.FileDescriptor
Functions ¶
func RegisterGonfigServer ¶
func RegisterGonfigServer(s *grpc.Server, srv GonfigServer)
Types ¶
type GetConfigRequest ¶
type GetConfigRequest struct {
ConfigPath string `protobuf:"bytes,1,opt,name=configPath,proto3" json:"configPath,omitempty"`
// contains filtered or unexported fields
}
func (*GetConfigRequest) Descriptor
deprecated
func (*GetConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.
func (*GetConfigRequest) GetConfigPath ¶
func (x *GetConfigRequest) GetConfigPath() string
func (*GetConfigRequest) ProtoMessage ¶
func (*GetConfigRequest) ProtoMessage()
func (*GetConfigRequest) ProtoReflect ¶
func (x *GetConfigRequest) ProtoReflect() protoreflect.Message
func (*GetConfigRequest) Reset ¶
func (x *GetConfigRequest) Reset()
func (*GetConfigRequest) String ¶
func (x *GetConfigRequest) String() string
type GetConfigResponse ¶
type GetConfigResponse struct {
Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*GetConfigResponse) Descriptor
deprecated
func (*GetConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.
func (*GetConfigResponse) GetConfig ¶
func (x *GetConfigResponse) GetConfig() string
func (*GetConfigResponse) ProtoMessage ¶
func (*GetConfigResponse) ProtoMessage()
func (*GetConfigResponse) ProtoReflect ¶
func (x *GetConfigResponse) ProtoReflect() protoreflect.Message
func (*GetConfigResponse) Reset ¶
func (x *GetConfigResponse) Reset()
func (*GetConfigResponse) String ¶
func (x *GetConfigResponse) String() string
type GonfigClient ¶
type GonfigClient interface {
GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
WatchConfig(ctx context.Context, in *WatchConfigRequest, opts ...grpc.CallOption) (Gonfig_WatchConfigClient, error)
}
GonfigClient is the client API for Gonfig service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewGonfigClient ¶
func NewGonfigClient(cc grpc.ClientConnInterface) GonfigClient
type GonfigServer ¶
type GonfigServer interface {
GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
WatchConfig(*WatchConfigRequest, Gonfig_WatchConfigServer) error
}
GonfigServer is the server API for Gonfig service.
type Gonfig_WatchConfigClient ¶
type Gonfig_WatchConfigClient interface {
Recv() (*WatchConfigResponse, error)
grpc.ClientStream
}
type Gonfig_WatchConfigServer ¶
type Gonfig_WatchConfigServer interface {
Send(*WatchConfigResponse) error
grpc.ServerStream
}
type UnimplementedGonfigServer ¶
type UnimplementedGonfigServer struct {
}
UnimplementedGonfigServer can be embedded to have forward compatible implementations.
func (*UnimplementedGonfigServer) GetConfig ¶
func (*UnimplementedGonfigServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
func (*UnimplementedGonfigServer) WatchConfig ¶
func (*UnimplementedGonfigServer) WatchConfig(*WatchConfigRequest, Gonfig_WatchConfigServer) error
type WatchConfigRequest ¶
type WatchConfigRequest struct {
ConfigPath string `protobuf:"bytes,1,opt,name=configPath,proto3" json:"configPath,omitempty"`
// contains filtered or unexported fields
}
func (*WatchConfigRequest) Descriptor
deprecated
func (*WatchConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchConfigRequest.ProtoReflect.Descriptor instead.
func (*WatchConfigRequest) GetConfigPath ¶
func (x *WatchConfigRequest) GetConfigPath() string
func (*WatchConfigRequest) ProtoMessage ¶
func (*WatchConfigRequest) ProtoMessage()
func (*WatchConfigRequest) ProtoReflect ¶
func (x *WatchConfigRequest) ProtoReflect() protoreflect.Message
func (*WatchConfigRequest) Reset ¶
func (x *WatchConfigRequest) Reset()
func (*WatchConfigRequest) String ¶
func (x *WatchConfigRequest) String() string
type WatchConfigResponse ¶
type WatchConfigResponse struct {
SubscriptionID string `protobuf:"bytes,1,opt,name=subscriptionID,proto3" json:"subscriptionID,omitempty"`
Event string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
// contains filtered or unexported fields
}
func (*WatchConfigResponse) Descriptor
deprecated
func (*WatchConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchConfigResponse.ProtoReflect.Descriptor instead.
func (*WatchConfigResponse) GetEvent ¶
func (x *WatchConfigResponse) GetEvent() string
func (*WatchConfigResponse) GetSubscriptionID ¶
func (x *WatchConfigResponse) GetSubscriptionID() string
func (*WatchConfigResponse) ProtoMessage ¶
func (*WatchConfigResponse) ProtoMessage()
func (*WatchConfigResponse) ProtoReflect ¶
func (x *WatchConfigResponse) ProtoReflect() protoreflect.Message
func (*WatchConfigResponse) Reset ¶
func (x *WatchConfigResponse) Reset()
func (*WatchConfigResponse) String ¶
func (x *WatchConfigResponse) String() string
Click to show internal directories.
Click to hide internal directories.