eventhub

Documentation

Index

• Constants
• func InitEventHub()
• func Publish(topic string, event Event)
• func Shutdown()
• func Subscribe(topic string, name string, handler Handler, opts ...SubOption) error
• func TestInitEventHub()
• func TestShutdownEventHub()
• func Unsubscribe(topic string, name string)
• type Event
• type Handler
• type SubOption
  • func WithQueueSize(size int) SubOption
• type SubOptions

Constants

const (
	// InstanceEventTopic 服务发现事件主题
	InstanceEventTopic = "instance_event"
	// LeaderChangeEventTopic
	LeaderChangeEventTopic = "leader_change_event"
)

事件主题

Functions

func InitEventHub

func InitEventHub()

InitEventHub initialize event hub

func Publish

func Publish(topic string, event Event)

Publish pushlish event to topic @param topic Topic name @param event Event object

func Shutdown

func Shutdown()

Shutdown shutdown event hub

func Subscribe

func Subscribe(topic string, name string, handler Handler, opts ...SubOption) error

Subscribe subscribe topic @param topic Topic name @param name Subscribe name @param handler Message handler @param opts Subscription options @return error Subscribe failed, return error

func TestInitEventHub

func TestInitEventHub()

func TestShutdownEventHub

func TestShutdownEventHub()

func Unsubscribe

func Unsubscribe(topic string, name string)

Unsubscribe unsubscribe topic @param topic Topic name @param name Subscribe name

Types

type Event

type Event interface{}

Event evnt type

type Handler

type Handler interface {
	// PreProcess do preprocess logic for event
	PreProcess(context.Context, any) any
	// OnEvent event process logic
	OnEvent(ctx context.Context, any2 any) error
}

Handler event handler

type SubOption

type SubOption func(s *SubOptions)

SubOption subscription option func

func WithQueueSize

func WithQueueSize(size int) SubOption

WithQueueSize set event queue size

type SubOptions

type SubOptions struct {
	QueueSize int
}

SubOptions subscripion options