Versions in this module Expand all Collapse all v1 v1.0.0 Feb 1, 2021 Changes in this version + func RegisterSourceServer(s *grpc1.Server, srv SourceServer) + type ChangeSet struct + Checksum string + Data []byte + Format string + Source string + Timestamp int64 + 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 + type ReadRequest struct + Path string + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) GetPath() string + func (m *ReadRequest) Reset() + func (m *ReadRequest) String() string + type ReadResponse struct + ChangeSet *ChangeSet + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetChangeSet() *ChangeSet + func (m *ReadResponse) Reset() + func (m *ReadResponse) String() string + type SourceClient interface + Read func(ctx context.Context, in *ReadRequest, opts ...grpc1.CallOption) (*ReadResponse, error) + Watch func(ctx context.Context, in *WatchRequest, opts ...grpc1.CallOption) (Source_WatchClient, error) + func NewSourceClient(cc *grpc1.ClientConn) SourceClient + type SourceServer interface + Read func(context.Context, *ReadRequest) (*ReadResponse, error) + Watch func(*WatchRequest, Source_WatchServer) error + type Source_WatchClient interface + Recv func() (*WatchResponse, error) + type Source_WatchServer interface + Send func(*WatchResponse) error + type WatchRequest struct + Path string + func (*WatchRequest) Descriptor() ([]byte, []int) + func (*WatchRequest) ProtoMessage() + func (m *WatchRequest) GetPath() string + func (m *WatchRequest) Reset() + func (m *WatchRequest) String() string + type WatchResponse struct + ChangeSet *ChangeSet + func (*WatchResponse) Descriptor() ([]byte, []int) + func (*WatchResponse) ProtoMessage() + func (m *WatchResponse) GetChangeSet() *ChangeSet + func (m *WatchResponse) Reset() + func (m *WatchResponse) String() string
Go to main page