nats

package
v0.0.0-...-b2d74e5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 20, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	GROUP_NAME  = "global"
	TYPE_NAME   = "notifier"
	MODULE_NAME = "nats"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	NATSURL string
	Msg     string
	Topic   string
}

type GlobalNotifierNats

type GlobalNotifierNats struct {
	core.Module
	// contains filtered or unexported fields
}

func (*GlobalNotifierNats) Close

func (m *GlobalNotifierNats) Close() error

Close closes compressor

func (*GlobalNotifierNats) GetConfig

func (m *GlobalNotifierNats) GetConfig() interface{}

func (*GlobalNotifierNats) GetGroup

func (m *GlobalNotifierNats) GetGroup() core.ModuleGroup

func (*GlobalNotifierNats) GetName

func (m *GlobalNotifierNats) GetName() string

func (*GlobalNotifierNats) GetType

func (m *GlobalNotifierNats) GetType() core.ModuleType

func (*GlobalNotifierNats) InitModule

func (m *GlobalNotifierNats) InitModule(_cfg interface{}) error

func (*GlobalNotifierNats) InitPipe

func (m *GlobalNotifierNats) InitPipe(w io.Writer, r io.Reader) error

func (*GlobalNotifierNats) Run

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL