transport

Jan 12, 2023

Changes in this version

+ const HeaderFrom

+ var DefaultMessageTTL = 10

+ var DefaultNumPartitions = 3

+ var DefaultReplicationFactor = 1

+ func New(conf *config.TransportConfig) (t types.Transport, err error)

+ type KafkaTransport struct

+ func NewKafkaTransport(cfg *config.TransportConfig) (*KafkaTransport, error)

+ func (t *KafkaTransport) CloseReceive() error

+ func (t *KafkaTransport) CloseSend() error

+ func (t *KafkaTransport) OnReceive(omr types.OnMessageReceived)

+ func (t *KafkaTransport) Send(from, to string, msg []byte) error

+ func (t *KafkaTransport) Start() error