observable

type Change ¶

type Change struct {
	Domain  string
	Op      string
	ID      string
	Payload any
	Time    time.Time
}

Change is a single state-change notification a Store emits to its observers.

Domain identifies the emitting store ("task", "subagent", ...). Op names the verb ("created", "updated", "removed", "phase", ...). ID is the affected entity. Payload carries a domain-typed snapshot the consumer type-asserts on.

type Observable ¶

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

Observable(被觀察者) is the embeddable pub/sub primitive. Zero value is ready to use; safe for concurrent Subscribe and Notify from any goroutine.

func (o *Observable) Notify(c Change)

func (o *Observable) Subscribe(fn Observer)

type Observer ¶

type Observer func(Change)

Observer(觀察者) is the callback shape Subscribe accepts. Observers run on the goroutine that called Notify and must not block — slow consumers buffer internally.

type Store ¶

type Store interface {
	Domain() string
	Subscribe(Observer) // Store 必須可被觀察
}

Store is the contract every observable backing store satisfies. The Observable mixin below provides Subscribe and a Notify helper, so a store typically only needs to declare Domain().