kafka

Documentation

Index

• Constants
• type Config
• type GlobalNotifieKafka
  • func (m *GlobalNotifieKafka) Close() error
  • func (m *GlobalNotifieKafka) GetConfig() interface{}
  • func (m *GlobalNotifieKafka) GetGroup() core.ModuleGroup
  • func (m *GlobalNotifieKafka) GetName() string
  • func (m *GlobalNotifieKafka) GetType() core.ModuleType
  • func (m *GlobalNotifieKafka) InitModule(_cfg interface{}) error
  • func (m *GlobalNotifieKafka) InitPipe(w io.Writer, r io.Reader) error
  • func (m *GlobalNotifieKafka) Run(ctx context.Context) error

Constants

const (
	GROUP_NAME  = "global"
	TYPE_NAME   = "notifier"
	MODULE_NAME = "kafka"
)

Types

type Config

type Config struct {
	MaxRetry   int
	BrokerList []string
	Topic      string
	Message    string
}

type GlobalNotifieKafka

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

GlobalNotifieKafka represends ...

func (*GlobalNotifieKafka) Close

func (m *GlobalNotifieKafka) Close() error

Close closes compressor

func (*GlobalNotifieKafka) GetConfig

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

GetConfig returns module config

func (*GlobalNotifieKafka) GetGroup

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

GetGroup returns group of the module

func (*GlobalNotifieKafka) GetName

func (m *GlobalNotifieKafka) GetName() string

GetName returns name of the module

func (*GlobalNotifieKafka) GetType

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

GetType returns group of the module

func (*GlobalNotifieKafka) InitModule

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

InitModule initializes module

func (*GlobalNotifieKafka) InitPipe

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

InitPipe initializes pipe

func (*GlobalNotifieKafka) Run

func (m *GlobalNotifieKafka) Run(ctx context.Context) error

Run runs module