api

package
v1.7.1 Latest Latest
Warning

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

 Go to latest Published: Jul 3, 2020 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMQTTServer 

func RegisterMQTTServer(s *grpc.Server, srv MQTTServer)

Types

type CreateSubscriptionRequest 

type CreateSubscriptionRequest struct {
	SessionID            string   `protobuf:"bytes,1,opt,name=SessionID,proto3" json:"SessionID,omitempty"`
	Peer                 uint64   `protobuf:"varint,2,opt,name=Peer,proto3" json:"Peer,omitempty"`
	Pattern              []byte   `protobuf:"bytes,3,opt,name=Pattern,proto3" json:"Pattern,omitempty"`
	QoS                  int32    `protobuf:"varint,4,opt,name=QoS,proto3" json:"QoS,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateSubscriptionRequest) Descriptor 

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

func (*CreateSubscriptionRequest) GetPattern 

func (m *CreateSubscriptionRequest) GetPattern() []byte

func (*CreateSubscriptionRequest) GetPeer 

func (m *CreateSubscriptionRequest) GetPeer() uint64

func (*CreateSubscriptionRequest) GetQoS 

func (m *CreateSubscriptionRequest) GetQoS() int32

func (*CreateSubscriptionRequest) GetSessionID 

func (m *CreateSubscriptionRequest) GetSessionID() string

func (*CreateSubscriptionRequest) ProtoMessage 

func (*CreateSubscriptionRequest) ProtoMessage()

func (*CreateSubscriptionRequest) Reset 

func (m *CreateSubscriptionRequest) Reset()

func (*CreateSubscriptionRequest) String 

func (m *CreateSubscriptionRequest) String() string

func (*CreateSubscriptionRequest) XXX_DiscardUnknown 

func (m *CreateSubscriptionRequest) XXX_DiscardUnknown()

func (*CreateSubscriptionRequest) XXX_Marshal 

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

func (*CreateSubscriptionRequest) XXX_Merge 

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

func (*CreateSubscriptionRequest) XXX_Size 

func (m *CreateSubscriptionRequest) XXX_Size() int

func (*CreateSubscriptionRequest) XXX_Unmarshal 

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

type CreateSubscriptionResponse 

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

func (*CreateSubscriptionResponse) Descriptor 

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

func (*CreateSubscriptionResponse) ProtoMessage 

func (*CreateSubscriptionResponse) ProtoMessage()

func (*CreateSubscriptionResponse) Reset 

func (m *CreateSubscriptionResponse) Reset()

func (*CreateSubscriptionResponse) String 

func (m *CreateSubscriptionResponse) String() string

func (*CreateSubscriptionResponse) XXX_DiscardUnknown 

func (m *CreateSubscriptionResponse) XXX_DiscardUnknown()

func (*CreateSubscriptionResponse) XXX_Marshal 

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

func (*CreateSubscriptionResponse) XXX_Merge 

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

func (*CreateSubscriptionResponse) XXX_Size 

func (m *CreateSubscriptionResponse) XXX_Size() int

func (*CreateSubscriptionResponse) XXX_Unmarshal 

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

type DeleteSubscriptionRequest 

type DeleteSubscriptionRequest struct {
	SessionID            string   `protobuf:"bytes,1,opt,name=SessionID,proto3" json:"SessionID,omitempty"`
	Peer                 uint64   `protobuf:"varint,2,opt,name=Peer,proto3" json:"Peer,omitempty"`
	Pattern              []byte   `protobuf:"bytes,3,opt,name=Pattern,proto3" json:"Pattern,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteSubscriptionRequest) Descriptor 

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

func (*DeleteSubscriptionRequest) GetPattern 

func (m *DeleteSubscriptionRequest) GetPattern() []byte

func (*DeleteSubscriptionRequest) GetPeer 

func (m *DeleteSubscriptionRequest) GetPeer() uint64

func (*DeleteSubscriptionRequest) GetSessionID 

func (m *DeleteSubscriptionRequest) GetSessionID() string

func (*DeleteSubscriptionRequest) ProtoMessage 

func (*DeleteSubscriptionRequest) ProtoMessage()

func (*DeleteSubscriptionRequest) Reset 

func (m *DeleteSubscriptionRequest) Reset()

func (*DeleteSubscriptionRequest) String 

func (m *DeleteSubscriptionRequest) String() string

func (*DeleteSubscriptionRequest) XXX_DiscardUnknown 

func (m *DeleteSubscriptionRequest) XXX_DiscardUnknown()

func (*DeleteSubscriptionRequest) XXX_Marshal 

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

func (*DeleteSubscriptionRequest) XXX_Merge 

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

func (*DeleteSubscriptionRequest) XXX_Size 

func (m *DeleteSubscriptionRequest) XXX_Size() int

func (*DeleteSubscriptionRequest) XXX_Unmarshal 

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

type DeleteSubscriptionResponse 

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

func (*DeleteSubscriptionResponse) Descriptor 

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

func (*DeleteSubscriptionResponse) ProtoMessage 

func (*DeleteSubscriptionResponse) ProtoMessage()

func (*DeleteSubscriptionResponse) Reset 

func (m *DeleteSubscriptionResponse) Reset()

func (*DeleteSubscriptionResponse) String 

func (m *DeleteSubscriptionResponse) String() string

func (*DeleteSubscriptionResponse) XXX_DiscardUnknown 

func (m *DeleteSubscriptionResponse) XXX_DiscardUnknown()

func (*DeleteSubscriptionResponse) XXX_Marshal 

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

func (*DeleteSubscriptionResponse) XXX_Merge 

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

func (*DeleteSubscriptionResponse) XXX_Size 

func (m *DeleteSubscriptionResponse) XXX_Size() int

func (*DeleteSubscriptionResponse) XXX_Unmarshal 

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

type DistributeMessageRequest 

type DistributeMessageRequest struct {
	Message                 *packet.Publish `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	ResolveRemoteRecipients bool            `protobuf:"varint,2,opt,name=ResolveRemoteRecipients,proto3" json:"ResolveRemoteRecipients,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}        `json:"-"`
	XXX_unrecognized        []byte          `json:"-"`
	XXX_sizecache           int32           `json:"-"`
}

func (*DistributeMessageRequest) Descriptor 

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

func (*DistributeMessageRequest) GetMessage 

func (m *DistributeMessageRequest) GetMessage() *packet.Publish

func (*DistributeMessageRequest) GetResolveRemoteRecipients 

func (m *DistributeMessageRequest) GetResolveRemoteRecipients() bool

func (*DistributeMessageRequest) ProtoMessage 

func (*DistributeMessageRequest) ProtoMessage()

func (*DistributeMessageRequest) Reset 

func (m *DistributeMessageRequest) Reset()

func (*DistributeMessageRequest) String 

func (m *DistributeMessageRequest) String() string

func (*DistributeMessageRequest) XXX_DiscardUnknown 

func (m *DistributeMessageRequest) XXX_DiscardUnknown()

func (*DistributeMessageRequest) XXX_Marshal 

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

func (*DistributeMessageRequest) XXX_Merge 

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

func (*DistributeMessageRequest) XXX_Size 

func (m *DistributeMessageRequest) XXX_Size() int

func (*DistributeMessageRequest) XXX_Unmarshal 

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

type DistributeMessageResponse 

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

func (*DistributeMessageResponse) Descriptor 

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

func (*DistributeMessageResponse) ProtoMessage 

func (*DistributeMessageResponse) ProtoMessage()

func (*DistributeMessageResponse) Reset 

func (m *DistributeMessageResponse) Reset()

func (*DistributeMessageResponse) String 

func (m *DistributeMessageResponse) String() string

func (*DistributeMessageResponse) XXX_DiscardUnknown 

func (m *DistributeMessageResponse) XXX_DiscardUnknown()

func (*DistributeMessageResponse) XXX_Marshal 

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

func (*DistributeMessageResponse) XXX_Merge 

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

func (*DistributeMessageResponse) XXX_Size 

func (m *DistributeMessageResponse) XXX_Size() int

func (*DistributeMessageResponse) XXX_Unmarshal 

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

type ListSessionMetadatasRequest 

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

func (*ListSessionMetadatasRequest) Descriptor 

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

func (*ListSessionMetadatasRequest) ProtoMessage 

func (*ListSessionMetadatasRequest) ProtoMessage()

func (*ListSessionMetadatasRequest) Reset 

func (m *ListSessionMetadatasRequest) Reset()

func (*ListSessionMetadatasRequest) String 

func (m *ListSessionMetadatasRequest) String() string

func (*ListSessionMetadatasRequest) XXX_DiscardUnknown 

func (m *ListSessionMetadatasRequest) XXX_DiscardUnknown()

func (*ListSessionMetadatasRequest) XXX_Marshal 

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

func (*ListSessionMetadatasRequest) XXX_Merge 

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

func (*ListSessionMetadatasRequest) XXX_Size 

func (m *ListSessionMetadatasRequest) XXX_Size() int

func (*ListSessionMetadatasRequest) XXX_Unmarshal 

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

type ListSessionMetadatasResponse 

type ListSessionMetadatasResponse struct {
	SessionMetadatasList []*SessionMetadatas `protobuf:"bytes,1,rep,name=SessionMetadatasList,proto3" json:"SessionMetadatasList,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ListSessionMetadatasResponse) Descriptor 

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

func (*ListSessionMetadatasResponse) GetSessionMetadatasList 

func (m *ListSessionMetadatasResponse) GetSessionMetadatasList() []*SessionMetadatas

func (*ListSessionMetadatasResponse) ProtoMessage 

func (*ListSessionMetadatasResponse) ProtoMessage()

func (*ListSessionMetadatasResponse) Reset 

func (m *ListSessionMetadatasResponse) Reset()

func (*ListSessionMetadatasResponse) String 

func (m *ListSessionMetadatasResponse) String() string

func (*ListSessionMetadatasResponse) XXX_DiscardUnknown 

func (m *ListSessionMetadatasResponse) XXX_DiscardUnknown()

func (*ListSessionMetadatasResponse) XXX_Marshal 

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

func (*ListSessionMetadatasResponse) XXX_Merge 

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

func (*ListSessionMetadatasResponse) XXX_Size 

func (m *ListSessionMetadatasResponse) XXX_Size() int

func (*ListSessionMetadatasResponse) XXX_Unmarshal 

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

type ListSubscriptionsRequest 

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

func (*ListSubscriptionsRequest) Descriptor 

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

func (*ListSubscriptionsRequest) ProtoMessage 

func (*ListSubscriptionsRequest) ProtoMessage()

func (*ListSubscriptionsRequest) Reset 

func (m *ListSubscriptionsRequest) Reset()

func (*ListSubscriptionsRequest) String 

func (m *ListSubscriptionsRequest) String() string

func (*ListSubscriptionsRequest) XXX_DiscardUnknown 

func (m *ListSubscriptionsRequest) XXX_DiscardUnknown()

func (*ListSubscriptionsRequest) XXX_Marshal 

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

func (*ListSubscriptionsRequest) XXX_Merge 

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

func (*ListSubscriptionsRequest) XXX_Size 

func (m *ListSubscriptionsRequest) XXX_Size() int

func (*ListSubscriptionsRequest) XXX_Unmarshal 

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

type ListSubscriptionsResponse 

type ListSubscriptionsResponse struct {
	Subscriptions        []*CreateSubscriptionRequest `protobuf:"bytes,1,rep,name=Subscriptions,proto3" json:"Subscriptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ListSubscriptionsResponse) Descriptor 

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

func (*ListSubscriptionsResponse) GetSubscriptions 

func (m *ListSubscriptionsResponse) GetSubscriptions() []*CreateSubscriptionRequest

func (*ListSubscriptionsResponse) ProtoMessage 

func (*ListSubscriptionsResponse) ProtoMessage()

func (*ListSubscriptionsResponse) Reset 

func (m *ListSubscriptionsResponse) Reset()

func (*ListSubscriptionsResponse) String 

func (m *ListSubscriptionsResponse) String() string

func (*ListSubscriptionsResponse) XXX_DiscardUnknown 

func (m *ListSubscriptionsResponse) XXX_DiscardUnknown()

func (*ListSubscriptionsResponse) XXX_Marshal 

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

func (*ListSubscriptionsResponse) XXX_Merge 

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

func (*ListSubscriptionsResponse) XXX_Size 

func (m *ListSubscriptionsResponse) XXX_Size() int

func (*ListSubscriptionsResponse) XXX_Unmarshal 

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

type MQTTClient 

type MQTTClient interface {
	ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*DeleteSubscriptionResponse, error)
	CreateSubscription(ctx context.Context, in *CreateSubscriptionRequest, opts ...grpc.CallOption) (*CreateSubscriptionResponse, error)
	DistributeMessage(ctx context.Context, in *DistributeMessageRequest, opts ...grpc.CallOption) (*DistributeMessageResponse, error)
	ListSessionMetadatas(ctx context.Context, in *ListSessionMetadatasRequest, opts ...grpc.CallOption) (*ListSessionMetadatasResponse, error)
}

MQTTClient is the client API for MQTT service.

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

func NewMQTTClient 

func NewMQTTClient(cc *grpc.ClientConn) MQTTClient

type MQTTServer 

type MQTTServer interface {
	ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
	DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*DeleteSubscriptionResponse, error)
	CreateSubscription(context.Context, *CreateSubscriptionRequest) (*CreateSubscriptionResponse, error)
	DistributeMessage(context.Context, *DistributeMessageRequest) (*DistributeMessageResponse, error)
	ListSessionMetadatas(context.Context, *ListSessionMetadatasRequest) (*ListSessionMetadatasResponse, error)
}

MQTTServer is the server API for MQTT service.

type SessionMetadatas 

type SessionMetadatas struct {
	SessionID            string          `protobuf:"bytes,1,opt,name=SessionID,proto3" json:"SessionID,omitempty"`
	ClientID             string          `protobuf:"bytes,2,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	ConnectedAt          int64           `protobuf:"varint,3,opt,name=ConnectedAt,proto3" json:"ConnectedAt,omitempty"`
	Peer                 uint64          `protobuf:"varint,4,opt,name=Peer,proto3" json:"Peer,omitempty"`
	LWT                  *packet.Publish `protobuf:"bytes,5,opt,name=LWT,proto3" json:"LWT,omitempty"`
	MountPoint           string          `protobuf:"bytes,6,opt,name=MountPoint,proto3" json:"MountPoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*SessionMetadatas) Descriptor 

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

func (*SessionMetadatas) GetClientID 

func (m *SessionMetadatas) GetClientID() string

func (*SessionMetadatas) GetConnectedAt 

func (m *SessionMetadatas) GetConnectedAt() int64

func (*SessionMetadatas) GetLWT 

func (m *SessionMetadatas) GetLWT() *packet.Publish

func (*SessionMetadatas) GetMountPoint 

func (m *SessionMetadatas) GetMountPoint() string

func (*SessionMetadatas) GetPeer 

func (m *SessionMetadatas) GetPeer() uint64

func (*SessionMetadatas) GetSessionID 

func (m *SessionMetadatas) GetSessionID() string

func (*SessionMetadatas) ProtoMessage 

func (*SessionMetadatas) ProtoMessage()

func (*SessionMetadatas) Reset 

func (m *SessionMetadatas) Reset()

func (*SessionMetadatas) String 

func (m *SessionMetadatas) String() string

func (*SessionMetadatas) XXX_DiscardUnknown 

func (m *SessionMetadatas) XXX_DiscardUnknown()

func (*SessionMetadatas) XXX_Marshal 

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

func (*SessionMetadatas) XXX_Merge 

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

func (*SessionMetadatas) XXX_Size 

func (m *SessionMetadatas) XXX_Size() int

func (*SessionMetadatas) XXX_Unmarshal 

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

type UnimplementedMQTTServer 

type UnimplementedMQTTServer struct {
}

UnimplementedMQTTServer can be embedded to have forward compatible implementations.

func (*UnimplementedMQTTServer) CreateSubscription 

func (*UnimplementedMQTTServer) CreateSubscription(ctx context.Context, req *CreateSubscriptionRequest) (*CreateSubscriptionResponse, error)

func (*UnimplementedMQTTServer) DeleteSubscription 

func (*UnimplementedMQTTServer) DeleteSubscription(ctx context.Context, req *DeleteSubscriptionRequest) (*DeleteSubscriptionResponse, error)

func (*UnimplementedMQTTServer) DistributeMessage 

func (*UnimplementedMQTTServer) DistributeMessage(ctx context.Context, req *DistributeMessageRequest) (*DistributeMessageResponse, error)

func (*UnimplementedMQTTServer) ListSessionMetadatas 

func (*UnimplementedMQTTServer) ListSessionMetadatas(ctx context.Context, req *ListSessionMetadatasRequest) (*ListSessionMetadatasResponse, error)

func (*UnimplementedMQTTServer) ListSubscriptions 

func (*UnimplementedMQTTServer) ListSubscriptions(ctx context.Context, req *ListSubscriptionsRequest) (*ListSubscriptionsResponse, 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.