eventbus

package

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

Details

This section is empty.

This section is empty.

This section is empty.

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

func New() *Bus

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

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

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

func (b *Bus) Unsubscribe(id string)