transport

Documentation

Index

• Variables
• func New(cfg *config.TransportConfig) (t types.Transport, err error)
• type KafkaTransport
  • 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

Variables

var (
	DefaultMessageTTL = 10 // 10 seconds
	HeaderFrom        = "From"
)

Functions

func New

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

Types

type KafkaTransport

type KafkaTransport struct {
	// contains filtered or unexported fields
}

func NewKafkaTransport

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

func (*KafkaTransport) CloseReceive

func (t *KafkaTransport) CloseReceive() error

func (*KafkaTransport) CloseSend

func (t *KafkaTransport) CloseSend() error

func (*KafkaTransport) OnReceive

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

func (*KafkaTransport) Send

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

func (*KafkaTransport) Start

func (t *KafkaTransport) Start() error