bus

Documentation

Index

• func WithContext(ctx context.Context, bus Plugin) context.Context
• type BusData
  • func (e *BusData) LoadData(out interface{}) error
  • func (e *BusData) SetData(data interface{}) error
• type CallBackFunc
• type Plugin
  • func FromContext(ctx context.Context) (Plugin, error)

Functions

func WithContext

func WithContext(ctx context.Context, bus Plugin) context.Context

Types

type BusData

type BusData struct {
	Topic string `json:"topic" yaml:"topic"`
	Data  []byte `json:"data" yaml:"data"`
}

BusData struct

func (*BusData) LoadData

func (e *BusData) LoadData(out interface{}) error

LoadData converts data to target interface

func (*BusData) SetData

func (e *BusData) SetData(data interface{}) error

SetData updates data in []byte format

type CallBackFunc

type CallBackFunc func(data *BusData)

CallBackFunc message passed to this func

type Plugin

type Plugin interface {
	Name() string
	Close() error
	Publish(topic string, data interface{}) error
	Subscribe(topic string, handler CallBackFunc) (int64, error)
	Unsubscribe(topic string, subscriptionID int64) error
	QueueSubscribe(topic, queueName string, handler CallBackFunc) (int64, error)
	QueueUnsubscribe(topic, queueName string, subscriptionID int64) error
	UnsubscribeAll(topic string) error
	PausePublish()
	ResumePublish()
	TopicPrefix() string
}

Plugin interface

func FromContext

func FromContext(ctx context.Context) (Plugin, error)