transport

Documentation

Index

• Constants
• Variables
• func New(conf *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

Constants

const HeaderFrom = "From"

Variables

var (
	// DefaultMessageTTL and other options, can be modified accordingly
	DefaultMessageTTL        = 10 // message TTL default to 10 seconds
	DefaultNumPartitions     = 3  // topic partitions default to 3
	DefaultReplicationFactor = 1  // topic replication factor default to 1
)

Functions

func New

func New(conf *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