event

package

v0.15.4 Latest Latest Go to latest Published: Dec 26, 2025 License: Apache-2.0 Imports: 5 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cloudwego/kitex

Links

Documentation ¶

Index ¶

Constants
type Bus
- func NewEventBus() Bus
type Callback
type Event
type Queue
- func NewQueue(cap int) Queue

Constants ¶

View Source

const (
	// MaxEventNum is the default size of a event queue.
	MaxEventNum = 200
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Bus ¶

type Bus interface {
	Watch(event string, callback Callback)
	Unwatch(event string, callback Callback)
	Dispatch(event *Event)
	DispatchAndWait(event *Event)
}

Bus implements the observer pattern to allow event dispatching and watching.

func NewEventBus ¶

func NewEventBus() Bus

NewEventBus creates a Bus.

type Callback ¶

type Callback func(*Event)

Callback is called when the subscribed event happens.

type Event ¶

type Event struct {
	Name   string
	Time   time.Time
	Detail string
	Extra  interface{}
}

Event represents an event.

type Queue ¶

type Queue interface {
	Push(e *Event)
	Dump() interface{}
}

Queue is a ring to collect events.

func NewQueue ¶

func NewQueue(cap int) Queue

NewQueue creates a queue with the given capacity.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL