pb

package
v0.0.51 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 7, 2019 License: MPL-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterBrokerServiceServer 

func RegisterBrokerServiceServer(s *grpc.Server, srv BrokerServiceServer)

Types

type BrokerServiceClient 

type BrokerServiceClient interface {
	ListSessions(ctx context.Context, in *SessionFilter, opts ...grpc.CallOption) (*ListSessionsOutput, error)
	CloseSession(ctx context.Context, in *CloseSessionInput, opts ...grpc.CallOption) (*CloseSessionOutput, error)
	DistributeMessage(ctx context.Context, in *MessagePublished, opts ...grpc.CallOption) (*MessagePublishedOutput, error)
	Connect(ctx context.Context, in *ConnectInput, opts ...grpc.CallOption) (*ConnectOutput, error)
	Disconnect(ctx context.Context, in *DisconnectInput, opts ...grpc.CallOption) (*DisconnectOutput, error)
	Publish(ctx context.Context, in *PublishInput, opts ...grpc.CallOption) (*PublishOutput, error)
	Subscribe(ctx context.Context, in *SubscribeInput, opts ...grpc.CallOption) (*SubscribeOutput, error)
	Unsubscribe(ctx context.Context, in *UnsubscribeInput, opts ...grpc.CallOption) (*UnsubscribeOutput, error)
}

BrokerServiceClient is the client API for BrokerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBrokerServiceClient 

func NewBrokerServiceClient(cc *grpc.ClientConn) BrokerServiceClient

type BrokerServiceServer 

type BrokerServiceServer interface {
	ListSessions(context.Context, *SessionFilter) (*ListSessionsOutput, error)
	CloseSession(context.Context, *CloseSessionInput) (*CloseSessionOutput, error)
	DistributeMessage(context.Context, *MessagePublished) (*MessagePublishedOutput, error)
	Connect(context.Context, *ConnectInput) (*ConnectOutput, error)
	Disconnect(context.Context, *DisconnectInput) (*DisconnectOutput, error)
	Publish(context.Context, *PublishInput) (*PublishOutput, error)
	Subscribe(context.Context, *SubscribeInput) (*SubscribeOutput, error)
	Unsubscribe(context.Context, *UnsubscribeInput) (*UnsubscribeOutput, error)
}

BrokerServiceServer is the server API for BrokerService service.

type Client 

type Client struct {
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(conn *grpc.ClientConn) *Client

func (*Client) CloseSession 

func (c *Client) CloseSession(ctx context.Context, id string) error

func (*Client) Connect 

func (c *Client) Connect(ctx context.Context, metadata transport.Metadata, connect *packet.Connect) (string, *packet.ConnAck, error)

func (*Client) Disconnect 

func (c *Client) Disconnect(ctx context.Context, id string, disconnect *packet.Disconnect) error

func (*Client) ListSessions 

func (c *Client) ListSessions(ctx context.Context) (sessions.SessionSet, error)

func (*Client) Publish 

func (c *Client) Publish(ctx context.Context, id string, publish *packet.Publish) (*packet.PubAck, error)

func (*Client) Subscribe 

func (c *Client) Subscribe(ctx context.Context, id string, subscribe *packet.Subscribe) (*packet.SubAck, error)

func (*Client) Unsubscribe 

func (c *Client) Unsubscribe(ctx context.Context, id string, unsubscribe *packet.Unsubscribe) (*packet.UnsubAck, error)

type CloseSessionInput 

type CloseSessionInput struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseSessionInput) Descriptor 

func (*CloseSessionInput) Descriptor() ([]byte, []int)

func (*CloseSessionInput) GetID 

func (m *CloseSessionInput) GetID() string

func (*CloseSessionInput) ProtoMessage 

func (*CloseSessionInput) ProtoMessage()

func (*CloseSessionInput) Reset 

func (m *CloseSessionInput) Reset()

func (*CloseSessionInput) String 

func (m *CloseSessionInput) String() string

func (*CloseSessionInput) XXX_DiscardUnknown 

func (m *CloseSessionInput) XXX_DiscardUnknown()

func (*CloseSessionInput) XXX_Marshal 

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

func (*CloseSessionInput) XXX_Merge 

func (m *CloseSessionInput) XXX_Merge(src proto.Message)

func (*CloseSessionInput) XXX_Size 

func (m *CloseSessionInput) XXX_Size() int

func (*CloseSessionInput) XXX_Unmarshal 

func (m *CloseSessionInput) XXX_Unmarshal(b []byte) error

type CloseSessionOutput 

type CloseSessionOutput struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseSessionOutput) Descriptor 

func (*CloseSessionOutput) Descriptor() ([]byte, []int)

func (*CloseSessionOutput) GetID 

func (m *CloseSessionOutput) GetID() string

func (*CloseSessionOutput) ProtoMessage 

func (*CloseSessionOutput) ProtoMessage()

func (*CloseSessionOutput) Reset 

func (m *CloseSessionOutput) Reset()

func (*CloseSessionOutput) String 

func (m *CloseSessionOutput) String() string

func (*CloseSessionOutput) XXX_DiscardUnknown 

func (m *CloseSessionOutput) XXX_DiscardUnknown()

func (*CloseSessionOutput) XXX_Marshal 

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

func (*CloseSessionOutput) XXX_Merge 

func (m *CloseSessionOutput) XXX_Merge(src proto.Message)

func (*CloseSessionOutput) XXX_Size 

func (m *CloseSessionOutput) XXX_Size() int

func (*CloseSessionOutput) XXX_Unmarshal 

func (m *CloseSessionOutput) XXX_Unmarshal(b []byte) error

type ConnectInput 

type ConnectInput struct {
	TransportMetadata    *TransportMetadata `protobuf:"bytes,1,opt,name=TransportMetadata,proto3" json:"TransportMetadata,omitempty"`
	Connect              *packet.Connect    `protobuf:"bytes,2,opt,name=Connect,proto3" json:"Connect,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ConnectInput) Descriptor 

func (*ConnectInput) Descriptor() ([]byte, []int)

func (*ConnectInput) GetConnect 

func (m *ConnectInput) GetConnect() *packet.Connect

func (*ConnectInput) GetTransportMetadata 

func (m *ConnectInput) GetTransportMetadata() *TransportMetadata

func (*ConnectInput) ProtoMessage 

func (*ConnectInput) ProtoMessage()

func (*ConnectInput) Reset 

func (m *ConnectInput) Reset()

func (*ConnectInput) String 

func (m *ConnectInput) String() string

func (*ConnectInput) XXX_DiscardUnknown 

func (m *ConnectInput) XXX_DiscardUnknown()

func (*ConnectInput) XXX_Marshal 

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

func (*ConnectInput) XXX_Merge 

func (m *ConnectInput) XXX_Merge(src proto.Message)

func (*ConnectInput) XXX_Size 

func (m *ConnectInput) XXX_Size() int

func (*ConnectInput) XXX_Unmarshal 

func (m *ConnectInput) XXX_Unmarshal(b []byte) error

type ConnectOutput 

type ConnectOutput struct {
	ID                   string          `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ConnAck              *packet.ConnAck `protobuf:"bytes,2,opt,name=ConnAck,proto3" json:"ConnAck,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ConnectOutput) Descriptor 

func (*ConnectOutput) Descriptor() ([]byte, []int)

func (*ConnectOutput) GetConnAck 

func (m *ConnectOutput) GetConnAck() *packet.ConnAck

func (*ConnectOutput) GetID 

func (m *ConnectOutput) GetID() string

func (*ConnectOutput) ProtoMessage 

func (*ConnectOutput) ProtoMessage()

func (*ConnectOutput) Reset 

func (m *ConnectOutput) Reset()

func (*ConnectOutput) String 

func (m *ConnectOutput) String() string

func (*ConnectOutput) XXX_DiscardUnknown 

func (m *ConnectOutput) XXX_DiscardUnknown()

func (*ConnectOutput) XXX_Marshal 

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

func (*ConnectOutput) XXX_Merge 

func (m *ConnectOutput) XXX_Merge(src proto.Message)

func (*ConnectOutput) XXX_Size 

func (m *ConnectOutput) XXX_Size() int

func (*ConnectOutput) XXX_Unmarshal 

func (m *ConnectOutput) XXX_Unmarshal(b []byte) error

type DisconnectInput 

type DisconnectInput struct {
	ID                   string             `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Disconnect           *packet.Disconnect `protobuf:"bytes,2,opt,name=Disconnect,proto3" json:"Disconnect,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*DisconnectInput) Descriptor 

func (*DisconnectInput) Descriptor() ([]byte, []int)

func (*DisconnectInput) GetDisconnect 

func (m *DisconnectInput) GetDisconnect() *packet.Disconnect

func (*DisconnectInput) GetID 

func (m *DisconnectInput) GetID() string

func (*DisconnectInput) ProtoMessage 

func (*DisconnectInput) ProtoMessage()

func (*DisconnectInput) Reset 

func (m *DisconnectInput) Reset()

func (*DisconnectInput) String 

func (m *DisconnectInput) String() string

func (*DisconnectInput) XXX_DiscardUnknown 

func (m *DisconnectInput) XXX_DiscardUnknown()

func (*DisconnectInput) XXX_Marshal 

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

func (*DisconnectInput) XXX_Merge 

func (m *DisconnectInput) XXX_Merge(src proto.Message)

func (*DisconnectInput) XXX_Size 

func (m *DisconnectInput) XXX_Size() int

func (*DisconnectInput) XXX_Unmarshal 

func (m *DisconnectInput) XXX_Unmarshal(b []byte) error

type DisconnectOutput 

type DisconnectOutput struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DisconnectOutput) Descriptor 

func (*DisconnectOutput) Descriptor() ([]byte, []int)

func (*DisconnectOutput) ProtoMessage 

func (*DisconnectOutput) ProtoMessage()

func (*DisconnectOutput) Reset 

func (m *DisconnectOutput) Reset()

func (*DisconnectOutput) String 

func (m *DisconnectOutput) String() string

func (*DisconnectOutput) XXX_DiscardUnknown 

func (m *DisconnectOutput) XXX_DiscardUnknown()

func (*DisconnectOutput) XXX_Marshal 

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

func (*DisconnectOutput) XXX_Merge 

func (m *DisconnectOutput) XXX_Merge(src proto.Message)

func (*DisconnectOutput) XXX_Size 

func (m *DisconnectOutput) XXX_Size() int

func (*DisconnectOutput) XXX_Unmarshal 

func (m *DisconnectOutput) XXX_Unmarshal(b []byte) error

type ListSessionsOutput 

type ListSessionsOutput struct {
	Sessions             []*sessions.Metadata `protobuf:"bytes,1,rep,name=Sessions,proto3" json:"Sessions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListSessionsOutput) Descriptor 

func (*ListSessionsOutput) Descriptor() ([]byte, []int)

func (*ListSessionsOutput) GetSessions 

func (m *ListSessionsOutput) GetSessions() []*sessions.Metadata

func (*ListSessionsOutput) ProtoMessage 

func (*ListSessionsOutput) ProtoMessage()

func (*ListSessionsOutput) Reset 

func (m *ListSessionsOutput) Reset()

func (*ListSessionsOutput) String 

func (m *ListSessionsOutput) String() string

func (*ListSessionsOutput) XXX_DiscardUnknown 

func (m *ListSessionsOutput) XXX_DiscardUnknown()

func (*ListSessionsOutput) XXX_Marshal 

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

func (*ListSessionsOutput) XXX_Merge 

func (m *ListSessionsOutput) XXX_Merge(src proto.Message)

func (*ListSessionsOutput) XXX_Size 

func (m *ListSessionsOutput) XXX_Size() int

func (*ListSessionsOutput) XXX_Unmarshal 

func (m *ListSessionsOutput) XXX_Unmarshal(b []byte) error

type MessagePublished 

type MessagePublished struct {
	Recipient            string   `protobuf:"bytes,1,opt,name=Recipient,proto3" json:"Recipient,omitempty"`
	Topic                []byte   `protobuf:"bytes,2,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Qos                  int32    `protobuf:"varint,3,opt,name=Qos,proto3" json:"Qos,omitempty"`
	Payload              []byte   `protobuf:"bytes,4,opt,name=Payload,proto3" json:"Payload,omitempty"`
	Retained             bool     `protobuf:"varint,5,opt,name=Retained,proto3" json:"Retained,omitempty"`
	Dup                  bool     `protobuf:"varint,6,opt,name=Dup,proto3" json:"Dup,omitempty"`
	Tenant               string   `protobuf:"bytes,7,opt,name=Tenant,proto3" json:"Tenant,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessagePublished) Descriptor 

func (*MessagePublished) Descriptor() ([]byte, []int)

func (*MessagePublished) GetDup 

func (m *MessagePublished) GetDup() bool

func (*MessagePublished) GetPayload 

func (m *MessagePublished) GetPayload() []byte

func (*MessagePublished) GetQos 

func (m *MessagePublished) GetQos() int32

func (*MessagePublished) GetRecipient 

func (m *MessagePublished) GetRecipient() string

func (*MessagePublished) GetRetained 

func (m *MessagePublished) GetRetained() bool

func (*MessagePublished) GetTenant 

func (m *MessagePublished) GetTenant() string

func (*MessagePublished) GetTopic 

func (m *MessagePublished) GetTopic() []byte

func (*MessagePublished) ProtoMessage 

func (*MessagePublished) ProtoMessage()

func (*MessagePublished) Reset 

func (m *MessagePublished) Reset()

func (*MessagePublished) String 

func (m *MessagePublished) String() string

func (*MessagePublished) XXX_DiscardUnknown 

func (m *MessagePublished) XXX_DiscardUnknown()

func (*MessagePublished) XXX_Marshal 

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

func (*MessagePublished) XXX_Merge 

func (m *MessagePublished) XXX_Merge(src proto.Message)

func (*MessagePublished) XXX_Size 

func (m *MessagePublished) XXX_Size() int

func (*MessagePublished) XXX_Unmarshal 

func (m *MessagePublished) XXX_Unmarshal(b []byte) error

type MessagePublishedOutput 

type MessagePublishedOutput struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessagePublishedOutput) Descriptor 

func (*MessagePublishedOutput) Descriptor() ([]byte, []int)

func (*MessagePublishedOutput) ProtoMessage 

func (*MessagePublishedOutput) ProtoMessage()

func (*MessagePublishedOutput) Reset 

func (m *MessagePublishedOutput) Reset()

func (*MessagePublishedOutput) String 

func (m *MessagePublishedOutput) String() string

func (*MessagePublishedOutput) XXX_DiscardUnknown 

func (m *MessagePublishedOutput) XXX_DiscardUnknown()

func (*MessagePublishedOutput) XXX_Marshal 

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

func (*MessagePublishedOutput) XXX_Merge 

func (m *MessagePublishedOutput) XXX_Merge(src proto.Message)

func (*MessagePublishedOutput) XXX_Size 

func (m *MessagePublishedOutput) XXX_Size() int

func (*MessagePublishedOutput) XXX_Unmarshal 

func (m *MessagePublishedOutput) XXX_Unmarshal(b []byte) error

type PublishInput 

type PublishInput struct {
	ID                   string          `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Publish              *packet.Publish `protobuf:"bytes,2,opt,name=Publish,proto3" json:"Publish,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PublishInput) Descriptor 

func (*PublishInput) Descriptor() ([]byte, []int)

func (*PublishInput) GetID 

func (m *PublishInput) GetID() string

func (*PublishInput) GetPublish 

func (m *PublishInput) GetPublish() *packet.Publish

func (*PublishInput) ProtoMessage 

func (*PublishInput) ProtoMessage()

func (*PublishInput) Reset 

func (m *PublishInput) Reset()

func (*PublishInput) String 

func (m *PublishInput) String() string

func (*PublishInput) XXX_DiscardUnknown 

func (m *PublishInput) XXX_DiscardUnknown()

func (*PublishInput) XXX_Marshal 

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

func (*PublishInput) XXX_Merge 

func (m *PublishInput) XXX_Merge(src proto.Message)

func (*PublishInput) XXX_Size 

func (m *PublishInput) XXX_Size() int

func (*PublishInput) XXX_Unmarshal 

func (m *PublishInput) XXX_Unmarshal(b []byte) error

type PublishOutput 

type PublishOutput struct {
	PubAck               *packet.PubAck `protobuf:"bytes,1,opt,name=PubAck,proto3" json:"PubAck,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*PublishOutput) Descriptor 

func (*PublishOutput) Descriptor() ([]byte, []int)

func (*PublishOutput) GetPubAck 

func (m *PublishOutput) GetPubAck() *packet.PubAck

func (*PublishOutput) ProtoMessage 

func (*PublishOutput) ProtoMessage()

func (*PublishOutput) Reset 

func (m *PublishOutput) Reset()

func (*PublishOutput) String 

func (m *PublishOutput) String() string

func (*PublishOutput) XXX_DiscardUnknown 

func (m *PublishOutput) XXX_DiscardUnknown()

func (*PublishOutput) XXX_Marshal 

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

func (*PublishOutput) XXX_Merge 

func (m *PublishOutput) XXX_Merge(src proto.Message)

func (*PublishOutput) XXX_Size 

func (m *PublishOutput) XXX_Size() int

func (*PublishOutput) XXX_Unmarshal 

func (m *PublishOutput) XXX_Unmarshal(b []byte) error

type SessionFilter 

type SessionFilter struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SessionFilter) Descriptor 

func (*SessionFilter) Descriptor() ([]byte, []int)

func (*SessionFilter) ProtoMessage 

func (*SessionFilter) ProtoMessage()

func (*SessionFilter) Reset 

func (m *SessionFilter) Reset()

func (*SessionFilter) String 

func (m *SessionFilter) String() string

func (*SessionFilter) XXX_DiscardUnknown 

func (m *SessionFilter) XXX_DiscardUnknown()

func (*SessionFilter) XXX_Marshal 

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

func (*SessionFilter) XXX_Merge 

func (m *SessionFilter) XXX_Merge(src proto.Message)

func (*SessionFilter) XXX_Size 

func (m *SessionFilter) XXX_Size() int

func (*SessionFilter) XXX_Unmarshal 

func (m *SessionFilter) XXX_Unmarshal(b []byte) error

type SubscribeInput 

type SubscribeInput struct {
	ID                   string            `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Subscribe            *packet.Subscribe `protobuf:"bytes,2,opt,name=Subscribe,proto3" json:"Subscribe,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SubscribeInput) Descriptor 

func (*SubscribeInput) Descriptor() ([]byte, []int)

func (*SubscribeInput) GetID 

func (m *SubscribeInput) GetID() string

func (*SubscribeInput) GetSubscribe 

func (m *SubscribeInput) GetSubscribe() *packet.Subscribe

func (*SubscribeInput) ProtoMessage 

func (*SubscribeInput) ProtoMessage()

func (*SubscribeInput) Reset 

func (m *SubscribeInput) Reset()

func (*SubscribeInput) String 

func (m *SubscribeInput) String() string

func (*SubscribeInput) XXX_DiscardUnknown 

func (m *SubscribeInput) XXX_DiscardUnknown()

func (*SubscribeInput) XXX_Marshal 

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

func (*SubscribeInput) XXX_Merge 

func (m *SubscribeInput) XXX_Merge(src proto.Message)

func (*SubscribeInput) XXX_Size 

func (m *SubscribeInput) XXX_Size() int

func (*SubscribeInput) XXX_Unmarshal 

func (m *SubscribeInput) XXX_Unmarshal(b []byte) error

type SubscribeOutput 

type SubscribeOutput struct {
	SubAck               *packet.SubAck `protobuf:"bytes,1,opt,name=SubAck,proto3" json:"SubAck,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*SubscribeOutput) Descriptor 

func (*SubscribeOutput) Descriptor() ([]byte, []int)

func (*SubscribeOutput) GetSubAck 

func (m *SubscribeOutput) GetSubAck() *packet.SubAck

func (*SubscribeOutput) ProtoMessage 

func (*SubscribeOutput) ProtoMessage()

func (*SubscribeOutput) Reset 

func (m *SubscribeOutput) Reset()

func (*SubscribeOutput) String 

func (m *SubscribeOutput) String() string

func (*SubscribeOutput) XXX_DiscardUnknown 

func (m *SubscribeOutput) XXX_DiscardUnknown()

func (*SubscribeOutput) XXX_Marshal 

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

func (*SubscribeOutput) XXX_Merge 

func (m *SubscribeOutput) XXX_Merge(src proto.Message)

func (*SubscribeOutput) XXX_Size 

func (m *SubscribeOutput) XXX_Size() int

func (*SubscribeOutput) XXX_Unmarshal 

func (m *SubscribeOutput) XXX_Unmarshal(b []byte) error

type TransportMetadata 

type TransportMetadata struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Encrypted            bool     `protobuf:"varint,2,opt,name=Encrypted,proto3" json:"Encrypted,omitempty"`
	RemoteAddress        string   `protobuf:"bytes,3,opt,name=RemoteAddress,proto3" json:"RemoteAddress,omitempty"`
	Endpoint             string   `protobuf:"bytes,4,opt,name=Endpoint,proto3" json:"Endpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TransportMetadata) Descriptor 

func (*TransportMetadata) Descriptor() ([]byte, []int)

func (*TransportMetadata) GetEncrypted 

func (m *TransportMetadata) GetEncrypted() bool

func (*TransportMetadata) GetEndpoint 

func (m *TransportMetadata) GetEndpoint() string

func (*TransportMetadata) GetName 

func (m *TransportMetadata) GetName() string

func (*TransportMetadata) GetRemoteAddress 

func (m *TransportMetadata) GetRemoteAddress() string

func (*TransportMetadata) ProtoMessage 

func (*TransportMetadata) ProtoMessage()

func (*TransportMetadata) Reset 

func (m *TransportMetadata) Reset()

func (*TransportMetadata) String 

func (m *TransportMetadata) String() string

func (*TransportMetadata) XXX_DiscardUnknown 

func (m *TransportMetadata) XXX_DiscardUnknown()

func (*TransportMetadata) XXX_Marshal 

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

func (*TransportMetadata) XXX_Merge 

func (m *TransportMetadata) XXX_Merge(src proto.Message)

func (*TransportMetadata) XXX_Size 

func (m *TransportMetadata) XXX_Size() int

func (*TransportMetadata) XXX_Unmarshal 

func (m *TransportMetadata) XXX_Unmarshal(b []byte) error

type UnimplementedBrokerServiceServer 

type UnimplementedBrokerServiceServer struct {
}

UnimplementedBrokerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBrokerServiceServer) CloseSession 

func (*UnimplementedBrokerServiceServer) CloseSession(ctx context.Context, req *CloseSessionInput) (*CloseSessionOutput, error)

func (*UnimplementedBrokerServiceServer) Connect 

func (*UnimplementedBrokerServiceServer) Connect(ctx context.Context, req *ConnectInput) (*ConnectOutput, error)

func (*UnimplementedBrokerServiceServer) Disconnect 

func (*UnimplementedBrokerServiceServer) Disconnect(ctx context.Context, req *DisconnectInput) (*DisconnectOutput, error)

func (*UnimplementedBrokerServiceServer) DistributeMessage 

func (*UnimplementedBrokerServiceServer) DistributeMessage(ctx context.Context, req *MessagePublished) (*MessagePublishedOutput, error)

func (*UnimplementedBrokerServiceServer) ListSessions 

func (*UnimplementedBrokerServiceServer) ListSessions(ctx context.Context, req *SessionFilter) (*ListSessionsOutput, error)

func (*UnimplementedBrokerServiceServer) Publish 

func (*UnimplementedBrokerServiceServer) Publish(ctx context.Context, req *PublishInput) (*PublishOutput, error)

func (*UnimplementedBrokerServiceServer) Subscribe 

func (*UnimplementedBrokerServiceServer) Subscribe(ctx context.Context, req *SubscribeInput) (*SubscribeOutput, error)

func (*UnimplementedBrokerServiceServer) Unsubscribe 

func (*UnimplementedBrokerServiceServer) Unsubscribe(ctx context.Context, req *UnsubscribeInput) (*UnsubscribeOutput, error)

type UnsubscribeInput 

type UnsubscribeInput struct {
	ID                   string              `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Unsubscribe          *packet.Unsubscribe `protobuf:"bytes,2,opt,name=Unsubscribe,proto3" json:"Unsubscribe,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*UnsubscribeInput) Descriptor 

func (*UnsubscribeInput) Descriptor() ([]byte, []int)

func (*UnsubscribeInput) GetID 

func (m *UnsubscribeInput) GetID() string

func (*UnsubscribeInput) GetUnsubscribe 

func (m *UnsubscribeInput) GetUnsubscribe() *packet.Unsubscribe

func (*UnsubscribeInput) ProtoMessage 

func (*UnsubscribeInput) ProtoMessage()

func (*UnsubscribeInput) Reset 

func (m *UnsubscribeInput) Reset()

func (*UnsubscribeInput) String 

func (m *UnsubscribeInput) String() string

func (*UnsubscribeInput) XXX_DiscardUnknown 

func (m *UnsubscribeInput) XXX_DiscardUnknown()

func (*UnsubscribeInput) XXX_Marshal 

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

func (*UnsubscribeInput) XXX_Merge 

func (m *UnsubscribeInput) XXX_Merge(src proto.Message)

func (*UnsubscribeInput) XXX_Size 

func (m *UnsubscribeInput) XXX_Size() int

func (*UnsubscribeInput) XXX_Unmarshal 

func (m *UnsubscribeInput) XXX_Unmarshal(b []byte) error

type UnsubscribeOutput 

type UnsubscribeOutput struct {
	UnsubAck             *packet.UnsubAck `protobuf:"bytes,1,opt,name=UnsubAck,proto3" json:"UnsubAck,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*UnsubscribeOutput) Descriptor 

func (*UnsubscribeOutput) Descriptor() ([]byte, []int)

func (*UnsubscribeOutput) GetUnsubAck 

func (m *UnsubscribeOutput) GetUnsubAck() *packet.UnsubAck

func (*UnsubscribeOutput) ProtoMessage 

func (*UnsubscribeOutput) ProtoMessage()

func (*UnsubscribeOutput) Reset 

func (m *UnsubscribeOutput) Reset()

func (*UnsubscribeOutput) String 

func (m *UnsubscribeOutput) String() string

func (*UnsubscribeOutput) XXX_DiscardUnknown 

func (m *UnsubscribeOutput) XXX_DiscardUnknown()

func (*UnsubscribeOutput) XXX_Marshal 

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

func (*UnsubscribeOutput) XXX_Merge 

func (m *UnsubscribeOutput) XXX_Merge(src proto.Message)

func (*UnsubscribeOutput) XXX_Size 

func (m *UnsubscribeOutput) XXX_Size() int

func (*UnsubscribeOutput) XXX_Unmarshal 

func (m *UnsubscribeOutput) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.