msgqueue

Documentation

Index

• Constants
• Variables
• type MsgSender
  • func NewProducer() MsgSender
  • func NewProducerFromConfig(brokers, topics string, featureToggle bool) MsgSender
• type MsgWriter
  • func NewFileMsgWriter(filePath string) (MsgWriter, error)
  • func NewKafkaMsgWriter(brokers string) MsgWriter
  • func NewNopMsgWriter() MsgWriter
  • func NewStdOutMsgWriter() MsgWriter

Constants

const (
	FlagBrokers       = "brokers"
	FlagTopics        = "subscribe-modules"
	FlagFeatureToggle = "feature-toggle"
	KafkaPubTopic     = "coinex-dex"
)

const (
	CfgPrefixFile  = "file:"
	CfgPrefixKafka = "kafka:"
	CfgPrefixOS    = "os:"
)

Variables

var (
	EventTypeMsgQueue = "kafka"
)

Types

type MsgSender

type MsgSender interface {
	SendMsg(key []byte, v []byte)
	IsSubscribed(topic string) bool
	IsOpenToggle() bool
	GetMode() string
	Close()
}

func NewProducer

func NewProducer() MsgSender

func NewProducerFromConfig

func NewProducerFromConfig(brokers, topics string, featureToggle bool) MsgSender

type MsgWriter

type MsgWriter interface {
	WriteKV(k, v []byte) error
	Close() error
	String() string
}

func NewFileMsgWriter

func NewFileMsgWriter(filePath string) (MsgWriter, error)

func NewKafkaMsgWriter

func NewKafkaMsgWriter(brokers string) MsgWriter

func NewNopMsgWriter

func NewNopMsgWriter() MsgWriter

func NewStdOutMsgWriter

func NewStdOutMsgWriter() MsgWriter