sdk

Documentation

Index

• type Config
• type Message
• type PManager
  • func NewPManager(ctx context.Context) (*PManager, error)
  • func (pm *PManager) Subscribe() (*Subscription, error)
  • func (pm *PManager) WriteMessage(msgData []byte)
• type Subscription
  • func (s *Subscription) Cancel()
  • func (s *Subscription) ReadMessage(ctx context.Context) (*Message, error)

Types

type Config

type Config struct {
	Path string `mapstructure:"PM_ADDR"`
}

type Message

type Message struct {
	// ReceivedFrom string
	Data []byte
}

type PManager

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

func NewPManager

func NewPManager(ctx context.Context) (*PManager, error)

func (*PManager) Subscribe

func (pm *PManager) Subscribe() (*Subscription, error)

func (*PManager) WriteMessage

func (pm *PManager) WriteMessage(msgData []byte)

type Subscription

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

func (*Subscription) Cancel

func (s *Subscription) Cancel()

func (*Subscription) ReadMessage

func (s *Subscription) ReadMessage(ctx context.Context) (*Message, error)