Versions in this module Expand all Collapse all v0 v0.1.1 Oct 24, 2023 v0.1.0 Oct 23, 2023 Changes in this version + const API_VERSION + var DataType_name = map[int32]string + var DataType_value = map[string]int32 + var Error_name = map[int32]string + var Error_value = map[string]int32 + var File_api_syncd_proto protoreflect.FileDescriptor + var Sync_ServiceDesc = grpc.ServiceDesc + func LocalRecordError() *uint32 + func NoRecordError() *uint32 + func RegisterSyncServer(s grpc.ServiceRegistrar, srv SyncServer) + type AcknowledgeResponse struct + func (*AcknowledgeResponse) Descriptor() ([]byte, []int) + func (*AcknowledgeResponse) ProtoMessage() + func (x *AcknowledgeResponse) ProtoReflect() protoreflect.Message + func (x *AcknowledgeResponse) Reset() + func (x *AcknowledgeResponse) String() string + type Data struct + Bools []bool + Bytes [][]byte + Floats []float64 + Ints []int64 + IsList bool + Records []*Record + Strings []string + Type DataType + Uints []uint64 + func (*Data) Descriptor() ([]byte, []int) + func (*Data) ProtoMessage() + func (d *Data) Describe() string + func (x *Data) GetBools() []bool + func (x *Data) GetBytes() [][]byte + func (x *Data) GetFloats() []float64 + func (x *Data) GetInts() []int64 + func (x *Data) GetIsList() bool + func (x *Data) GetRecords() []*Record + func (x *Data) GetStrings() []string + func (x *Data) GetType() DataType + func (x *Data) GetUints() []uint64 + func (x *Data) ProtoReflect() protoreflect.Message + func (x *Data) Reset() + func (x *Data) String() string + type DataType int32 + const DataType_BOOL + const DataType_BYTES + const DataType_FLOAT + const DataType_INT + const DataType_RECORD + const DataType_STRING + const DataType_UINT + func (DataType) Descriptor() protoreflect.EnumDescriptor + func (DataType) EnumDescriptor() ([]byte, []int) + func (DataType) Type() protoreflect.EnumType + func (x DataType) Enum() *DataType + func (x DataType) Number() protoreflect.EnumNumber + func (x DataType) String() string + type Error int32 + const Error_MALFORMED_RECORD + const Error_SERVER_ERROR + func (Error) Descriptor() protoreflect.EnumDescriptor + func (Error) EnumDescriptor() ([]byte, []int) + func (Error) Type() protoreflect.EnumType + func (x Error) Enum() *Error + func (x Error) Number() protoreflect.EnumNumber + func (x Error) String() string + type IDataType interface + Append func(value interface{}, data *Data) error + Decode func(data *Data, value interface{}) error + Encode func(value interface{}, data *Data) error + MustAppend func(value interface{}, data *Data) + MustDecode func(data *Data, value interface{}) + MustEncode func(value interface{}, data *Data) + New func() *Data + NewList func() *Data + NewValue func() interface{} + Type func() DataType + type Info struct + ApiVersion uint32 + func CheckInfo() *Info + func (*Info) Descriptor() ([]byte, []int) + func (*Info) ProtoMessage() + func (x *Info) GetApiVersion() uint32 + func (x *Info) ProtoReflect() protoreflect.Message + func (x *Info) Reset() + func (x *Info) String() string + type IntData struct + func (IntData) Append(value interface{}, data *Data) error + func (IntData) Decode(data *Data, value interface{}) error + func (IntData) Encode(value interface{}, data *Data) (err error) + func (IntData) New() *Data + func (IntData) NewValue() interface{} + func (IntData) Type() DataType + func (s IntData) From(i int64) *Data + func (s IntData) FromAll(i ...int64) *Data + func (s IntData) MustAppend(value interface{}, data *Data) + func (s IntData) MustDecode(data *Data, value interface{}) + func (s IntData) MustEncode(value interface{}, data *Data) + func (s IntData) NewList() *Data + type Metadata struct + Model string + Peer string + func GetMetadataFromContext(ctx context.Context) (md Metadata, ok bool) + func MustGetMetadataFromContext(ctx context.Context) Metadata + func (md *Metadata) MetricLabels() prometheus.Labels + type PullRequest struct + func (*PullRequest) Descriptor() ([]byte, []int) + func (*PullRequest) ProtoMessage() + func (x *PullRequest) ProtoReflect() protoreflect.Message + func (x *PullRequest) Reset() + func (x *PullRequest) String() string + type Record struct + Fields map[string]*Data + func (*Record) Descriptor() ([]byte, []int) + func (*Record) ProtoMessage() + func (x *Record) GetFields() map[string]*Data + func (x *Record) ProtoReflect() protoreflect.Message + func (x *Record) Reset() + func (x *Record) String() string + type RecordStatus struct + Error *uint32 + ErrorField *string + Id string + Sequences map[string]uint64 + Version string + func (*RecordStatus) Descriptor() ([]byte, []int) + func (*RecordStatus) ProtoMessage() + func (x *RecordStatus) GetError() uint32 + func (x *RecordStatus) GetErrorField() string + func (x *RecordStatus) GetId() string + func (x *RecordStatus) GetSequences() map[string]uint64 + func (x *RecordStatus) GetVersion() string + func (x *RecordStatus) ProtoReflect() protoreflect.Message + func (x *RecordStatus) Reset() + func (x *RecordStatus) String() string + type StringData struct + func (StringData) Append(value interface{}, data *Data) error + func (StringData) Decode(data *Data, value interface{}) error + func (StringData) Encode(value interface{}, data *Data) (err error) + func (StringData) New() *Data + func (StringData) NewValue() interface{} + func (StringData) Type() DataType + func (s StringData) From(str string) *Data + func (s StringData) FromAll(str ...string) *Data + func (s StringData) MustAppend(value interface{}, data *Data) + func (s StringData) MustDecode(data *Data, value interface{}) + func (s StringData) MustEncode(value interface{}, data *Data) + func (s StringData) NewList() *Data + type SyncClient interface + Acknowledge func(ctx context.Context, opts ...grpc.CallOption) (Sync_AcknowledgeClient, error) + Check func(ctx context.Context, in *Info, opts ...grpc.CallOption) (*Info, error) + Pull func(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (Sync_PullClient, error) + Push func(ctx context.Context, opts ...grpc.CallOption) (Sync_PushClient, error) + func NewSyncClient(cc grpc.ClientConnInterface) SyncClient + type SyncServer interface + Acknowledge func(Sync_AcknowledgeServer) error + Check func(context.Context, *Info) (*Info, error) + Pull func(*PullRequest, Sync_PullServer) error + Push func(Sync_PushServer) error + type Sync_AcknowledgeClient interface + CloseAndRecv func() (*AcknowledgeResponse, error) + Send func(*RecordStatus) error + type Sync_AcknowledgeServer interface + Recv func() (*RecordStatus, error) + SendAndClose func(*AcknowledgeResponse) error + type Sync_PullClient interface + Recv func() (*Record, error) + type Sync_PullServer interface + Send func(*Record) error + type Sync_PushClient interface + Recv func() (*RecordStatus, error) + Send func(*Record) error + type Sync_PushServer interface + Recv func() (*Record, error) + Send func(*RecordStatus) error + type UintData struct + func (UintData) Append(value interface{}, data *Data) error + func (UintData) Decode(data *Data, value interface{}) error + func (UintData) Encode(value interface{}, data *Data) (err error) + func (UintData) New() *Data + func (UintData) NewValue() interface{} + func (UintData) Type() DataType + func (s UintData) From(i uint64) *Data + func (s UintData) FromAll(i ...uint64) *Data + func (s UintData) MustAppend(value interface{}, data *Data) + func (s UintData) MustDecode(data *Data, value interface{}) + func (s UintData) MustEncode(value interface{}, data *Data) + func (s UintData) NewList() *Data + type UnimplementedSyncServer struct + func (UnimplementedSyncServer) Acknowledge(Sync_AcknowledgeServer) error + func (UnimplementedSyncServer) Check(context.Context, *Info) (*Info, error) + func (UnimplementedSyncServer) Pull(*PullRequest, Sync_PullServer) error + func (UnimplementedSyncServer) Push(Sync_PushServer) error + type UnsafeSyncServer interface
Go to main page