pubsub

Documentation

Index

• type PubsubService
  • func (ps *PubsubService) Init() error
  • func (ps *PubsubService) ProcessCmd(buf []byte, msgID string, requestorID string, requestorCh chan interface{})

Types

type PubsubService

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

func (*PubsubService) Init

func (ps *PubsubService) Init() error

func (*PubsubService) ProcessCmd

func (ps *PubsubService) ProcessCmd(buf []byte, msgID string, requestorID string, requestorCh chan interface{})