c8ysubscribe

Documentation

Index

• func Subscribe(client *c8y.Client, log *logger.Logger, channelPattern string, opts Options) (err error)
• func SubscribeMultiple(client *c8y.Client, log *logger.Logger, channelPatterns []string, opts Options) (err error)
• type Options

Functions

func Subscribe

func Subscribe(client *c8y.Client, log *logger.Logger, channelPattern string, opts Options) (err error)

Subscribe subscribe to a single channel

func SubscribeMultiple

func SubscribeMultiple(client *c8y.Client, log *logger.Logger, channelPatterns []string, opts Options) (err error)

SubscribeMultiple subscribe to multiple channels

Types

type Options

type Options struct {
	// Timeout duration
	Timeout time.Duration

	// MaxMessages maximum messages
	MaxMessages int64

	// ActionTypes filter by action types
	ActionTypes []string

	// OnMessage on message callback
	OnMessage func(msg string) error
}

Options subscription options