notification

Documentation

Index

• func LoadConfiguration(config *viper.Viper)
• type MessageQueue

Functions

func LoadConfiguration

func LoadConfiguration(config *viper.Viper)

Types

type MessageQueue

type MessageQueue interface {
	// GetName gets the name to locate the configuration in filer.toml file
	GetName() string
	// Initialize initializes the file store
	Initialize(configuration util.Configuration) error
	SendMessage(key string, message proto.Message) error
}

var (
	MessageQueues []MessageQueue

	Queue MessageQueue
)