Versions in this module Expand all Collapse all v1 v1.0.0 Jun 25, 2024 Changes in this version + func RegisterSourceHandler(s server.Server, hdlr SourceHandler, opts ...server.HandlerOption) error + type ChangeSet struct + Checksum string + Data []byte + 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() []byte + 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 ReadRequest struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + 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 + ChangeSet *ChangeSet + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetChangeSet() *ChangeSet + 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 SourceHandler interface + Read func(context.Context, *ReadRequest, *ReadResponse) error + Watch func(context.Context, *WatchRequest, Source_WatchStream) error + type SourceService interface + Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error) + Watch func(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Source_WatchService, error) + func NewSourceService(name string, c client.Client) SourceService + type Source_WatchService interface + Close func() error + Recv func() (*WatchResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Source_WatchStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*WatchResponse) error + SendMsg func(interface{}) error + type WatchRequest struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchRequest) Descriptor() ([]byte, []int) + func (*WatchRequest) ProtoMessage() + 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 + 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) 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
Go to main page