subscriber

Documentation

Index

• type ConsumeFunc
• type Subscriber

Types

type ConsumeFunc

type ConsumeFunc func(ctx context.Context, message event.EventString) error

type Subscriber

type Subscriber interface {
	// Start the subscriber
	Start()
	// Close all underlying connections and resources
	Close() error
	// GroupID that is used
	GroupID() string
	// Topic that it is subscribed
	Topic() string
}

Subscriber is the interface to manage ONE topic