Versions in this module Expand all Collapse all v1 v1.11.0 Dec 20, 2021 Changes in this version + func SetLogger(loggerP *logrus.Logger) v1.10.3 Aug 10, 2021 v1.10.2 Jul 21, 2021 Changes in this version + const MSG_QUEUE_MAX_LEN + func ReaderThread_Kafka(mbusP *MsgBusReader_Kafka) + type BlockingMode int + const Blocking + const NonBlocking + type BusDir int + const BusReader + const BusWriter + type BusStatus int + const StatusClosed + const StatusOpen + type CBFunc func(msg string) + type CallbackToken int + type MsgBusConfig struct + Blocking BlockingMode + BusTech MsgBusTech + ConnectRetries int + Direction BusDir + GroupId string + Host string + Port int + Topic string + type MsgBusIO interface + Disconnect func() error + MessageAvailable func() int + MessageRead func() (string, error) + MessageWrite func(msg string) error + RegisterCB func(cbfunc CBFunc) error + Status func() int + UnregisterCB func() error + func Connect(cfg MsgBusConfig) (MsgBusIO, error) + type MsgBusReader_Kafka struct + func ConnectReader_Kafka(cfg MsgBusConfig) (*MsgBusReader_Kafka, error) + func (mbus *MsgBusReader_Kafka) Disconnect() error + func (mbus *MsgBusReader_Kafka) MessageAvailable() int + func (mbus *MsgBusReader_Kafka) MessageRead() (string, error) + func (mbus *MsgBusReader_Kafka) MessageWrite(msg string) error + func (mbus *MsgBusReader_Kafka) RegisterCB(cbfunc CBFunc) error + func (mbus *MsgBusReader_Kafka) Status() int + func (mbus *MsgBusReader_Kafka) UnregisterCB() error + type MsgBusTech int + const BusTechKafka + type MsgBusWriter_Kafka struct + func ConnectWriter_Kafka(cfg MsgBusConfig) (*MsgBusWriter_Kafka, error) + func (mbus *MsgBusWriter_Kafka) Disconnect() error + func (mbus *MsgBusWriter_Kafka) MessageAvailable() int + func (mbus *MsgBusWriter_Kafka) MessageRead() (string, error) + func (mbus *MsgBusWriter_Kafka) MessageWrite(msg string) error + func (mbus *MsgBusWriter_Kafka) RegisterCB(cbfunc CBFunc) error + func (mbus *MsgBusWriter_Kafka) Status() int + func (mbus *MsgBusWriter_Kafka) UnregisterCB() error + type SubscriptionToken int