service

package

Go to main page

Versions in this module

v2

v2.9.9

Mar 31, 2022

v2.9.8

Mar 31, 2022

Changes in this version

+ var File_config_source_service_proto_service_proto protoreflect.FileDescriptor

type Change

+ func (x *Change) ProtoReflect() protoreflect.Message

type ChangeSet

+ func (x *ChangeSet) ProtoReflect() protoreflect.Message

type CreateRequest

+ func (x *CreateRequest) ProtoReflect() protoreflect.Message

type CreateResponse

+ func (x *CreateResponse) ProtoReflect() protoreflect.Message

type DeleteRequest

+ func (x *DeleteRequest) ProtoReflect() protoreflect.Message

type DeleteResponse

+ func (x *DeleteResponse) ProtoReflect() protoreflect.Message

type ListRequest

+ func (x *ListRequest) ProtoReflect() protoreflect.Message

type ListResponse

+ func (x *ListResponse) ProtoReflect() protoreflect.Message

type ReadRequest

+ func (x *ReadRequest) ProtoReflect() protoreflect.Message

type ReadResponse

+ func (x *ReadResponse) ProtoReflect() protoreflect.Message

type UpdateRequest

+ func (x *UpdateRequest) ProtoReflect() protoreflect.Message

type UpdateResponse

+ func (x *UpdateResponse) ProtoReflect() protoreflect.Message

type WatchRequest

+ func (x *WatchRequest) ProtoReflect() protoreflect.Message

type WatchResponse

+ func (x *WatchResponse) ProtoReflect() protoreflect.Message

v2.9.7

Nov 30, 2021

v2.9.6

Aug 19, 2021

v2.9.5

Aug 11, 2021

Changes in this version

+ func NewConfigEndpoints() []*api.Endpoint

+ func RegisterConfigHandler(s server.Server, hdlr ConfigHandler, opts ...server.HandlerOption) error

+ func RegisterConfigServer(s *grpc.Server, srv ConfigServer)

+ 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 ConfigClient interface

+ Create func(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)

+ List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)

+ Update func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)

+ Watch func(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Config_WatchClient, error)

+ func NewConfigClient(cc *grpc.ClientConn) ConfigClient

+ 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 ConfigServer 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(*WatchRequest, Config_WatchServer) 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_WatchClient interface

+ Recv func() (*WatchResponse, error)

+ type Config_WatchServer interface

+ Send func(*WatchResponse) error

+ 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 UnimplementedConfigServer struct

+ func (*UnimplementedConfigServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)

+ func (*UnimplementedConfigServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

+ func (*UnimplementedConfigServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error)

+ func (*UnimplementedConfigServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error)

+ func (*UnimplementedConfigServer) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error)

+ func (*UnimplementedConfigServer) Watch(req *WatchRequest, srv Config_WatchServer) 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

v2.9.4

Aug 10, 2021

v2.9.3

Aug 10, 2021

v2.9.2

Aug 10, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL