vltypes

Documentation

Index

• Variables
• func NormalizeConfig(cfg interface{}) (map[string]interface{}, error)
• type RetainObject
• type TopicMessenger

Variables

var (
	ErrInvalidConfigType = errors.New("vltypes: invalid type of config object")
)

Functions

func NormalizeConfig

func NormalizeConfig(cfg interface{}) (map[string]interface{}, error)

NormalizeConfig make sure config object meets basic requirement to be as map[string]interface{}

Types

type RetainObject

type RetainObject interface {
	Topic() string
}

RetainObject general interface of the retain as not only publish message can be retained

type TopicMessenger

type TopicMessenger interface {
	Publish(interface{}) error
	Retain(RetainObject) error
}

TopicMessenger interface for session or systree used to publish or retain messages