rpc

May 29, 2019

Changes in this version

type MessagePublished

+ Tenant string

+ func (m *MessagePublished) GetTenant() string

Apr 15, 2019

Changes in this version

+ type JobWrap struct

Apr 15, 2019

Changes in this version

+ var ErrPoolNotFound = errors.New("pool not found")

+ func Call(addr string, f func(BrokerServiceClient) error) error

type BrokerServiceClient

+ DistributeMessage func(ctx context.Context, in *MessagePublished, opts ...grpc.CallOption) (*MessagePublishedOutput, error)

type BrokerServiceServer

+ DistributeMessage func(context.Context, *MessagePublished) (*MessagePublishedOutput, error)

+ type Caller struct

+ func NewCaller() *Caller

+ func (c *Caller) Call(addr string, job RPCJob) error

+ func (c *Caller) Cancel(addr string) error

+ type MessagePublished struct

+ Dup bool

+ Payload []byte

+ Qos []int32

+ Recipient []string

+ Retained bool

+ Topic []byte

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

+ func (*MessagePublished) ProtoMessage()

+ func (m *MessagePublished) GetDup() bool

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

+ func (m *MessagePublished) GetQos() []int32

+ func (m *MessagePublished) GetRecipient() []string

+ func (m *MessagePublished) GetRetained() bool

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

+ func (m *MessagePublished) Reset()

+ func (m *MessagePublished) String() string

+ type MessagePublishedOutput struct

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

+ func (*MessagePublishedOutput) ProtoMessage()

+ func (m *MessagePublishedOutput) Reset()

+ func (m *MessagePublishedOutput) String() string

+ type Pool struct

+ func NewPool(addr string) (*Pool, error)

+ func (a *Pool) Call(job RPCJob) error

+ func (a *Pool) Cancel()

+ type RPCJob func(BrokerServiceClient) error

Feb 8, 2019

Changes in this version

type BrokerServiceClient

+ CloseSession func(ctx context.Context, in *CloseSessionInput, opts ...grpc.CallOption) (*CloseSessionOutput, error)

type BrokerServiceServer

+ CloseSession func(context.Context, *CloseSessionInput) (*CloseSessionOutput, error)

+ type CloseSessionInput struct

+ ID string

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

+ func (*CloseSessionInput) ProtoMessage()

+ func (m *CloseSessionInput) GetID() string

+ func (m *CloseSessionInput) Reset()

+ func (m *CloseSessionInput) String() string

+ type CloseSessionOutput struct

+ ID string

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

+ func (*CloseSessionOutput) ProtoMessage()

+ func (m *CloseSessionOutput) GetID() string

+ func (m *CloseSessionOutput) Reset()

+ func (m *CloseSessionOutput) String() string

Nov 4, 2018

Changes in this version

+ func New(port int, handler broker) io.Closer

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

+ type BrokerServiceClient interface

+ ListSessions func(ctx context.Context, in *SessionFilter, opts ...grpc.CallOption) (*ListSessionsOutput, error)

+ func NewBrokerServiceClient(cc *grpc.ClientConn) BrokerServiceClient

+ type BrokerServiceServer interface

+ ListSessions func(context.Context, *SessionFilter) (*ListSessionsOutput, error)

+ type ListSessionsOutput struct

+ Sessions []*sessions.Session

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

+ func (*ListSessionsOutput) ProtoMessage()

+ func (m *ListSessionsOutput) GetSessions() []*sessions.Session

+ func (m *ListSessionsOutput) Reset()

+ func (m *ListSessionsOutput) String() string

+ type SessionFilter struct

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

+ func (*SessionFilter) ProtoMessage()

+ func (m *SessionFilter) Reset()

+ func (m *SessionFilter) String() string