Versions in this module Expand all Collapse all v1 v1.0.1 May 10, 2021 v1.0.0 May 9, 2021 Changes in this version + func RegisterConfigHandler(s server.Server, hdlr ConfigHandler, opts ...server.HandlerOption) error + type Change struct + ChangeSet *ChangeSet + Namespace string + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Change) Descriptor() ([]byte, []int) + func (*Change) ProtoMessage() + func (m *Change) GetChangeSet() *ChangeSet + func (m *Change) GetNamespace() string + func (m *Change) GetPath() string + func (m *Change) Reset() + func (m *Change) String() string + func (m *Change) XXX_DiscardUnknown() + func (m *Change) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Change) XXX_Merge(src proto.Message) + func (m *Change) XXX_Size() int + func (m *Change) XXX_Unmarshal(b []byte) error + type ChangeSet struct + Checksum string + Data string + Format string + Source string + Timestamp int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangeSet) Descriptor() ([]byte, []int) + func (*ChangeSet) ProtoMessage() + func (m *ChangeSet) GetChecksum() string + func (m *ChangeSet) GetData() string + func (m *ChangeSet) GetFormat() string + func (m *ChangeSet) GetSource() string + func (m *ChangeSet) GetTimestamp() int64 + func (m *ChangeSet) Reset() + func (m *ChangeSet) String() string + func (m *ChangeSet) XXX_DiscardUnknown() + func (m *ChangeSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChangeSet) XXX_Merge(src proto.Message) + func (m *ChangeSet) XXX_Size() int + func (m *ChangeSet) XXX_Unmarshal(b []byte) error + type ConfigHandler interface + Create func(context.Context, *CreateRequest, *CreateResponse) error + Delete func(context.Context, *DeleteRequest, *DeleteResponse) error + List func(context.Context, *ListRequest, *ListResponse) error + Read func(context.Context, *ReadRequest, *ReadResponse) error + Update func(context.Context, *UpdateRequest, *UpdateResponse) error + Watch func(context.Context, *WatchRequest, Config_WatchStream) error + type ConfigService interface + Create func(ctx context.Context, in *CreateRequest, opts ...client.CallOption) (*CreateResponse, error) + Delete func(ctx context.Context, in *DeleteRequest, opts ...client.CallOption) (*DeleteResponse, error) + List func(ctx context.Context, in *ListRequest, opts ...client.CallOption) (*ListResponse, error) + Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error) + Update func(ctx context.Context, in *UpdateRequest, opts ...client.CallOption) (*UpdateResponse, error) + Watch func(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Config_WatchService, error) + func NewConfigService(name string, c client.Client) ConfigService + type Config_WatchService interface + Close func() error + Context func() context.Context + Recv func() (*WatchResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Config_WatchStream interface + Close func() error + Context func() context.Context + RecvMsg func(interface{}) error + Send func(*WatchResponse) error + SendMsg func(interface{}) error + type CreateRequest struct + Change *Change + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateRequest) Descriptor() ([]byte, []int) + func (*CreateRequest) ProtoMessage() + func (m *CreateRequest) GetChange() *Change + func (m *CreateRequest) Reset() + func (m *CreateRequest) String() string + func (m *CreateRequest) XXX_DiscardUnknown() + func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateRequest) XXX_Merge(src proto.Message) + func (m *CreateRequest) XXX_Size() int + func (m *CreateRequest) XXX_Unmarshal(b []byte) error + type CreateResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateResponse) Descriptor() ([]byte, []int) + func (*CreateResponse) ProtoMessage() + func (m *CreateResponse) Reset() + func (m *CreateResponse) String() string + func (m *CreateResponse) XXX_DiscardUnknown() + func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateResponse) XXX_Merge(src proto.Message) + func (m *CreateResponse) XXX_Size() int + func (m *CreateResponse) XXX_Unmarshal(b []byte) error + type DeleteRequest struct + Change *Change + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (m *DeleteRequest) GetChange() *Change + func (m *DeleteRequest) Reset() + func (m *DeleteRequest) String() string + func (m *DeleteRequest) XXX_DiscardUnknown() + func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteRequest) XXX_Merge(src proto.Message) + func (m *DeleteRequest) XXX_Size() int + func (m *DeleteRequest) XXX_Unmarshal(b []byte) error + type DeleteResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (m *DeleteResponse) Reset() + func (m *DeleteResponse) String() string + func (m *DeleteResponse) XXX_DiscardUnknown() + func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteResponse) XXX_Merge(src proto.Message) + func (m *DeleteResponse) XXX_Size() int + func (m *DeleteResponse) XXX_Unmarshal(b []byte) error + type ListRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (m *ListRequest) Reset() + func (m *ListRequest) String() string + func (m *ListRequest) XXX_DiscardUnknown() + func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListRequest) XXX_Merge(src proto.Message) + func (m *ListRequest) XXX_Size() int + func (m *ListRequest) XXX_Unmarshal(b []byte) error + type ListResponse struct + Values []*Change + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListResponse) Descriptor() ([]byte, []int) + func (*ListResponse) ProtoMessage() + func (m *ListResponse) GetValues() []*Change + func (m *ListResponse) Reset() + func (m *ListResponse) String() string + func (m *ListResponse) XXX_DiscardUnknown() + func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListResponse) XXX_Merge(src proto.Message) + func (m *ListResponse) XXX_Size() int + func (m *ListResponse) XXX_Unmarshal(b []byte) error + type ReadRequest struct + Namespace string + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) GetNamespace() string + func (m *ReadRequest) GetPath() string + func (m *ReadRequest) Reset() + func (m *ReadRequest) String() string + func (m *ReadRequest) XXX_DiscardUnknown() + func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadRequest) XXX_Merge(src proto.Message) + func (m *ReadRequest) XXX_Size() int + func (m *ReadRequest) XXX_Unmarshal(b []byte) error + type ReadResponse struct + Change *Change + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetChange() *Change + func (m *ReadResponse) Reset() + func (m *ReadResponse) String() string + func (m *ReadResponse) XXX_DiscardUnknown() + func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadResponse) XXX_Merge(src proto.Message) + func (m *ReadResponse) XXX_Size() int + func (m *ReadResponse) XXX_Unmarshal(b []byte) error + type UpdateRequest struct + Change *Change + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateRequest) Descriptor() ([]byte, []int) + func (*UpdateRequest) ProtoMessage() + func (m *UpdateRequest) GetChange() *Change + func (m *UpdateRequest) Reset() + func (m *UpdateRequest) String() string + func (m *UpdateRequest) XXX_DiscardUnknown() + func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateRequest) XXX_Merge(src proto.Message) + func (m *UpdateRequest) XXX_Size() int + func (m *UpdateRequest) XXX_Unmarshal(b []byte) error + type UpdateResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateResponse) Descriptor() ([]byte, []int) + func (*UpdateResponse) ProtoMessage() + func (m *UpdateResponse) Reset() + func (m *UpdateResponse) String() string + func (m *UpdateResponse) XXX_DiscardUnknown() + func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateResponse) XXX_Merge(src proto.Message) + func (m *UpdateResponse) XXX_Size() int + func (m *UpdateResponse) XXX_Unmarshal(b []byte) error + type WatchRequest struct + Namespace string + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchRequest) Descriptor() ([]byte, []int) + func (*WatchRequest) ProtoMessage() + func (m *WatchRequest) GetNamespace() string + func (m *WatchRequest) GetPath() string + func (m *WatchRequest) Reset() + func (m *WatchRequest) String() string + func (m *WatchRequest) XXX_DiscardUnknown() + func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchRequest) XXX_Merge(src proto.Message) + func (m *WatchRequest) XXX_Size() int + func (m *WatchRequest) XXX_Unmarshal(b []byte) error + type WatchResponse struct + ChangeSet *ChangeSet + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchResponse) Descriptor() ([]byte, []int) + func (*WatchResponse) ProtoMessage() + func (m *WatchResponse) GetChangeSet() *ChangeSet + func (m *WatchResponse) GetNamespace() string + func (m *WatchResponse) Reset() + func (m *WatchResponse) String() string + func (m *WatchResponse) XXX_DiscardUnknown() + func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchResponse) XXX_Merge(src proto.Message) + func (m *WatchResponse) XXX_Size() int + func (m *WatchResponse) XXX_Unmarshal(b []byte) error Incompatible versions in this module v2.3.0+incompatible May 9, 2021
Go to main page