message

package

v0.5.0-beta2.6 Latest Latest Go to latest Published: Oct 13, 2019 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Acker interface {
	Ack(ctx context.Context)
}

type Handler interface {
	HandleMessage(ctx context.Context, topic string, msg Message) error
	Name() string
}

type InputMessage struct {
	Topic string
	Message
	Acker Acker
}

func (msg InputMessage) Ack(ctx context.Context)

type Message struct {
	UID       string
	Partition int64
	PayLoad   []byte
	Head      map[string]string
}

type Middle interface {
	Warp(handler Handler) Handler
}

type OutputMessage struct {
	OffsetToken string
	Topic       string
	Message
}

type RetryMiddle struct {
	CheckRetry    func(err error) bool
	MaxRetryCount int
}

func (middle RetryMiddle) Warp(handler Handler) Handler

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

func NewRouter(option RouterOption, subs ...Subscriber) (*Router, error)

func (router *Router) AddHandler(topic string, handler Handler) error

func (router *Router) Start(ctx context.Context) error

type RouterOption struct {
	Middles []Middle
}

type Subscriber interface {
	Topic() string
	Read(ctx context.Context) (InputMessage, error)
	Close() error
}

type TimeOutMiddle struct {
	TimeOut time.Duration
}

func (middle TimeOutMiddle) Warp(handler Handler) Handler

Path	Synopsis
kafka