__

Aug 8, 2021

Changes in this version

+ var File_synchronizer_proto protoreflect.FileDescriptor

type AssignPipelineReply

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

type AssignPipelineRequest

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

type GetPipelineStateReply

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

type GetPipelineStateRequest

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

+ type Key struct

+ AppID string

+ Collections []string

+ Key []byte

+ Permissions []string

+ func (*Key) Descriptor() ([]byte, []int)

+ func (*Key) ProtoMessage()

+ func (x *Key) GetAppID() string

+ func (x *Key) GetCollections() []string

+ func (x *Key) GetKey() []byte

+ func (x *Key) GetPermissions() []string

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

+ func (x *Key) Reset()

+ func (x *Key) String() string

type PipelineFetchReply

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

type PipelineFetchRequest

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

type RegisterSubscriberReply

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

type RegisterSubscriberRequest

+ AccessKey string

+ AppID string

+ func (x *RegisterSubscriberRequest) GetAccessKey() string

+ func (x *RegisterSubscriberRequest) GetAppID() string

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

type RevokePipelineReply

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

type RevokePipelineRequest

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

type SubscribeToCollectionsReply

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

type SubscribeToCollectionsRequest

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

type UnregisterSubscriberReply

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

type UnregisterSubscriberRequest

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

type UnsubscribeFromCollectionsReply

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

type UnsubscribeFromCollectionsRequest

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

+ type UpdateKeyringReply struct

+ Reason string

+ Success bool

+ func (*UpdateKeyringReply) Descriptor() ([]byte, []int)

+ func (*UpdateKeyringReply) ProtoMessage()

+ func (x *UpdateKeyringReply) GetReason() string

+ func (x *UpdateKeyringReply) GetSuccess() bool

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

+ func (x *UpdateKeyringReply) Reset()

+ func (x *UpdateKeyringReply) String() string

+ type UpdateKeyringRequest struct

+ Keys []*Key

+ func (*UpdateKeyringRequest) Descriptor() ([]byte, []int)

+ func (*UpdateKeyringRequest) ProtoMessage()

+ func (x *UpdateKeyringRequest) GetKeys() []*Key

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

+ func (x *UpdateKeyringRequest) Reset()

+ func (x *UpdateKeyringRequest) String() string

Jun 6, 2021

Changes in this version

+ func RegisterSynchronizerServer(s *grpc.Server, srv SynchronizerServer)

+ type AssignPipelineReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AssignPipelineReply) Descriptor() ([]byte, []int)

+ func (*AssignPipelineReply) ProtoMessage()

+ func (m *AssignPipelineReply) GetReason() string

+ func (m *AssignPipelineReply) GetSuccess() bool

+ func (m *AssignPipelineReply) Reset()

+ func (m *AssignPipelineReply) String() string

+ func (m *AssignPipelineReply) XXX_DiscardUnknown()

+ func (m *AssignPipelineReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AssignPipelineReply) XXX_Merge(src proto.Message)

+ func (m *AssignPipelineReply) XXX_Size() int

+ func (m *AssignPipelineReply) XXX_Unmarshal(b []byte) error

+ type AssignPipelineRequest struct

+ ClientID string

+ PipelineID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AssignPipelineRequest) Descriptor() ([]byte, []int)

+ func (*AssignPipelineRequest) ProtoMessage()

+ func (m *AssignPipelineRequest) GetClientID() string

+ func (m *AssignPipelineRequest) GetPipelineID() uint64

+ func (m *AssignPipelineRequest) Reset()

+ func (m *AssignPipelineRequest) String() string

+ func (m *AssignPipelineRequest) XXX_DiscardUnknown()

+ func (m *AssignPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AssignPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *AssignPipelineRequest) XXX_Size() int

+ func (m *AssignPipelineRequest) XXX_Unmarshal(b []byte) error

+ type GetPipelineStateReply struct

+ LastSeq uint64

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetPipelineStateReply) Descriptor() ([]byte, []int)

+ func (*GetPipelineStateReply) ProtoMessage()

+ func (m *GetPipelineStateReply) GetLastSeq() uint64

+ func (m *GetPipelineStateReply) GetReason() string

+ func (m *GetPipelineStateReply) GetSuccess() bool

+ func (m *GetPipelineStateReply) Reset()

+ func (m *GetPipelineStateReply) String() string

+ func (m *GetPipelineStateReply) XXX_DiscardUnknown()

+ func (m *GetPipelineStateReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetPipelineStateReply) XXX_Merge(src proto.Message)

+ func (m *GetPipelineStateReply) XXX_Size() int

+ func (m *GetPipelineStateReply) XXX_Unmarshal(b []byte) error

+ type GetPipelineStateRequest struct

+ PipelineID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetPipelineStateRequest) Descriptor() ([]byte, []int)

+ func (*GetPipelineStateRequest) ProtoMessage()

+ func (m *GetPipelineStateRequest) GetPipelineID() string

+ func (m *GetPipelineStateRequest) Reset()

+ func (m *GetPipelineStateRequest) String() string

+ func (m *GetPipelineStateRequest) XXX_DiscardUnknown()

+ func (m *GetPipelineStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetPipelineStateRequest) XXX_Merge(src proto.Message)

+ func (m *GetPipelineStateRequest) XXX_Size() int

+ func (m *GetPipelineStateRequest) XXX_Unmarshal(b []byte) error

+ type PipelineFetchReply struct

+ Count uint64

+ LastSeq uint64

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PipelineFetchReply) Descriptor() ([]byte, []int)

+ func (*PipelineFetchReply) ProtoMessage()

+ func (m *PipelineFetchReply) GetCount() uint64

+ func (m *PipelineFetchReply) GetLastSeq() uint64

+ func (m *PipelineFetchReply) GetReason() string

+ func (m *PipelineFetchReply) GetSuccess() bool

+ func (m *PipelineFetchReply) Reset()

+ func (m *PipelineFetchReply) String() string

+ func (m *PipelineFetchReply) XXX_DiscardUnknown()

+ func (m *PipelineFetchReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PipelineFetchReply) XXX_Merge(src proto.Message)

+ func (m *PipelineFetchReply) XXX_Size() int

+ func (m *PipelineFetchReply) XXX_Unmarshal(b []byte) error

+ type PipelineFetchRequest struct

+ Count int64

+ Offset uint64

+ PipelineID uint64

+ StartAt uint64

+ SubscriberID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PipelineFetchRequest) Descriptor() ([]byte, []int)

+ func (*PipelineFetchRequest) ProtoMessage()

+ func (m *PipelineFetchRequest) GetCount() int64

+ func (m *PipelineFetchRequest) GetOffset() uint64

+ func (m *PipelineFetchRequest) GetPipelineID() uint64

+ func (m *PipelineFetchRequest) GetStartAt() uint64

+ func (m *PipelineFetchRequest) GetSubscriberID() string

+ func (m *PipelineFetchRequest) Reset()

+ func (m *PipelineFetchRequest) String() string

+ func (m *PipelineFetchRequest) XXX_DiscardUnknown()

+ func (m *PipelineFetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PipelineFetchRequest) XXX_Merge(src proto.Message)

+ func (m *PipelineFetchRequest) XXX_Size() int

+ func (m *PipelineFetchRequest) XXX_Unmarshal(b []byte) error

+ type RegisterSubscriberReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RegisterSubscriberReply) Descriptor() ([]byte, []int)

+ func (*RegisterSubscriberReply) ProtoMessage()

+ func (m *RegisterSubscriberReply) GetReason() string

+ func (m *RegisterSubscriberReply) GetSuccess() bool

+ func (m *RegisterSubscriberReply) Reset()

+ func (m *RegisterSubscriberReply) String() string

+ func (m *RegisterSubscriberReply) XXX_DiscardUnknown()

+ func (m *RegisterSubscriberReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RegisterSubscriberReply) XXX_Merge(src proto.Message)

+ func (m *RegisterSubscriberReply) XXX_Size() int

+ func (m *RegisterSubscriberReply) XXX_Unmarshal(b []byte) error

+ type RegisterSubscriberRequest struct

+ Name string

+ SubscriberID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RegisterSubscriberRequest) Descriptor() ([]byte, []int)

+ func (*RegisterSubscriberRequest) ProtoMessage()

+ func (m *RegisterSubscriberRequest) GetName() string

+ func (m *RegisterSubscriberRequest) GetSubscriberID() string

+ func (m *RegisterSubscriberRequest) Reset()

+ func (m *RegisterSubscriberRequest) String() string

+ func (m *RegisterSubscriberRequest) XXX_DiscardUnknown()

+ func (m *RegisterSubscriberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RegisterSubscriberRequest) XXX_Merge(src proto.Message)

+ func (m *RegisterSubscriberRequest) XXX_Size() int

+ func (m *RegisterSubscriberRequest) XXX_Unmarshal(b []byte) error

+ type RevokePipelineReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RevokePipelineReply) Descriptor() ([]byte, []int)

+ func (*RevokePipelineReply) ProtoMessage()

+ func (m *RevokePipelineReply) GetReason() string

+ func (m *RevokePipelineReply) GetSuccess() bool

+ func (m *RevokePipelineReply) Reset()

+ func (m *RevokePipelineReply) String() string

+ func (m *RevokePipelineReply) XXX_DiscardUnknown()

+ func (m *RevokePipelineReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RevokePipelineReply) XXX_Merge(src proto.Message)

+ func (m *RevokePipelineReply) XXX_Size() int

+ func (m *RevokePipelineReply) XXX_Unmarshal(b []byte) error

+ type RevokePipelineRequest struct

+ ClientID string

+ PipelineID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RevokePipelineRequest) Descriptor() ([]byte, []int)

+ func (*RevokePipelineRequest) ProtoMessage()

+ func (m *RevokePipelineRequest) GetClientID() string

+ func (m *RevokePipelineRequest) GetPipelineID() uint64

+ func (m *RevokePipelineRequest) Reset()

+ func (m *RevokePipelineRequest) String() string

+ func (m *RevokePipelineRequest) XXX_DiscardUnknown()

+ func (m *RevokePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RevokePipelineRequest) XXX_Merge(src proto.Message)

+ func (m *RevokePipelineRequest) XXX_Size() int

+ func (m *RevokePipelineRequest) XXX_Unmarshal(b []byte) error

+ type SubscribeToCollectionsReply struct

+ Collections []string

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SubscribeToCollectionsReply) Descriptor() ([]byte, []int)

+ func (*SubscribeToCollectionsReply) ProtoMessage()

+ func (m *SubscribeToCollectionsReply) GetCollections() []string

+ func (m *SubscribeToCollectionsReply) GetReason() string

+ func (m *SubscribeToCollectionsReply) GetSuccess() bool

+ func (m *SubscribeToCollectionsReply) Reset()

+ func (m *SubscribeToCollectionsReply) String() string

+ func (m *SubscribeToCollectionsReply) XXX_DiscardUnknown()

+ func (m *SubscribeToCollectionsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SubscribeToCollectionsReply) XXX_Merge(src proto.Message)

+ func (m *SubscribeToCollectionsReply) XXX_Size() int

+ func (m *SubscribeToCollectionsReply) XXX_Unmarshal(b []byte) error

+ type SubscribeToCollectionsRequest struct

+ Collections []string

+ SubscriberID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SubscribeToCollectionsRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeToCollectionsRequest) ProtoMessage()

+ func (m *SubscribeToCollectionsRequest) GetCollections() []string

+ func (m *SubscribeToCollectionsRequest) GetSubscriberID() string

+ func (m *SubscribeToCollectionsRequest) Reset()

+ func (m *SubscribeToCollectionsRequest) String() string

+ func (m *SubscribeToCollectionsRequest) XXX_DiscardUnknown()

+ func (m *SubscribeToCollectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SubscribeToCollectionsRequest) XXX_Merge(src proto.Message)

+ func (m *SubscribeToCollectionsRequest) XXX_Size() int

+ func (m *SubscribeToCollectionsRequest) XXX_Unmarshal(b []byte) error

+ type SynchronizerClient interface

+ func NewSynchronizerClient(cc *grpc.ClientConn) SynchronizerClient

+ type SynchronizerServer interface

+ type UnimplementedSynchronizerServer struct

+ type UnregisterSubscriberReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UnregisterSubscriberReply) Descriptor() ([]byte, []int)

+ func (*UnregisterSubscriberReply) ProtoMessage()

+ func (m *UnregisterSubscriberReply) GetReason() string

+ func (m *UnregisterSubscriberReply) GetSuccess() bool

+ func (m *UnregisterSubscriberReply) Reset()

+ func (m *UnregisterSubscriberReply) String() string

+ func (m *UnregisterSubscriberReply) XXX_DiscardUnknown()

+ func (m *UnregisterSubscriberReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UnregisterSubscriberReply) XXX_Merge(src proto.Message)

+ func (m *UnregisterSubscriberReply) XXX_Size() int

+ func (m *UnregisterSubscriberReply) XXX_Unmarshal(b []byte) error

+ type UnregisterSubscriberRequest struct

+ SubscriberID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UnregisterSubscriberRequest) Descriptor() ([]byte, []int)

+ func (*UnregisterSubscriberRequest) ProtoMessage()

+ func (m *UnregisterSubscriberRequest) GetSubscriberID() string

+ func (m *UnregisterSubscriberRequest) Reset()

+ func (m *UnregisterSubscriberRequest) String() string

+ func (m *UnregisterSubscriberRequest) XXX_DiscardUnknown()

+ func (m *UnregisterSubscriberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UnregisterSubscriberRequest) XXX_Merge(src proto.Message)

+ func (m *UnregisterSubscriberRequest) XXX_Size() int

+ func (m *UnregisterSubscriberRequest) XXX_Unmarshal(b []byte) error

+ type UnsubscribeFromCollectionsReply struct

+ Collections []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UnsubscribeFromCollectionsReply) Descriptor() ([]byte, []int)

+ func (*UnsubscribeFromCollectionsReply) ProtoMessage()

+ func (m *UnsubscribeFromCollectionsReply) GetCollections() []string

+ func (m *UnsubscribeFromCollectionsReply) Reset()

+ func (m *UnsubscribeFromCollectionsReply) String() string

+ func (m *UnsubscribeFromCollectionsReply) XXX_DiscardUnknown()

+ func (m *UnsubscribeFromCollectionsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UnsubscribeFromCollectionsReply) XXX_Merge(src proto.Message)

+ func (m *UnsubscribeFromCollectionsReply) XXX_Size() int

+ func (m *UnsubscribeFromCollectionsReply) XXX_Unmarshal(b []byte) error

+ type UnsubscribeFromCollectionsRequest struct

+ Collections []string

+ SubscriberID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UnsubscribeFromCollectionsRequest) Descriptor() ([]byte, []int)

+ func (*UnsubscribeFromCollectionsRequest) ProtoMessage()

+ func (m *UnsubscribeFromCollectionsRequest) GetCollections() []string

+ func (m *UnsubscribeFromCollectionsRequest) GetSubscriberID() string

+ func (m *UnsubscribeFromCollectionsRequest) Reset()

+ func (m *UnsubscribeFromCollectionsRequest) String() string

+ func (m *UnsubscribeFromCollectionsRequest) XXX_DiscardUnknown()

+ func (m *UnsubscribeFromCollectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UnsubscribeFromCollectionsRequest) XXX_Merge(src proto.Message)

+ func (m *UnsubscribeFromCollectionsRequest) XXX_Size() int

+ func (m *UnsubscribeFromCollectionsRequest) XXX_Unmarshal(b []byte) error