Documentation
¶
Index ¶
- Variables
- type AssignPipelineReply
- func (*AssignPipelineReply) Descriptor() ([]byte, []int)deprecated
- func (x *AssignPipelineReply) GetReason() string
- func (x *AssignPipelineReply) GetSuccess() bool
- func (*AssignPipelineReply) ProtoMessage()
- func (x *AssignPipelineReply) ProtoReflect() protoreflect.Message
- func (x *AssignPipelineReply) Reset()
- func (x *AssignPipelineReply) String() string
- type AssignPipelineRequest
- func (*AssignPipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AssignPipelineRequest) GetClientID() string
- func (x *AssignPipelineRequest) GetPipelineID() uint64
- func (*AssignPipelineRequest) ProtoMessage()
- func (x *AssignPipelineRequest) ProtoReflect() protoreflect.Message
- func (x *AssignPipelineRequest) Reset()
- func (x *AssignPipelineRequest) String() string
- type GetPipelineStateReply
- func (*GetPipelineStateReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetPipelineStateReply) GetLastSeq() uint64
- func (x *GetPipelineStateReply) GetReason() string
- func (x *GetPipelineStateReply) GetSuccess() bool
- func (*GetPipelineStateReply) ProtoMessage()
- func (x *GetPipelineStateReply) ProtoReflect() protoreflect.Message
- func (x *GetPipelineStateReply) Reset()
- func (x *GetPipelineStateReply) String() string
- type GetPipelineStateRequest
- func (*GetPipelineStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetPipelineStateRequest) GetPipelineID() string
- func (*GetPipelineStateRequest) ProtoMessage()
- func (x *GetPipelineStateRequest) ProtoReflect() protoreflect.Message
- func (x *GetPipelineStateRequest) Reset()
- func (x *GetPipelineStateRequest) String() string
- type Key
- func (*Key) Descriptor() ([]byte, []int)deprecated
- func (x *Key) GetAppID() string
- func (x *Key) GetCollections() []string
- func (x *Key) GetKey() []byte
- func (x *Key) GetPermissions() []string
- func (*Key) ProtoMessage()
- func (x *Key) ProtoReflect() protoreflect.Message
- func (x *Key) Reset()
- func (x *Key) String() string
- type PipelineFetchReply
- func (*PipelineFetchReply) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineFetchReply) GetCount() uint64
- func (x *PipelineFetchReply) GetLastSeq() uint64
- func (x *PipelineFetchReply) GetReason() string
- func (x *PipelineFetchReply) GetSuccess() bool
- func (*PipelineFetchReply) ProtoMessage()
- func (x *PipelineFetchReply) ProtoReflect() protoreflect.Message
- func (x *PipelineFetchReply) Reset()
- func (x *PipelineFetchReply) String() string
- type PipelineFetchRequest
- func (*PipelineFetchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineFetchRequest) GetCount() int64
- func (x *PipelineFetchRequest) GetOffset() uint64
- func (x *PipelineFetchRequest) GetPipelineID() uint64
- func (x *PipelineFetchRequest) GetStartAt() uint64
- func (x *PipelineFetchRequest) GetSubscriberID() string
- func (*PipelineFetchRequest) ProtoMessage()
- func (x *PipelineFetchRequest) ProtoReflect() protoreflect.Message
- func (x *PipelineFetchRequest) Reset()
- func (x *PipelineFetchRequest) String() string
- type RegisterSubscriberReply
- func (*RegisterSubscriberReply) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterSubscriberReply) GetReason() string
- func (x *RegisterSubscriberReply) GetSuccess() bool
- func (*RegisterSubscriberReply) ProtoMessage()
- func (x *RegisterSubscriberReply) ProtoReflect() protoreflect.Message
- func (x *RegisterSubscriberReply) Reset()
- func (x *RegisterSubscriberReply) String() string
- type RegisterSubscriberRequest
- func (*RegisterSubscriberRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterSubscriberRequest) GetAccessKey() string
- func (x *RegisterSubscriberRequest) GetAppID() string
- func (x *RegisterSubscriberRequest) GetName() string
- func (x *RegisterSubscriberRequest) GetSubscriberID() string
- func (*RegisterSubscriberRequest) ProtoMessage()
- func (x *RegisterSubscriberRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterSubscriberRequest) Reset()
- func (x *RegisterSubscriberRequest) String() string
- type RevokePipelineReply
- func (*RevokePipelineReply) Descriptor() ([]byte, []int)deprecated
- func (x *RevokePipelineReply) GetReason() string
- func (x *RevokePipelineReply) GetSuccess() bool
- func (*RevokePipelineReply) ProtoMessage()
- func (x *RevokePipelineReply) ProtoReflect() protoreflect.Message
- func (x *RevokePipelineReply) Reset()
- func (x *RevokePipelineReply) String() string
- type RevokePipelineRequest
- func (*RevokePipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RevokePipelineRequest) GetClientID() string
- func (x *RevokePipelineRequest) GetPipelineID() uint64
- func (*RevokePipelineRequest) ProtoMessage()
- func (x *RevokePipelineRequest) ProtoReflect() protoreflect.Message
- func (x *RevokePipelineRequest) Reset()
- func (x *RevokePipelineRequest) String() string
- type SubscribeToCollectionsReply
- func (*SubscribeToCollectionsReply) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeToCollectionsReply) GetCollections() []string
- func (x *SubscribeToCollectionsReply) GetReason() string
- func (x *SubscribeToCollectionsReply) GetSuccess() bool
- func (*SubscribeToCollectionsReply) ProtoMessage()
- func (x *SubscribeToCollectionsReply) ProtoReflect() protoreflect.Message
- func (x *SubscribeToCollectionsReply) Reset()
- func (x *SubscribeToCollectionsReply) String() string
- type SubscribeToCollectionsRequest
- func (*SubscribeToCollectionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeToCollectionsRequest) GetCollections() []string
- func (x *SubscribeToCollectionsRequest) GetSubscriberID() string
- func (*SubscribeToCollectionsRequest) ProtoMessage()
- func (x *SubscribeToCollectionsRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeToCollectionsRequest) Reset()
- func (x *SubscribeToCollectionsRequest) String() string
- type UnregisterSubscriberReply
- func (*UnregisterSubscriberReply) Descriptor() ([]byte, []int)deprecated
- func (x *UnregisterSubscriberReply) GetReason() string
- func (x *UnregisterSubscriberReply) GetSuccess() bool
- func (*UnregisterSubscriberReply) ProtoMessage()
- func (x *UnregisterSubscriberReply) ProtoReflect() protoreflect.Message
- func (x *UnregisterSubscriberReply) Reset()
- func (x *UnregisterSubscriberReply) String() string
- type UnregisterSubscriberRequest
- func (*UnregisterSubscriberRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnregisterSubscriberRequest) GetSubscriberID() string
- func (*UnregisterSubscriberRequest) ProtoMessage()
- func (x *UnregisterSubscriberRequest) ProtoReflect() protoreflect.Message
- func (x *UnregisterSubscriberRequest) Reset()
- func (x *UnregisterSubscriberRequest) String() string
- type UnsubscribeFromCollectionsReply
- func (*UnsubscribeFromCollectionsReply) Descriptor() ([]byte, []int)deprecated
- func (x *UnsubscribeFromCollectionsReply) GetCollections() []string
- func (*UnsubscribeFromCollectionsReply) ProtoMessage()
- func (x *UnsubscribeFromCollectionsReply) ProtoReflect() protoreflect.Message
- func (x *UnsubscribeFromCollectionsReply) Reset()
- func (x *UnsubscribeFromCollectionsReply) String() string
- type UnsubscribeFromCollectionsRequest
- func (*UnsubscribeFromCollectionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnsubscribeFromCollectionsRequest) GetCollections() []string
- func (x *UnsubscribeFromCollectionsRequest) GetSubscriberID() string
- func (*UnsubscribeFromCollectionsRequest) ProtoMessage()
- func (x *UnsubscribeFromCollectionsRequest) ProtoReflect() protoreflect.Message
- func (x *UnsubscribeFromCollectionsRequest) Reset()
- func (x *UnsubscribeFromCollectionsRequest) String() string
- type UpdateKeyringReply
- func (*UpdateKeyringReply) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateKeyringReply) GetReason() string
- func (x *UpdateKeyringReply) GetSuccess() bool
- func (*UpdateKeyringReply) ProtoMessage()
- func (x *UpdateKeyringReply) ProtoReflect() protoreflect.Message
- func (x *UpdateKeyringReply) Reset()
- func (x *UpdateKeyringReply) String() string
- type UpdateKeyringRequest
- func (*UpdateKeyringRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateKeyringRequest) GetKeys() []*Key
- func (*UpdateKeyringRequest) ProtoMessage()
- func (x *UpdateKeyringRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateKeyringRequest) Reset()
- func (x *UpdateKeyringRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var File_synchronizer_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AssignPipelineReply ¶
type AssignPipelineReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*AssignPipelineReply) Descriptor
deprecated
func (*AssignPipelineReply) Descriptor() ([]byte, []int)
Deprecated: Use AssignPipelineReply.ProtoReflect.Descriptor instead.
func (*AssignPipelineReply) GetReason ¶
func (x *AssignPipelineReply) GetReason() string
func (*AssignPipelineReply) GetSuccess ¶
func (x *AssignPipelineReply) GetSuccess() bool
func (*AssignPipelineReply) ProtoMessage ¶
func (*AssignPipelineReply) ProtoMessage()
func (*AssignPipelineReply) ProtoReflect ¶ added in v0.0.22
func (x *AssignPipelineReply) ProtoReflect() protoreflect.Message
func (*AssignPipelineReply) Reset ¶
func (x *AssignPipelineReply) Reset()
func (*AssignPipelineReply) String ¶
func (x *AssignPipelineReply) String() string
type AssignPipelineRequest ¶
type AssignPipelineRequest struct { ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"` PipelineID uint64 `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"` // contains filtered or unexported fields }
func (*AssignPipelineRequest) Descriptor
deprecated
func (*AssignPipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use AssignPipelineRequest.ProtoReflect.Descriptor instead.
func (*AssignPipelineRequest) GetClientID ¶
func (x *AssignPipelineRequest) GetClientID() string
func (*AssignPipelineRequest) GetPipelineID ¶
func (x *AssignPipelineRequest) GetPipelineID() uint64
func (*AssignPipelineRequest) ProtoMessage ¶
func (*AssignPipelineRequest) ProtoMessage()
func (*AssignPipelineRequest) ProtoReflect ¶ added in v0.0.22
func (x *AssignPipelineRequest) ProtoReflect() protoreflect.Message
func (*AssignPipelineRequest) Reset ¶
func (x *AssignPipelineRequest) Reset()
func (*AssignPipelineRequest) String ¶
func (x *AssignPipelineRequest) String() string
type GetPipelineStateReply ¶
type GetPipelineStateReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` LastSeq uint64 `protobuf:"varint,3,opt,name=lastSeq,proto3" json:"lastSeq,omitempty"` // contains filtered or unexported fields }
func (*GetPipelineStateReply) Descriptor
deprecated
func (*GetPipelineStateReply) Descriptor() ([]byte, []int)
Deprecated: Use GetPipelineStateReply.ProtoReflect.Descriptor instead.
func (*GetPipelineStateReply) GetLastSeq ¶
func (x *GetPipelineStateReply) GetLastSeq() uint64
func (*GetPipelineStateReply) GetReason ¶
func (x *GetPipelineStateReply) GetReason() string
func (*GetPipelineStateReply) GetSuccess ¶
func (x *GetPipelineStateReply) GetSuccess() bool
func (*GetPipelineStateReply) ProtoMessage ¶
func (*GetPipelineStateReply) ProtoMessage()
func (*GetPipelineStateReply) ProtoReflect ¶ added in v0.0.22
func (x *GetPipelineStateReply) ProtoReflect() protoreflect.Message
func (*GetPipelineStateReply) Reset ¶
func (x *GetPipelineStateReply) Reset()
func (*GetPipelineStateReply) String ¶
func (x *GetPipelineStateReply) String() string
type GetPipelineStateRequest ¶
type GetPipelineStateRequest struct { PipelineID string `protobuf:"bytes,1,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"` // contains filtered or unexported fields }
func (*GetPipelineStateRequest) Descriptor
deprecated
func (*GetPipelineStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPipelineStateRequest.ProtoReflect.Descriptor instead.
func (*GetPipelineStateRequest) GetPipelineID ¶
func (x *GetPipelineStateRequest) GetPipelineID() string
func (*GetPipelineStateRequest) ProtoMessage ¶
func (*GetPipelineStateRequest) ProtoMessage()
func (*GetPipelineStateRequest) ProtoReflect ¶ added in v0.0.22
func (x *GetPipelineStateRequest) ProtoReflect() protoreflect.Message
func (*GetPipelineStateRequest) Reset ¶
func (x *GetPipelineStateRequest) Reset()
func (*GetPipelineStateRequest) String ¶
func (x *GetPipelineStateRequest) String() string
type Key ¶ added in v0.0.22
type Key struct { AppID string `protobuf:"bytes,1,opt,name=appID,proto3" json:"appID,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Permissions []string `protobuf:"bytes,3,rep,name=permissions,proto3" json:"permissions,omitempty"` Collections []string `protobuf:"bytes,4,rep,name=collections,proto3" json:"collections,omitempty"` // contains filtered or unexported fields }
func (*Key) Descriptor
deprecated
added in
v0.0.22
func (*Key) GetCollections ¶ added in v0.0.22
func (*Key) GetPermissions ¶ added in v0.0.22
func (*Key) ProtoMessage ¶ added in v0.0.22
func (*Key) ProtoMessage()
func (*Key) ProtoReflect ¶ added in v0.0.22
func (x *Key) ProtoReflect() protoreflect.Message
type PipelineFetchReply ¶
type PipelineFetchReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` Count uint64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"` LastSeq uint64 `protobuf:"varint,4,opt,name=lastSeq,proto3" json:"lastSeq,omitempty"` // contains filtered or unexported fields }
func (*PipelineFetchReply) Descriptor
deprecated
func (*PipelineFetchReply) Descriptor() ([]byte, []int)
Deprecated: Use PipelineFetchReply.ProtoReflect.Descriptor instead.
func (*PipelineFetchReply) GetCount ¶
func (x *PipelineFetchReply) GetCount() uint64
func (*PipelineFetchReply) GetLastSeq ¶
func (x *PipelineFetchReply) GetLastSeq() uint64
func (*PipelineFetchReply) GetReason ¶
func (x *PipelineFetchReply) GetReason() string
func (*PipelineFetchReply) GetSuccess ¶
func (x *PipelineFetchReply) GetSuccess() bool
func (*PipelineFetchReply) ProtoMessage ¶
func (*PipelineFetchReply) ProtoMessage()
func (*PipelineFetchReply) ProtoReflect ¶ added in v0.0.22
func (x *PipelineFetchReply) ProtoReflect() protoreflect.Message
func (*PipelineFetchReply) Reset ¶
func (x *PipelineFetchReply) Reset()
func (*PipelineFetchReply) String ¶
func (x *PipelineFetchReply) String() string
type PipelineFetchRequest ¶
type PipelineFetchRequest struct { SubscriberID string `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"` PipelineID uint64 `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"` StartAt uint64 `protobuf:"varint,3,opt,name=startAt,proto3" json:"startAt,omitempty"` Offset uint64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` Count int64 `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*PipelineFetchRequest) Descriptor
deprecated
func (*PipelineFetchRequest) Descriptor() ([]byte, []int)
Deprecated: Use PipelineFetchRequest.ProtoReflect.Descriptor instead.
func (*PipelineFetchRequest) GetCount ¶
func (x *PipelineFetchRequest) GetCount() int64
func (*PipelineFetchRequest) GetOffset ¶
func (x *PipelineFetchRequest) GetOffset() uint64
func (*PipelineFetchRequest) GetPipelineID ¶
func (x *PipelineFetchRequest) GetPipelineID() uint64
func (*PipelineFetchRequest) GetStartAt ¶
func (x *PipelineFetchRequest) GetStartAt() uint64
func (*PipelineFetchRequest) GetSubscriberID ¶
func (x *PipelineFetchRequest) GetSubscriberID() string
func (*PipelineFetchRequest) ProtoMessage ¶
func (*PipelineFetchRequest) ProtoMessage()
func (*PipelineFetchRequest) ProtoReflect ¶ added in v0.0.22
func (x *PipelineFetchRequest) ProtoReflect() protoreflect.Message
func (*PipelineFetchRequest) Reset ¶
func (x *PipelineFetchRequest) Reset()
func (*PipelineFetchRequest) String ¶
func (x *PipelineFetchRequest) String() string
type RegisterSubscriberReply ¶
type RegisterSubscriberReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*RegisterSubscriberReply) Descriptor
deprecated
func (*RegisterSubscriberReply) Descriptor() ([]byte, []int)
Deprecated: Use RegisterSubscriberReply.ProtoReflect.Descriptor instead.
func (*RegisterSubscriberReply) GetReason ¶
func (x *RegisterSubscriberReply) GetReason() string
func (*RegisterSubscriberReply) GetSuccess ¶
func (x *RegisterSubscriberReply) GetSuccess() bool
func (*RegisterSubscriberReply) ProtoMessage ¶
func (*RegisterSubscriberReply) ProtoMessage()
func (*RegisterSubscriberReply) ProtoReflect ¶ added in v0.0.22
func (x *RegisterSubscriberReply) ProtoReflect() protoreflect.Message
func (*RegisterSubscriberReply) Reset ¶
func (x *RegisterSubscriberReply) Reset()
func (*RegisterSubscriberReply) String ¶
func (x *RegisterSubscriberReply) String() string
type RegisterSubscriberRequest ¶
type RegisterSubscriberRequest struct { SubscriberID string `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` AppID string `protobuf:"bytes,3,opt,name=AppID,proto3" json:"AppID,omitempty"` AccessKey string `protobuf:"bytes,4,opt,name=AccessKey,proto3" json:"AccessKey,omitempty"` // contains filtered or unexported fields }
func (*RegisterSubscriberRequest) Descriptor
deprecated
func (*RegisterSubscriberRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterSubscriberRequest.ProtoReflect.Descriptor instead.
func (*RegisterSubscriberRequest) GetAccessKey ¶ added in v0.0.22
func (x *RegisterSubscriberRequest) GetAccessKey() string
func (*RegisterSubscriberRequest) GetAppID ¶ added in v0.0.22
func (x *RegisterSubscriberRequest) GetAppID() string
func (*RegisterSubscriberRequest) GetName ¶
func (x *RegisterSubscriberRequest) GetName() string
func (*RegisterSubscriberRequest) GetSubscriberID ¶
func (x *RegisterSubscriberRequest) GetSubscriberID() string
func (*RegisterSubscriberRequest) ProtoMessage ¶
func (*RegisterSubscriberRequest) ProtoMessage()
func (*RegisterSubscriberRequest) ProtoReflect ¶ added in v0.0.22
func (x *RegisterSubscriberRequest) ProtoReflect() protoreflect.Message
func (*RegisterSubscriberRequest) Reset ¶
func (x *RegisterSubscriberRequest) Reset()
func (*RegisterSubscriberRequest) String ¶
func (x *RegisterSubscriberRequest) String() string
type RevokePipelineReply ¶
type RevokePipelineReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*RevokePipelineReply) Descriptor
deprecated
func (*RevokePipelineReply) Descriptor() ([]byte, []int)
Deprecated: Use RevokePipelineReply.ProtoReflect.Descriptor instead.
func (*RevokePipelineReply) GetReason ¶
func (x *RevokePipelineReply) GetReason() string
func (*RevokePipelineReply) GetSuccess ¶
func (x *RevokePipelineReply) GetSuccess() bool
func (*RevokePipelineReply) ProtoMessage ¶
func (*RevokePipelineReply) ProtoMessage()
func (*RevokePipelineReply) ProtoReflect ¶ added in v0.0.22
func (x *RevokePipelineReply) ProtoReflect() protoreflect.Message
func (*RevokePipelineReply) Reset ¶
func (x *RevokePipelineReply) Reset()
func (*RevokePipelineReply) String ¶
func (x *RevokePipelineReply) String() string
type RevokePipelineRequest ¶
type RevokePipelineRequest struct { ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"` PipelineID uint64 `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"` // contains filtered or unexported fields }
func (*RevokePipelineRequest) Descriptor
deprecated
func (*RevokePipelineRequest) Descriptor() ([]byte, []int)
Deprecated: Use RevokePipelineRequest.ProtoReflect.Descriptor instead.
func (*RevokePipelineRequest) GetClientID ¶
func (x *RevokePipelineRequest) GetClientID() string
func (*RevokePipelineRequest) GetPipelineID ¶
func (x *RevokePipelineRequest) GetPipelineID() uint64
func (*RevokePipelineRequest) ProtoMessage ¶
func (*RevokePipelineRequest) ProtoMessage()
func (*RevokePipelineRequest) ProtoReflect ¶ added in v0.0.22
func (x *RevokePipelineRequest) ProtoReflect() protoreflect.Message
func (*RevokePipelineRequest) Reset ¶
func (x *RevokePipelineRequest) Reset()
func (*RevokePipelineRequest) String ¶
func (x *RevokePipelineRequest) String() string
type SubscribeToCollectionsReply ¶
type SubscribeToCollectionsReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` Collections []string `protobuf:"bytes,3,rep,name=Collections,proto3" json:"Collections,omitempty"` // contains filtered or unexported fields }
func (*SubscribeToCollectionsReply) Descriptor
deprecated
func (*SubscribeToCollectionsReply) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeToCollectionsReply.ProtoReflect.Descriptor instead.
func (*SubscribeToCollectionsReply) GetCollections ¶
func (x *SubscribeToCollectionsReply) GetCollections() []string
func (*SubscribeToCollectionsReply) GetReason ¶
func (x *SubscribeToCollectionsReply) GetReason() string
func (*SubscribeToCollectionsReply) GetSuccess ¶
func (x *SubscribeToCollectionsReply) GetSuccess() bool
func (*SubscribeToCollectionsReply) ProtoMessage ¶
func (*SubscribeToCollectionsReply) ProtoMessage()
func (*SubscribeToCollectionsReply) ProtoReflect ¶ added in v0.0.22
func (x *SubscribeToCollectionsReply) ProtoReflect() protoreflect.Message
func (*SubscribeToCollectionsReply) Reset ¶
func (x *SubscribeToCollectionsReply) Reset()
func (*SubscribeToCollectionsReply) String ¶
func (x *SubscribeToCollectionsReply) String() string
type SubscribeToCollectionsRequest ¶
type SubscribeToCollectionsRequest struct { SubscriberID string `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"` Collections []string `protobuf:"bytes,2,rep,name=Collections,proto3" json:"Collections,omitempty"` // contains filtered or unexported fields }
func (*SubscribeToCollectionsRequest) Descriptor
deprecated
func (*SubscribeToCollectionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeToCollectionsRequest.ProtoReflect.Descriptor instead.
func (*SubscribeToCollectionsRequest) GetCollections ¶
func (x *SubscribeToCollectionsRequest) GetCollections() []string
func (*SubscribeToCollectionsRequest) GetSubscriberID ¶
func (x *SubscribeToCollectionsRequest) GetSubscriberID() string
func (*SubscribeToCollectionsRequest) ProtoMessage ¶
func (*SubscribeToCollectionsRequest) ProtoMessage()
func (*SubscribeToCollectionsRequest) ProtoReflect ¶ added in v0.0.22
func (x *SubscribeToCollectionsRequest) ProtoReflect() protoreflect.Message
func (*SubscribeToCollectionsRequest) Reset ¶
func (x *SubscribeToCollectionsRequest) Reset()
func (*SubscribeToCollectionsRequest) String ¶
func (x *SubscribeToCollectionsRequest) String() string
type UnregisterSubscriberReply ¶
type UnregisterSubscriberReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*UnregisterSubscriberReply) Descriptor
deprecated
func (*UnregisterSubscriberReply) Descriptor() ([]byte, []int)
Deprecated: Use UnregisterSubscriberReply.ProtoReflect.Descriptor instead.
func (*UnregisterSubscriberReply) GetReason ¶
func (x *UnregisterSubscriberReply) GetReason() string
func (*UnregisterSubscriberReply) GetSuccess ¶
func (x *UnregisterSubscriberReply) GetSuccess() bool
func (*UnregisterSubscriberReply) ProtoMessage ¶
func (*UnregisterSubscriberReply) ProtoMessage()
func (*UnregisterSubscriberReply) ProtoReflect ¶ added in v0.0.22
func (x *UnregisterSubscriberReply) ProtoReflect() protoreflect.Message
func (*UnregisterSubscriberReply) Reset ¶
func (x *UnregisterSubscriberReply) Reset()
func (*UnregisterSubscriberReply) String ¶
func (x *UnregisterSubscriberReply) String() string
type UnregisterSubscriberRequest ¶
type UnregisterSubscriberRequest struct { SubscriberID string `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"` // contains filtered or unexported fields }
func (*UnregisterSubscriberRequest) Descriptor
deprecated
func (*UnregisterSubscriberRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnregisterSubscriberRequest.ProtoReflect.Descriptor instead.
func (*UnregisterSubscriberRequest) GetSubscriberID ¶
func (x *UnregisterSubscriberRequest) GetSubscriberID() string
func (*UnregisterSubscriberRequest) ProtoMessage ¶
func (*UnregisterSubscriberRequest) ProtoMessage()
func (*UnregisterSubscriberRequest) ProtoReflect ¶ added in v0.0.22
func (x *UnregisterSubscriberRequest) ProtoReflect() protoreflect.Message
func (*UnregisterSubscriberRequest) Reset ¶
func (x *UnregisterSubscriberRequest) Reset()
func (*UnregisterSubscriberRequest) String ¶
func (x *UnregisterSubscriberRequest) String() string
type UnsubscribeFromCollectionsReply ¶
type UnsubscribeFromCollectionsReply struct { Collections []string `protobuf:"bytes,1,rep,name=collections,proto3" json:"collections,omitempty"` // contains filtered or unexported fields }
func (*UnsubscribeFromCollectionsReply) Descriptor
deprecated
func (*UnsubscribeFromCollectionsReply) Descriptor() ([]byte, []int)
Deprecated: Use UnsubscribeFromCollectionsReply.ProtoReflect.Descriptor instead.
func (*UnsubscribeFromCollectionsReply) GetCollections ¶
func (x *UnsubscribeFromCollectionsReply) GetCollections() []string
func (*UnsubscribeFromCollectionsReply) ProtoMessage ¶
func (*UnsubscribeFromCollectionsReply) ProtoMessage()
func (*UnsubscribeFromCollectionsReply) ProtoReflect ¶ added in v0.0.22
func (x *UnsubscribeFromCollectionsReply) ProtoReflect() protoreflect.Message
func (*UnsubscribeFromCollectionsReply) Reset ¶
func (x *UnsubscribeFromCollectionsReply) Reset()
func (*UnsubscribeFromCollectionsReply) String ¶
func (x *UnsubscribeFromCollectionsReply) String() string
type UnsubscribeFromCollectionsRequest ¶
type UnsubscribeFromCollectionsRequest struct { SubscriberID string `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"` Collections []string `protobuf:"bytes,2,rep,name=collections,proto3" json:"collections,omitempty"` // contains filtered or unexported fields }
func (*UnsubscribeFromCollectionsRequest) Descriptor
deprecated
func (*UnsubscribeFromCollectionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnsubscribeFromCollectionsRequest.ProtoReflect.Descriptor instead.
func (*UnsubscribeFromCollectionsRequest) GetCollections ¶
func (x *UnsubscribeFromCollectionsRequest) GetCollections() []string
func (*UnsubscribeFromCollectionsRequest) GetSubscriberID ¶
func (x *UnsubscribeFromCollectionsRequest) GetSubscriberID() string
func (*UnsubscribeFromCollectionsRequest) ProtoMessage ¶
func (*UnsubscribeFromCollectionsRequest) ProtoMessage()
func (*UnsubscribeFromCollectionsRequest) ProtoReflect ¶ added in v0.0.22
func (x *UnsubscribeFromCollectionsRequest) ProtoReflect() protoreflect.Message
func (*UnsubscribeFromCollectionsRequest) Reset ¶
func (x *UnsubscribeFromCollectionsRequest) Reset()
func (*UnsubscribeFromCollectionsRequest) String ¶
func (x *UnsubscribeFromCollectionsRequest) String() string
type UpdateKeyringReply ¶ added in v0.0.22
type UpdateKeyringReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*UpdateKeyringReply) Descriptor
deprecated
added in
v0.0.22
func (*UpdateKeyringReply) Descriptor() ([]byte, []int)
Deprecated: Use UpdateKeyringReply.ProtoReflect.Descriptor instead.
func (*UpdateKeyringReply) GetReason ¶ added in v0.0.22
func (x *UpdateKeyringReply) GetReason() string
func (*UpdateKeyringReply) GetSuccess ¶ added in v0.0.22
func (x *UpdateKeyringReply) GetSuccess() bool
func (*UpdateKeyringReply) ProtoMessage ¶ added in v0.0.22
func (*UpdateKeyringReply) ProtoMessage()
func (*UpdateKeyringReply) ProtoReflect ¶ added in v0.0.22
func (x *UpdateKeyringReply) ProtoReflect() protoreflect.Message
func (*UpdateKeyringReply) Reset ¶ added in v0.0.22
func (x *UpdateKeyringReply) Reset()
func (*UpdateKeyringReply) String ¶ added in v0.0.22
func (x *UpdateKeyringReply) String() string
type UpdateKeyringRequest ¶ added in v0.0.22
type UpdateKeyringRequest struct { Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // contains filtered or unexported fields }
func (*UpdateKeyringRequest) Descriptor
deprecated
added in
v0.0.22
func (*UpdateKeyringRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateKeyringRequest.ProtoReflect.Descriptor instead.
func (*UpdateKeyringRequest) GetKeys ¶ added in v0.0.22
func (x *UpdateKeyringRequest) GetKeys() []*Key
func (*UpdateKeyringRequest) ProtoMessage ¶ added in v0.0.22
func (*UpdateKeyringRequest) ProtoMessage()
func (*UpdateKeyringRequest) ProtoReflect ¶ added in v0.0.22
func (x *UpdateKeyringRequest) ProtoReflect() protoreflect.Message
func (*UpdateKeyringRequest) Reset ¶ added in v0.0.22
func (x *UpdateKeyringRequest) Reset()
func (*UpdateKeyringRequest) String ¶ added in v0.0.22
func (x *UpdateKeyringRequest) String() string