eventhub

Documentation

Index

• Constants
• Variables
• func InitEventHub()
• func Publish(topic string, event Event) error
• func RegisterPublisher(topic string, opt PublishOption) error
• func Shutdown()
• type CacheClientEvent
• type CacheInstanceEvent
• type CacheNamespaceEvent
• type Event
• type EventType
• type Handler
• type HandlerFunc
• type PublishConfigFileEvent
• type PublishOption
• type SubOption
  • func WithQueueSize(size int) SubOption
• type SubOptions
• type SubscribtionContext
  • func Subscribe(topic string, handler Handler, opts ...SubOption) (*SubscribtionContext, error)
  • func SubscribeWithFunc(topic string, handler HandlerFunc, opts ...SubOption) (*SubscribtionContext, error)
  • func (s *SubscribtionContext) Cancel()

Constants

const (
	// InstanceEventTopic discover event
	InstanceEventTopic = "instance_event"
	// LeaderChangeEventTopic leader change
	LeaderChangeEventTopic = "leader_change_event"
	// ConfigFilePublishTopic config file release publish
	ConfigFilePublishTopic = "configfile_publish"
	// CacheInstanceEventTopic record cache occur instance add/update/del event
	CacheInstanceEventTopic = "cache_instance_event"
	// CacheClientEventTopic record cache occur client add/update/del event
	CacheClientEventTopic = "cache_client_event"
	// CacheNamespaceEventTopic record cache occur namespace add/update/del event
	CacheNamespaceEventTopic = "cache_namespace_event"
	// ClientEventTopic .
	ClientEventTopic = "client_event"
)

事件主题

Variables

var (
	ErrorEventhubNotInitialize = errors.New("eventhub not initialize")
)

Functions

func InitEventHub

func InitEventHub()

InitEventHub initialize event hub

func Publish

func Publish(topic string, event Event) error

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

func RegisterPublisher

func RegisterPublisher(topic string, opt PublishOption) error

func Shutdown

func Shutdown()

Shutdown shutdown event hub

Types

type CacheClientEvent

type CacheClientEvent struct {
	Client    *model.Client
	EventType EventType
}

type CacheInstanceEvent

type CacheInstanceEvent struct {
	Instance  *model.Instance
	EventType EventType
}

type CacheNamespaceEvent

type CacheNamespaceEvent struct {
	OldItem   *model.Namespace
	Item      *model.Namespace
	EventType EventType
}

type Event

type Event interface{}

Event evnt type

type EventType

type EventType int

EventType common event type

const (
	// EventCreated value create event
	EventCreated EventType = iota
	// EventUpdated value update event
	EventUpdated
	// EventDeleted value delete event
	EventDeleted
)

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 HandlerFunc

type HandlerFunc func(ctx context.Context, any2 any) error

type PublishConfigFileEvent

type PublishConfigFileEvent struct {
	Message *model.SimpleConfigFileRelease
}

PublishConfigFileEvent 事件对象，包含类型和事件消息

type PublishOption

type PublishOption struct {
	WaitHaveSub bool
}

PublishOption .

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

type SubscribtionContext

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

func Subscribe

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

Subscribe subscribe topic

func SubscribeWithFunc

func SubscribeWithFunc(topic string, handler HandlerFunc, opts ...SubOption) (*SubscribtionContext, error)

SubscribeWithFunc subscribe topic use func

func (*SubscribtionContext) Cancel

func (s *SubscribtionContext) Cancel()