events

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 12, 2025 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Broker 

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

Broker manages event subscriptions and distribution

func NewBroker 

func NewBroker() *Broker

NewBroker creates a new event broker

func (*Broker) Publish 

func (b *Broker) Publish(event *Event)

Publish publishes an event to all subscribers

func (*Broker) Start 

func (b *Broker) Start()

Start begins the broker's event distribution loop

func (*Broker) Stop 

func (b *Broker) Stop()

Stop stops the broker

func (*Broker) Subscribe 

func (b *Broker) Subscribe() Subscriber

Subscribe creates a new subscription and returns a channel

func (*Broker) SubscriberCount 

func (b *Broker) SubscriberCount() int

SubscriberCount returns the number of active subscribers

func (*Broker) Unsubscribe 

func (b *Broker) Unsubscribe(sub Subscriber)

Unsubscribe removes a subscription

type Event 

type Event struct {
	ID        string
	Type      EventType
	Timestamp time.Time
	Message   string
	Metadata  map[string]string
}

Event represents a cluster event

type EventType 

type EventType string

EventType represents the type of event 

const (
	EventServiceCreated EventType = "service.created"
	EventServiceUpdated EventType = "service.updated"
	EventServiceDeleted EventType = "service.deleted"
	EventTaskCreated    EventType = "task.created"
	EventTaskFailed     EventType = "task.failed"
	EventTaskCompleted  EventType = "task.completed"
	EventNodeJoined     EventType = "node.joined"
	EventNodeLeft       EventType = "node.left"
	EventNodeDown       EventType = "node.down"
	EventSecretCreated  EventType = "secret.created"
	EventSecretDeleted  EventType = "secret.deleted"
	EventVolumeCreated  EventType = "volume.created"
	EventVolumeDeleted  EventType = "volume.deleted"
)

type Subscriber 

type Subscriber chan *Event

Subscriber is a channel that receives events

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.