types

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 4, 2020 License: Apache-2.0 Imports: 0 Imported by: 2

Documentation

Index

Constants

View Source
const (
	MSG_BUS_SENDER_UNKNOWN = iota
	MSG_BUS_SENDER_KAFKA
)
View Source
const (
	MSG_BUS_REQUEST_TIMEOUT  = "request.timeout.ms"
	MSG_BUS_MESSAGE_TIMEOUT  = "message.timeout.ms"
	MSG_BUS_SEND_MAX_RETRIES = "send.max.retries"
)
View Source
const (
	KAFKA_CFG_BROKER_LIST       = "broker_list"
	KAFKA_CFG_AUTO_OFFSET_STORE = "auto_offset_store"
	KAFKA_CFG_MSG_TOPIC         = "topic"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Message

type Message struct {
	Topic   string
	Key     string
	ErrChan chan error
	Value   []byte
}

func NewMsg

func NewMsg(topic, key string, val []byte) *Message

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL