rpc

Documentation

Index

• type MessageHandler
  • func NewMessageHandler(sendCh chan<- interface{}, sto store.Store, pubSub *PubSub, ...) (*MessageHandler, error)
  • func (c *MessageHandler) Close()
  • func (c *MessageHandler) HandleRawMessage(data []byte) error
• type PubSub
  • func NewPubSub() *PubSub
  • func (cm *PubSub) Len(id string) int
  • func (cm *PubSub) Publish(id string, msg interface{}) int
  • func (cm *PubSub) Subscribe(id string, subscriber Subscriber)
  • func (cm *PubSub) Unsubscribe(id string, subscriber Subscriber)
  • func (cm *PubSub) UnsubscribeAll(subscriber Subscriber) int
• type Subscriber

Types

type MessageHandler

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

MessageHandler - handles RPC messages

func NewMessageHandler

func NewMessageHandler(
	sendCh chan<- interface{},
	sto store.Store,
	pubSub *PubSub,
	webhook webhook.Caller,
) (*MessageHandler, error)

NewMessageHandler - construct a MessageHandler

func (*MessageHandler) Close

func (c *MessageHandler) Close()

Close - clean up

func (*MessageHandler) HandleRawMessage

func (c *MessageHandler) HandleRawMessage(data []byte) error

HandleRawMessage - handle a raw client message

type PubSub

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

PubSub - pub/sub interface for message senders

func NewPubSub

func NewPubSub() *PubSub

NewPubSub - construct a PubSub

func (*PubSub) Len

func (cm *PubSub) Len(id string) int

Len - returns the number of subscribers for a given id

func (*PubSub) Publish

func (cm *PubSub) Publish(id string, msg interface{}) int

Publish - publishes a message to all subscribers of an id and returns the number of subscribers messaged

func (*PubSub) Subscribe

func (cm *PubSub) Subscribe(id string, subscriber Subscriber)

Subscribe - subscribes a Subscriber to an id

func (*PubSub) Unsubscribe

func (cm *PubSub) Unsubscribe(id string, subscriber Subscriber)

Unsubscribe - unsubscribes a Subscriber from an id

func (*PubSub) UnsubscribeAll

func (cm *PubSub) UnsubscribeAll(subscriber Subscriber) int

UnsubscribeAll - unsubscribes subscriber from every id and returns the number of unsubscriptions done

type Subscriber

type Subscriber chan<- interface{}

Subscriber - channel that takes in any type