eventbus

package
v0.0.51 Latest Latest
Warning

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

Go to latest
Published: Mar 25, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Bus

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

func New

func New() *Bus

func (*Bus) Publish

func (b *Bus) Publish(event *taskguildv1.Event)

func (*Bus) PublishNew

func (b *Bus) PublishNew(eventType taskguildv1.EventType, resourceID string, payload string, metadata map[string]string)

func (*Bus) Subscribe

func (b *Bus) Subscribe(bufSize int) (string, <-chan *taskguildv1.Event)

func (*Bus) Unsubscribe

func (b *Bus) Unsubscribe(id string)

Jump to

Keyboard shortcuts

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