types

Documentation

Overview

Package types provides the types of the broker.

Index

• Constants
• type HandleMessage

Constants

const (
	// DefaultTopic if no topic set, use the default topic
	DefaultTopic = "default"
	// DefaultGroup if no group set, use the default group
	DefaultGroup = "default_group"

	// TokenTopic  the timeSlice token topic
	TokenTopic = "token"
	// TokenGroup the timeSlice token consumer group
	TokenGroup = "token_group"
)

Types

type HandleMessage

type HandleMessage func(ctx context.Context, msg *types.Message) error

HandleMessage is a function that handles a message.