Documentation ¶
Index ¶
- Variables
- func NewSourceEndpoints() []*api.Endpoint
- func RegisterSourceHandler(s server.Server, hdlr SourceHandler, opts ...server.HandlerOption) error
- type ChangeSet
- func (*ChangeSet) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeSet) GetChecksum() string
- func (x *ChangeSet) GetData() []byte
- func (x *ChangeSet) GetFormat() string
- func (x *ChangeSet) GetSource() string
- func (x *ChangeSet) GetTimestamp() int64
- func (*ChangeSet) ProtoMessage()
- func (x *ChangeSet) ProtoReflect() protoreflect.Message
- func (x *ChangeSet) Reset()
- func (x *ChangeSet) String() string
- type ReadRequest
- type ReadResponse
- type SourceHandler
- type SourceService
- type Source_WatchService
- type Source_WatchStream
- type WatchRequest
- type WatchResponse
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WriteRequest) GetChangeSet() *ChangeSet
- func (x *WriteRequest) GetPath() string
- func (*WriteRequest) ProtoMessage()
- func (x *WriteRequest) ProtoReflect() protoreflect.Message
- func (x *WriteRequest) Reset()
- func (x *WriteRequest) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_grpc_proto protoreflect.FileDescriptor
Functions ¶
func NewSourceEndpoints ¶
func RegisterSourceHandler ¶
func RegisterSourceHandler(s server.Server, hdlr SourceHandler, opts ...server.HandlerOption) error
Types ¶
type ChangeSet ¶
type ChangeSet struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Checksum string `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"` Format string `protobuf:"bytes,3,opt,name=format,proto3" json:"format,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` Timestamp int64 `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*ChangeSet) Descriptor
deprecated
func (*ChangeSet) GetChecksum ¶
func (*ChangeSet) GetTimestamp ¶
func (*ChangeSet) ProtoMessage ¶
func (*ChangeSet) ProtoMessage()
func (*ChangeSet) ProtoReflect ¶
func (x *ChangeSet) ProtoReflect() protoreflect.Message
type ReadRequest ¶
type ReadRequest struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*ReadRequest) Descriptor
deprecated
func (*ReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.
func (*ReadRequest) GetPath ¶
func (x *ReadRequest) GetPath() string
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) ProtoReflect ¶
func (x *ReadRequest) ProtoReflect() protoreflect.Message
func (*ReadRequest) Reset ¶
func (x *ReadRequest) Reset()
func (*ReadRequest) String ¶
func (x *ReadRequest) String() string
type ReadResponse ¶
type ReadResponse struct { ChangeSet *ChangeSet `protobuf:"bytes,1,opt,name=change_set,json=changeSet,proto3" json:"change_set,omitempty"` // contains filtered or unexported fields }
func (*ReadResponse) Descriptor
deprecated
func (*ReadResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.
func (*ReadResponse) GetChangeSet ¶
func (x *ReadResponse) GetChangeSet() *ChangeSet
func (*ReadResponse) ProtoMessage ¶
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) ProtoReflect ¶
func (x *ReadResponse) ProtoReflect() protoreflect.Message
func (*ReadResponse) Reset ¶
func (x *ReadResponse) Reset()
func (*ReadResponse) String ¶
func (x *ReadResponse) String() string
type SourceHandler ¶
type SourceHandler interface { Read(context.Context, *ReadRequest, *ReadResponse) error Write(context.Context, *WriteRequest, *wrapperspb.BoolValue) error Watch(context.Context, *WatchRequest, Source_WatchStream) error }
type SourceService ¶
type SourceService interface { Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error) Write(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*wrapperspb.BoolValue, error) Watch(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Source_WatchService, error) }
func NewSourceService ¶
func NewSourceService(name string, c client.Client) SourceService
type Source_WatchService ¶
type Source_WatchStream ¶
type WatchRequest ¶
type WatchRequest struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*WatchRequest) Descriptor
deprecated
func (*WatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.
func (*WatchRequest) GetPath ¶
func (x *WatchRequest) GetPath() string
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) ProtoReflect ¶
func (x *WatchRequest) ProtoReflect() protoreflect.Message
func (*WatchRequest) Reset ¶
func (x *WatchRequest) Reset()
func (*WatchRequest) String ¶
func (x *WatchRequest) String() string
type WatchResponse ¶
type WatchResponse struct { ChangeSet *ChangeSet `protobuf:"bytes,1,opt,name=change_set,json=changeSet,proto3" json:"change_set,omitempty"` // contains filtered or unexported fields }
func (*WatchResponse) Descriptor
deprecated
func (*WatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.
func (*WatchResponse) GetChangeSet ¶
func (x *WatchResponse) GetChangeSet() *ChangeSet
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) ProtoReflect ¶
func (x *WatchResponse) ProtoReflect() protoreflect.Message
func (*WatchResponse) Reset ¶
func (x *WatchResponse) Reset()
func (*WatchResponse) String ¶
func (x *WatchResponse) String() string
type WriteRequest ¶
type WriteRequest struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` ChangeSet *ChangeSet `protobuf:"bytes,2,opt,name=change_set,json=changeSet,proto3" json:"change_set,omitempty"` // contains filtered or unexported fields }
func (*WriteRequest) Descriptor
deprecated
func (*WriteRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.
func (*WriteRequest) GetChangeSet ¶
func (x *WriteRequest) GetChangeSet() *ChangeSet
func (*WriteRequest) GetPath ¶
func (x *WriteRequest) GetPath() string
func (*WriteRequest) ProtoMessage ¶
func (*WriteRequest) ProtoMessage()
func (*WriteRequest) ProtoReflect ¶
func (x *WriteRequest) ProtoReflect() protoreflect.Message
func (*WriteRequest) Reset ¶
func (x *WriteRequest) Reset()
func (*WriteRequest) String ¶
func (x *WriteRequest) String() string
Click to show internal directories.
Click to hide internal directories.