msgqueue

Documentation

Index

• Constants
• Variables
• type Mode
• type MsgSender
  • func NewProducer() MsgSender

Constants

const (
	PubTopic      = "coinex-dex"
	FeatureToggle = "feature-toggle"
)

const (
	KafkaMode = "kafka:"
	StdMode   = "os:"
)

Variables

var (
	EventTypeMsgQueue = "kafka"
)

Types

type Mode

type Mode int

type MsgSender

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

func NewProducer

func NewProducer() MsgSender