eventbus

type ActorRef ¶

type ActorRef struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

ActorRef identifies the actor who caused the event.

type BoardRef ¶

type BoardRef struct {
	Slug string `json:"slug"`
	Name string `json:"name"`
}

BoardRef identifies the board the event belongs to.

type Event ¶

type Event struct {
	Type      string        `json:"event"`
	Timestamp time.Time     `json:"timestamp"`
	Actor     ActorRef      `json:"actor"`
	Board     BoardRef      `json:"board"`
	Before    *TaskSnapshot `json:"before,omitempty"`
	After     *TaskSnapshot `json:"after,omitempty"`
	Detail    any           `json:"detail,omitempty"`
}

Event represents a domain event emitted after a successful mutation.

For task events, Before and After carry snapshots of the task state before and after the mutation:

• Create: Before=nil, After=snapshot
• Update: Before=snap, After=snapshot
• Transition: Before=snap, After=snapshot
• Delete: Before=snap, After=nil
• Comment/Dep/Attachment: Before=nil, After=snapshot (current state)

type EventBus ¶

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

EventBus is an in-process pub/sub system. Mutations publish events; subscribers (SSE, webhooks, MCP) receive them on buffered channels. Publishing never blocks — if a subscriber's buffer is full, the oldest event is dropped.

func New() *EventBus

func (b *EventBus) Publish(event Event)

func (b *EventBus) Subscribe() *Subscription

type Subscription ¶

type Subscription struct {
	C <-chan Event
	// contains filtered or unexported fields
}

Subscription receives events on a buffered channel.

func (s *Subscription) Cancel()

type TaskSnapshot ¶

type TaskSnapshot struct {
	Ref      string  `json:"ref"`
	Num      int     `json:"num"`
	Title    string  `json:"title"`
	State    string  `json:"state"`
	Priority string  `json:"priority,omitempty"`
	Assignee *string `json:"assignee,omitempty"`
}

TaskSnapshot is a point-in-time snapshot of a task's display-relevant fields.