Documentation
¶
Index ¶
- Constants
- Variables
- func DRPCRegisterPubSubService(mux drpc.Mux, impl DRPCPubSubServiceServer) error
- func NewSRPCPubSubServiceHandler(impl SRPCPubSubServiceServer, serviceID string) srpc.Handler
- func SRPCRegisterPubSubService(mux srpc.Mux, impl SRPCPubSubServiceServer) error
- type DRPCPubSubServiceClient
- type DRPCPubSubServiceDescription
- type DRPCPubSubServiceServer
- type DRPCPubSubServiceUnimplementedServer
- type DRPCPubSubService_SubscribeClient
- type DRPCPubSubService_SubscribeStream
- type IncomingMessage
- func (m *IncomingMessage) CloneMessageVT() proto.Message
- func (m *IncomingMessage) CloneVT() *IncomingMessage
- func (*IncomingMessage) Descriptor() ([]byte, []int)deprecated
- func (this *IncomingMessage) EqualMessageVT(thatMsg proto.Message) bool
- func (this *IncomingMessage) EqualVT(that *IncomingMessage) bool
- func (x *IncomingMessage) GetAuthenticated() bool
- func (x *IncomingMessage) GetData() []byte
- func (x *IncomingMessage) GetFromPeerId() string
- func (m *IncomingMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *IncomingMessage) MarshalToVT(dAtA []byte) (int, error)
- func (m *IncomingMessage) MarshalVT() (dAtA []byte, err error)
- func (*IncomingMessage) ProtoMessage()
- func (x *IncomingMessage) ProtoReflect() protoreflect.Message
- func (x *IncomingMessage) Reset()
- func (m *IncomingMessage) SizeVT() (n int)
- func (x *IncomingMessage) String() string
- func (m *IncomingMessage) UnmarshalVT(dAtA []byte) error
- type OutgoingStatus
- func (m *OutgoingStatus) CloneMessageVT() proto.Message
- func (m *OutgoingStatus) CloneVT() *OutgoingStatus
- func (*OutgoingStatus) Descriptor() ([]byte, []int)deprecated
- func (this *OutgoingStatus) EqualMessageVT(thatMsg proto.Message) bool
- func (this *OutgoingStatus) EqualVT(that *OutgoingStatus) bool
- func (x *OutgoingStatus) GetIdentifier() uint32
- func (x *OutgoingStatus) GetSent() bool
- func (m *OutgoingStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *OutgoingStatus) MarshalToVT(dAtA []byte) (int, error)
- func (m *OutgoingStatus) MarshalVT() (dAtA []byte, err error)
- func (*OutgoingStatus) ProtoMessage()
- func (x *OutgoingStatus) ProtoReflect() protoreflect.Message
- func (x *OutgoingStatus) Reset()
- func (m *OutgoingStatus) SizeVT() (n int)
- func (x *OutgoingStatus) String() string
- func (m *OutgoingStatus) UnmarshalVT(dAtA []byte) error
- type PublishRequest
- func (m *PublishRequest) CloneMessageVT() proto.Message
- func (m *PublishRequest) CloneVT() *PublishRequest
- func (*PublishRequest) Descriptor() ([]byte, []int)deprecated
- func (this *PublishRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *PublishRequest) EqualVT(that *PublishRequest) bool
- func (x *PublishRequest) GetData() []byte
- func (x *PublishRequest) GetIdentifier() uint32
- func (m *PublishRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PublishRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *PublishRequest) MarshalVT() (dAtA []byte, err error)
- func (*PublishRequest) ProtoMessage()
- func (x *PublishRequest) ProtoReflect() protoreflect.Message
- func (x *PublishRequest) Reset()
- func (m *PublishRequest) SizeVT() (n int)
- func (x *PublishRequest) String() string
- func (m *PublishRequest) UnmarshalVT(dAtA []byte) error
- type SRPCPubSubServiceClient
- type SRPCPubSubServiceHandler
- func (SRPCPubSubServiceHandler) GetMethodIDs() []string
- func (d *SRPCPubSubServiceHandler) GetServiceID() string
- func (d *SRPCPubSubServiceHandler) InvokeMethod(serviceID, methodID string, strm srpc.Stream) (bool, error)
- func (SRPCPubSubServiceHandler) InvokeMethod_Subscribe(impl SRPCPubSubServiceServer, strm srpc.Stream) error
- type SRPCPubSubServiceServer
- type SRPCPubSubServiceUnimplementedServer
- type SRPCPubSubService_SubscribeClient
- type SRPCPubSubService_SubscribeStream
- type SubscribeRequest
- func (m *SubscribeRequest) CloneMessageVT() proto.Message
- func (m *SubscribeRequest) CloneVT() *SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (this *SubscribeRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *SubscribeRequest) EqualVT(that *SubscribeRequest) bool
- func (x *SubscribeRequest) GetChannelId() string
- func (x *SubscribeRequest) GetPeerId() string
- func (x *SubscribeRequest) GetPrivKeyPem() string
- func (x *SubscribeRequest) GetPublishRequest() *PublishRequest
- func (m *SubscribeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SubscribeRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *SubscribeRequest) MarshalVT() (dAtA []byte, err error)
- func (*SubscribeRequest) ProtoMessage()
- func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeRequest) Reset()
- func (m *SubscribeRequest) SizeVT() (n int)
- func (x *SubscribeRequest) String() string
- func (m *SubscribeRequest) UnmarshalVT(dAtA []byte) error
- type SubscribeResponse
- func (m *SubscribeResponse) CloneMessageVT() proto.Message
- func (m *SubscribeResponse) CloneVT() *SubscribeResponse
- func (*SubscribeResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SubscribeResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *SubscribeResponse) EqualVT(that *SubscribeResponse) bool
- func (x *SubscribeResponse) GetIncomingMessage() *IncomingMessage
- func (x *SubscribeResponse) GetOutgoingStatus() *OutgoingStatus
- func (x *SubscribeResponse) GetSubscriptionStatus() *SubscriptionStatus
- func (m *SubscribeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SubscribeResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *SubscribeResponse) MarshalVT() (dAtA []byte, err error)
- func (*SubscribeResponse) ProtoMessage()
- func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeResponse) Reset()
- func (m *SubscribeResponse) SizeVT() (n int)
- func (x *SubscribeResponse) String() string
- func (m *SubscribeResponse) UnmarshalVT(dAtA []byte) error
- type SubscriptionStatus
- func (m *SubscriptionStatus) CloneMessageVT() proto.Message
- func (m *SubscriptionStatus) CloneVT() *SubscriptionStatus
- func (*SubscriptionStatus) Descriptor() ([]byte, []int)deprecated
- func (this *SubscriptionStatus) EqualMessageVT(thatMsg proto.Message) bool
- func (this *SubscriptionStatus) EqualVT(that *SubscriptionStatus) bool
- func (x *SubscriptionStatus) GetSubscribed() bool
- func (m *SubscriptionStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SubscriptionStatus) MarshalToVT(dAtA []byte) (int, error)
- func (m *SubscriptionStatus) MarshalVT() (dAtA []byte, err error)
- func (*SubscriptionStatus) ProtoMessage()
- func (x *SubscriptionStatus) ProtoReflect() protoreflect.Message
- func (x *SubscriptionStatus) Reset()
- func (m *SubscriptionStatus) SizeVT() (n int)
- func (x *SubscriptionStatus) String() string
- func (m *SubscriptionStatus) UnmarshalVT(dAtA []byte) error
Constants ¶
const SRPCPubSubServiceServiceID = "pubsub.api.PubSubService"
Variables ¶
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
var File_github_com_aperturerobotics_bifrost_pubsub_api_api_proto protoreflect.FileDescriptor
Functions ¶
func DRPCRegisterPubSubService ¶
func DRPCRegisterPubSubService(mux drpc.Mux, impl DRPCPubSubServiceServer) error
func NewSRPCPubSubServiceHandler ¶ added in v0.7.2
func NewSRPCPubSubServiceHandler(impl SRPCPubSubServiceServer, serviceID string) srpc.Handler
NewSRPCPubSubServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: pubsub.api.PubSubService
func SRPCRegisterPubSubService ¶ added in v0.3.0
func SRPCRegisterPubSubService(mux srpc.Mux, impl SRPCPubSubServiceServer) error
SRPCRegisterPubSubService registers the implementation with the mux. Uses the default serviceID: pubsub.api.PubSubService
Types ¶
type DRPCPubSubServiceClient ¶
type DRPCPubSubServiceClient interface { DRPCConn() drpc.Conn Subscribe(ctx context.Context) (DRPCPubSubService_SubscribeClient, error) }
func NewDRPCPubSubServiceClient ¶
func NewDRPCPubSubServiceClient(cc drpc.Conn) DRPCPubSubServiceClient
type DRPCPubSubServiceDescription ¶
type DRPCPubSubServiceDescription struct{}
func (DRPCPubSubServiceDescription) NumMethods ¶
func (DRPCPubSubServiceDescription) NumMethods() int
type DRPCPubSubServiceServer ¶
type DRPCPubSubServiceServer interface {
Subscribe(DRPCPubSubService_SubscribeStream) error
}
type DRPCPubSubServiceUnimplementedServer ¶
type DRPCPubSubServiceUnimplementedServer struct{}
func (*DRPCPubSubServiceUnimplementedServer) Subscribe ¶
func (s *DRPCPubSubServiceUnimplementedServer) Subscribe(DRPCPubSubService_SubscribeStream) error
type DRPCPubSubService_SubscribeClient ¶
type DRPCPubSubService_SubscribeClient interface { drpc.Stream Send(*SubscribeRequest) error Recv() (*SubscribeResponse, error) }
type DRPCPubSubService_SubscribeStream ¶
type DRPCPubSubService_SubscribeStream interface { drpc.Stream Send(*SubscribeResponse) error Recv() (*SubscribeRequest, error) }
type IncomingMessage ¶
type IncomingMessage struct { // FromPeerId is the peer identifier of the sender. FromPeerId string `protobuf:"bytes,1,opt,name=from_peer_id,json=fromPeerId,proto3" json:"from_peer_id,omitempty"` // Authenticated indicates if the message is verified to be from the sender. Authenticated bool `protobuf:"varint,2,opt,name=authenticated,proto3" json:"authenticated,omitempty"` // Data is the inner data. Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
IncomingMessage implements Message with a proto object.
func (*IncomingMessage) CloneMessageVT ¶ added in v0.15.6
func (m *IncomingMessage) CloneMessageVT() proto.Message
func (*IncomingMessage) CloneVT ¶ added in v0.8.3
func (m *IncomingMessage) CloneVT() *IncomingMessage
func (*IncomingMessage) Descriptor
deprecated
func (*IncomingMessage) Descriptor() ([]byte, []int)
Deprecated: Use IncomingMessage.ProtoReflect.Descriptor instead.
func (*IncomingMessage) EqualMessageVT ¶ added in v0.15.6
func (this *IncomingMessage) EqualMessageVT(thatMsg proto.Message) bool
func (*IncomingMessage) EqualVT ¶ added in v0.3.0
func (this *IncomingMessage) EqualVT(that *IncomingMessage) bool
func (*IncomingMessage) GetAuthenticated ¶
func (x *IncomingMessage) GetAuthenticated() bool
func (*IncomingMessage) GetData ¶
func (x *IncomingMessage) GetData() []byte
func (*IncomingMessage) GetFromPeerId ¶
func (x *IncomingMessage) GetFromPeerId() string
func (*IncomingMessage) MarshalToSizedBufferVT ¶ added in v0.2.0
func (m *IncomingMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*IncomingMessage) MarshalToVT ¶ added in v0.2.0
func (m *IncomingMessage) MarshalToVT(dAtA []byte) (int, error)
func (*IncomingMessage) MarshalVT ¶ added in v0.2.0
func (m *IncomingMessage) MarshalVT() (dAtA []byte, err error)
func (*IncomingMessage) ProtoMessage ¶
func (*IncomingMessage) ProtoMessage()
func (*IncomingMessage) ProtoReflect ¶ added in v0.2.0
func (x *IncomingMessage) ProtoReflect() protoreflect.Message
func (*IncomingMessage) Reset ¶
func (x *IncomingMessage) Reset()
func (*IncomingMessage) SizeVT ¶ added in v0.2.0
func (m *IncomingMessage) SizeVT() (n int)
func (*IncomingMessage) String ¶
func (x *IncomingMessage) String() string
func (*IncomingMessage) UnmarshalVT ¶ added in v0.2.0
func (m *IncomingMessage) UnmarshalVT(dAtA []byte) error
type OutgoingStatus ¶
type OutgoingStatus struct { // Identifier is the request-provided identifier for the message. Identifier uint32 `protobuf:"varint,1,opt,name=identifier,proto3" json:"identifier,omitempty"` // Sent indicates if the message was sent. Sent bool `protobuf:"varint,2,opt,name=sent,proto3" json:"sent,omitempty"` // contains filtered or unexported fields }
OutgoingStatus is status of an outgoing message.
func (*OutgoingStatus) CloneMessageVT ¶ added in v0.15.6
func (m *OutgoingStatus) CloneMessageVT() proto.Message
func (*OutgoingStatus) CloneVT ¶ added in v0.8.3
func (m *OutgoingStatus) CloneVT() *OutgoingStatus
func (*OutgoingStatus) Descriptor
deprecated
func (*OutgoingStatus) Descriptor() ([]byte, []int)
Deprecated: Use OutgoingStatus.ProtoReflect.Descriptor instead.
func (*OutgoingStatus) EqualMessageVT ¶ added in v0.15.6
func (this *OutgoingStatus) EqualMessageVT(thatMsg proto.Message) bool
func (*OutgoingStatus) EqualVT ¶ added in v0.3.0
func (this *OutgoingStatus) EqualVT(that *OutgoingStatus) bool
func (*OutgoingStatus) GetIdentifier ¶
func (x *OutgoingStatus) GetIdentifier() uint32
func (*OutgoingStatus) GetSent ¶
func (x *OutgoingStatus) GetSent() bool
func (*OutgoingStatus) MarshalToSizedBufferVT ¶ added in v0.2.0
func (m *OutgoingStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*OutgoingStatus) MarshalToVT ¶ added in v0.2.0
func (m *OutgoingStatus) MarshalToVT(dAtA []byte) (int, error)
func (*OutgoingStatus) MarshalVT ¶ added in v0.2.0
func (m *OutgoingStatus) MarshalVT() (dAtA []byte, err error)
func (*OutgoingStatus) ProtoMessage ¶
func (*OutgoingStatus) ProtoMessage()
func (*OutgoingStatus) ProtoReflect ¶ added in v0.2.0
func (x *OutgoingStatus) ProtoReflect() protoreflect.Message
func (*OutgoingStatus) Reset ¶
func (x *OutgoingStatus) Reset()
func (*OutgoingStatus) SizeVT ¶ added in v0.2.0
func (m *OutgoingStatus) SizeVT() (n int)
func (*OutgoingStatus) String ¶
func (x *OutgoingStatus) String() string
func (*OutgoingStatus) UnmarshalVT ¶ added in v0.2.0
func (m *OutgoingStatus) UnmarshalVT(dAtA []byte) error
type PublishRequest ¶
type PublishRequest struct { // Data is the published data. Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // Identifier is a uint32 identifier to use for outgoing status. // If zero, no outgoing status response will be sent. Identifier uint32 `protobuf:"varint,2,opt,name=identifier,proto3" json:"identifier,omitempty"` // contains filtered or unexported fields }
PublishRequest is a message published via the subscribe channel.
func (*PublishRequest) CloneMessageVT ¶ added in v0.15.6
func (m *PublishRequest) CloneMessageVT() proto.Message
func (*PublishRequest) CloneVT ¶ added in v0.8.3
func (m *PublishRequest) CloneVT() *PublishRequest
func (*PublishRequest) Descriptor
deprecated
func (*PublishRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.
func (*PublishRequest) EqualMessageVT ¶ added in v0.15.6
func (this *PublishRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*PublishRequest) EqualVT ¶ added in v0.3.0
func (this *PublishRequest) EqualVT(that *PublishRequest) bool
func (*PublishRequest) GetData ¶
func (x *PublishRequest) GetData() []byte
func (*PublishRequest) GetIdentifier ¶
func (x *PublishRequest) GetIdentifier() uint32
func (*PublishRequest) MarshalToSizedBufferVT ¶ added in v0.2.0
func (m *PublishRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*PublishRequest) MarshalToVT ¶ added in v0.2.0
func (m *PublishRequest) MarshalToVT(dAtA []byte) (int, error)
func (*PublishRequest) MarshalVT ¶ added in v0.2.0
func (m *PublishRequest) MarshalVT() (dAtA []byte, err error)
func (*PublishRequest) ProtoMessage ¶
func (*PublishRequest) ProtoMessage()
func (*PublishRequest) ProtoReflect ¶ added in v0.2.0
func (x *PublishRequest) ProtoReflect() protoreflect.Message
func (*PublishRequest) Reset ¶
func (x *PublishRequest) Reset()
func (*PublishRequest) SizeVT ¶ added in v0.2.0
func (m *PublishRequest) SizeVT() (n int)
func (*PublishRequest) String ¶
func (x *PublishRequest) String() string
func (*PublishRequest) UnmarshalVT ¶ added in v0.2.0
func (m *PublishRequest) UnmarshalVT(dAtA []byte) error
type SRPCPubSubServiceClient ¶ added in v0.3.0
type SRPCPubSubServiceClient interface { SRPCClient() srpc.Client Subscribe(ctx context.Context) (SRPCPubSubService_SubscribeClient, error) }
func NewSRPCPubSubServiceClient ¶ added in v0.3.0
func NewSRPCPubSubServiceClient(cc srpc.Client) SRPCPubSubServiceClient
func NewSRPCPubSubServiceClientWithServiceID ¶ added in v0.7.2
func NewSRPCPubSubServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCPubSubServiceClient
type SRPCPubSubServiceHandler ¶ added in v0.3.0
type SRPCPubSubServiceHandler struct {
// contains filtered or unexported fields
}
func (SRPCPubSubServiceHandler) GetMethodIDs ¶ added in v0.3.0
func (SRPCPubSubServiceHandler) GetMethodIDs() []string
func (*SRPCPubSubServiceHandler) GetServiceID ¶ added in v0.3.0
func (d *SRPCPubSubServiceHandler) GetServiceID() string
func (*SRPCPubSubServiceHandler) InvokeMethod ¶ added in v0.3.0
func (SRPCPubSubServiceHandler) InvokeMethod_Subscribe ¶ added in v0.3.0
func (SRPCPubSubServiceHandler) InvokeMethod_Subscribe(impl SRPCPubSubServiceServer, strm srpc.Stream) error
type SRPCPubSubServiceServer ¶ added in v0.3.0
type SRPCPubSubServiceServer interface {
Subscribe(SRPCPubSubService_SubscribeStream) error
}
type SRPCPubSubServiceUnimplementedServer ¶ added in v0.3.0
type SRPCPubSubServiceUnimplementedServer struct{}
func (*SRPCPubSubServiceUnimplementedServer) Subscribe ¶ added in v0.3.0
func (s *SRPCPubSubServiceUnimplementedServer) Subscribe(SRPCPubSubService_SubscribeStream) error
type SRPCPubSubService_SubscribeClient ¶ added in v0.3.0
type SRPCPubSubService_SubscribeClient interface { srpc.Stream Send(*SubscribeRequest) error Recv() (*SubscribeResponse, error) RecvTo(*SubscribeResponse) error }
type SRPCPubSubService_SubscribeStream ¶ added in v0.3.0
type SRPCPubSubService_SubscribeStream interface { srpc.Stream Send(*SubscribeResponse) error SendAndClose(*SubscribeResponse) error Recv() (*SubscribeRequest, error) }
type SubscribeRequest ¶
type SubscribeRequest struct { // ChannelId is the channel id to subscribe to. // Must be sent before / with publish. // Cannot change the channel ID after first transmission. ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // PeerId is the peer identifier of the publisher/subscriber. // The peer ID will be used to acquire the peer private key. PeerId string `protobuf:"bytes,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"` // PrivKeyPem is an alternate to PeerId, specify private key inline. // Overrides PeerId if set. PrivKeyPem string `protobuf:"bytes,3,opt,name=priv_key_pem,json=privKeyPem,proto3" json:"priv_key_pem,omitempty"` // PublishRequest contains a publish message request. PublishRequest *PublishRequest `protobuf:"bytes,4,opt,name=publish_request,json=publishRequest,proto3" json:"publish_request,omitempty"` // contains filtered or unexported fields }
SubcribeRequest is a pubsub subscription request message.
func (*SubscribeRequest) CloneMessageVT ¶ added in v0.15.6
func (m *SubscribeRequest) CloneMessageVT() proto.Message
func (*SubscribeRequest) CloneVT ¶ added in v0.8.3
func (m *SubscribeRequest) CloneVT() *SubscribeRequest
func (*SubscribeRequest) Descriptor
deprecated
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) EqualMessageVT ¶ added in v0.15.6
func (this *SubscribeRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*SubscribeRequest) EqualVT ¶ added in v0.3.0
func (this *SubscribeRequest) EqualVT(that *SubscribeRequest) bool
func (*SubscribeRequest) GetChannelId ¶
func (x *SubscribeRequest) GetChannelId() string
func (*SubscribeRequest) GetPeerId ¶
func (x *SubscribeRequest) GetPeerId() string
func (*SubscribeRequest) GetPrivKeyPem ¶
func (x *SubscribeRequest) GetPrivKeyPem() string
func (*SubscribeRequest) GetPublishRequest ¶
func (x *SubscribeRequest) GetPublishRequest() *PublishRequest
func (*SubscribeRequest) MarshalToSizedBufferVT ¶ added in v0.2.0
func (m *SubscribeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SubscribeRequest) MarshalToVT ¶ added in v0.2.0
func (m *SubscribeRequest) MarshalToVT(dAtA []byte) (int, error)
func (*SubscribeRequest) MarshalVT ¶ added in v0.2.0
func (m *SubscribeRequest) MarshalVT() (dAtA []byte, err error)
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶ added in v0.2.0
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) SizeVT ¶ added in v0.2.0
func (m *SubscribeRequest) SizeVT() (n int)
func (*SubscribeRequest) String ¶
func (x *SubscribeRequest) String() string
func (*SubscribeRequest) UnmarshalVT ¶ added in v0.2.0
func (m *SubscribeRequest) UnmarshalVT(dAtA []byte) error
type SubscribeResponse ¶
type SubscribeResponse struct { // IncomingMessage is an incoming message. IncomingMessage *IncomingMessage `protobuf:"bytes,1,opt,name=incoming_message,json=incomingMessage,proto3" json:"incoming_message,omitempty"` // OutgoingStatus is status of an outgoing message. // Sent when a Publish request finishes. OutgoingStatus *OutgoingStatus `protobuf:"bytes,2,opt,name=outgoing_status,json=outgoingStatus,proto3" json:"outgoing_status,omitempty"` // SubscriptionStatus is the status of the subscription SubscriptionStatus *SubscriptionStatus `protobuf:"bytes,3,opt,name=subscription_status,json=subscriptionStatus,proto3" json:"subscription_status,omitempty"` // contains filtered or unexported fields }
SubcribeResponse is a pubsub subscription response message.
func (*SubscribeResponse) CloneMessageVT ¶ added in v0.15.6
func (m *SubscribeResponse) CloneMessageVT() proto.Message
func (*SubscribeResponse) CloneVT ¶ added in v0.8.3
func (m *SubscribeResponse) CloneVT() *SubscribeResponse
func (*SubscribeResponse) Descriptor
deprecated
func (*SubscribeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.
func (*SubscribeResponse) EqualMessageVT ¶ added in v0.15.6
func (this *SubscribeResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*SubscribeResponse) EqualVT ¶ added in v0.3.0
func (this *SubscribeResponse) EqualVT(that *SubscribeResponse) bool
func (*SubscribeResponse) GetIncomingMessage ¶
func (x *SubscribeResponse) GetIncomingMessage() *IncomingMessage
func (*SubscribeResponse) GetOutgoingStatus ¶
func (x *SubscribeResponse) GetOutgoingStatus() *OutgoingStatus
func (*SubscribeResponse) GetSubscriptionStatus ¶
func (x *SubscribeResponse) GetSubscriptionStatus() *SubscriptionStatus
func (*SubscribeResponse) MarshalToSizedBufferVT ¶ added in v0.2.0
func (m *SubscribeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SubscribeResponse) MarshalToVT ¶ added in v0.2.0
func (m *SubscribeResponse) MarshalToVT(dAtA []byte) (int, error)
func (*SubscribeResponse) MarshalVT ¶ added in v0.2.0
func (m *SubscribeResponse) MarshalVT() (dAtA []byte, err error)
func (*SubscribeResponse) ProtoMessage ¶
func (*SubscribeResponse) ProtoMessage()
func (*SubscribeResponse) ProtoReflect ¶ added in v0.2.0
func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
func (*SubscribeResponse) Reset ¶
func (x *SubscribeResponse) Reset()
func (*SubscribeResponse) SizeVT ¶ added in v0.2.0
func (m *SubscribeResponse) SizeVT() (n int)
func (*SubscribeResponse) String ¶
func (x *SubscribeResponse) String() string
func (*SubscribeResponse) UnmarshalVT ¶ added in v0.2.0
func (m *SubscribeResponse) UnmarshalVT(dAtA []byte) error
type SubscriptionStatus ¶
type SubscriptionStatus struct { // Subscribed indicates the subscription is established. Subscribed bool `protobuf:"varint,1,opt,name=subscribed,proto3" json:"subscribed,omitempty"` // contains filtered or unexported fields }
SubscripionStatus is the status of the subscription handle.
func (*SubscriptionStatus) CloneMessageVT ¶ added in v0.15.6
func (m *SubscriptionStatus) CloneMessageVT() proto.Message
func (*SubscriptionStatus) CloneVT ¶ added in v0.8.3
func (m *SubscriptionStatus) CloneVT() *SubscriptionStatus
func (*SubscriptionStatus) Descriptor
deprecated
func (*SubscriptionStatus) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionStatus.ProtoReflect.Descriptor instead.
func (*SubscriptionStatus) EqualMessageVT ¶ added in v0.15.6
func (this *SubscriptionStatus) EqualMessageVT(thatMsg proto.Message) bool
func (*SubscriptionStatus) EqualVT ¶ added in v0.3.0
func (this *SubscriptionStatus) EqualVT(that *SubscriptionStatus) bool
func (*SubscriptionStatus) GetSubscribed ¶
func (x *SubscriptionStatus) GetSubscribed() bool
func (*SubscriptionStatus) MarshalToSizedBufferVT ¶ added in v0.2.0
func (m *SubscriptionStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SubscriptionStatus) MarshalToVT ¶ added in v0.2.0
func (m *SubscriptionStatus) MarshalToVT(dAtA []byte) (int, error)
func (*SubscriptionStatus) MarshalVT ¶ added in v0.2.0
func (m *SubscriptionStatus) MarshalVT() (dAtA []byte, err error)
func (*SubscriptionStatus) ProtoMessage ¶
func (*SubscriptionStatus) ProtoMessage()
func (*SubscriptionStatus) ProtoReflect ¶ added in v0.2.0
func (x *SubscriptionStatus) ProtoReflect() protoreflect.Message
func (*SubscriptionStatus) Reset ¶
func (x *SubscriptionStatus) Reset()
func (*SubscriptionStatus) SizeVT ¶ added in v0.2.0
func (m *SubscriptionStatus) SizeVT() (n int)
func (*SubscriptionStatus) String ¶
func (x *SubscriptionStatus) String() string
func (*SubscriptionStatus) UnmarshalVT ¶ added in v0.2.0
func (m *SubscriptionStatus) UnmarshalVT(dAtA []byte) error