__

Aug 22, 2022

Changes in this version

type RegisterSubscriberRequest

+ Pipelines []uint64

+ func (x *RegisterSubscriberRequest) GetPipelines() []uint64

type Subscriber

+ Pipelines []uint64

+ func (x *Subscriber) GetPipelines() []uint64

+ type UpdateSubscriberPropsReply struct

+ Reason string

+ Success bool

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

+ func (*UpdateSubscriberPropsReply) ProtoMessage()

+ func (x *UpdateSubscriberPropsReply) GetReason() string

+ func (x *UpdateSubscriberPropsReply) GetSuccess() bool

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

+ func (x *UpdateSubscriberPropsReply) Reset()

+ func (x *UpdateSubscriberPropsReply) String() string

+ type UpdateSubscriberPropsRequest struct

+ Pipelines []uint64

+ SubscriberID string

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

+ func (*UpdateSubscriberPropsRequest) ProtoMessage()

+ func (x *UpdateSubscriberPropsRequest) GetPipelines() []uint64

+ func (x *UpdateSubscriberPropsRequest) GetSubscriberID() string

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

+ func (x *UpdateSubscriberPropsRequest) Reset()

+ func (x *UpdateSubscriberPropsRequest) String() string

Aug 11, 2021

Changes in this version

type RegisterSubscriberReply

+ Token string

+ func (x *RegisterSubscriberReply) GetToken() string

type Subscriber

+ Collections []string

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

Jul 1, 2021

Changes in this version

type Subscriber

+ Token string

+ func (x *Subscriber) GetToken() string

Aug 8, 2021

Changes in this version

+ var File_subscriber_manager_proto protoreflect.FileDescriptor

type GetSubscribersReply

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

type GetSubscribersRequest

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

type HealthCheckReply

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

type HealthCheckRequest

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

type RegisterSubscriberReply

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

type RegisterSubscriberRequest

+ AppID string

+ Token []byte

+ func (x *RegisterSubscriberRequest) GetAppID() string

+ func (x *RegisterSubscriberRequest) GetToken() []byte

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

type SubscribeToCollectionsReply

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

type SubscribeToCollectionsRequest

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

type Subscriber

+ AccessKey string

+ AppID string

+ Permissions []string

+ func (x *Subscriber) GetAccessKey() string

+ func (x *Subscriber) GetAppID() string

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

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

type SubscriberType

+ func (SubscriberType) Descriptor() protoreflect.EnumDescriptor

+ func (SubscriberType) Type() protoreflect.EnumType

+ func (x SubscriberType) Enum() *SubscriberType

+ func (x SubscriberType) Number() protoreflect.EnumNumber

type UnregisterSubscriberReply

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

type UnregisterSubscriberRequest

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

Jun 6, 2021

Changes in this version

+ var SubscriberType_name = map[int32]string

+ var SubscriberType_value = map[string]int32

+ type GetSubscribersReply struct

+ Reason string

+ Subscribers []*Subscriber

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetSubscribersReply) ProtoMessage()

+ func (m *GetSubscribersReply) GetReason() string

+ func (m *GetSubscribersReply) GetSubscribers() []*Subscriber

+ func (m *GetSubscribersReply) GetSuccess() bool

+ func (m *GetSubscribersReply) Reset()

+ func (m *GetSubscribersReply) String() string

+ func (m *GetSubscribersReply) XXX_DiscardUnknown()

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

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

+ func (m *GetSubscribersReply) XXX_Size() int

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

+ type GetSubscribersRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetSubscribersRequest) ProtoMessage()

+ func (m *GetSubscribersRequest) Reset()

+ func (m *GetSubscribersRequest) String() string

+ func (m *GetSubscribersRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetSubscribersRequest) XXX_Size() int

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

+ type HealthCheckReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HealthCheckReply) ProtoMessage()

+ func (m *HealthCheckReply) GetReason() string

+ func (m *HealthCheckReply) GetSuccess() bool

+ func (m *HealthCheckReply) Reset()

+ func (m *HealthCheckReply) String() string

+ func (m *HealthCheckReply) XXX_DiscardUnknown()

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

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

+ func (m *HealthCheckReply) XXX_Size() int

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

+ type HealthCheckRequest struct

+ SubscriberID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*HealthCheckRequest) ProtoMessage()

+ func (m *HealthCheckRequest) GetSubscriberID() string

+ func (m *HealthCheckRequest) Reset()

+ func (m *HealthCheckRequest) String() string

+ func (m *HealthCheckRequest) XXX_DiscardUnknown()

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

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

+ func (m *HealthCheckRequest) XXX_Size() int

+ func (m *HealthCheckRequest) 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

+ Component string

+ Name string

+ SubscriberID string

+ Type SubscriberType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RegisterSubscriberRequest) ProtoMessage()

+ func (m *RegisterSubscriberRequest) GetComponent() string

+ func (m *RegisterSubscriberRequest) GetName() string

+ func (m *RegisterSubscriberRequest) GetSubscriberID() string

+ func (m *RegisterSubscriberRequest) GetType() SubscriberType

+ 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 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 Subscriber struct

+ Component string

+ LastCheck *timestamp.Timestamp

+ Name string

+ SubscriberID string

+ Type SubscriberType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Subscriber) ProtoMessage()

+ func (m *Subscriber) GetComponent() string

+ func (m *Subscriber) GetLastCheck() *timestamp.Timestamp

+ func (m *Subscriber) GetName() string

+ func (m *Subscriber) GetSubscriberID() string

+ func (m *Subscriber) GetType() SubscriberType

+ func (m *Subscriber) Reset()

+ func (m *Subscriber) String() string

+ func (m *Subscriber) XXX_DiscardUnknown()

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

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

+ func (m *Subscriber) XXX_Size() int

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

+ type SubscriberType int32

+ const SubscriberType_EXPORTER

+ const SubscriberType_TRANSMITTER

+ func (SubscriberType) EnumDescriptor() ([]byte, []int)

+ func (x SubscriberType) String() string

+ 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