pubsub

May 2, 2026

Changes in this version

+ const SourceCascade

+ const TopicCascade

+ type CascadeEnvelopeFields struct

+ ChangeClass string

+ EffectsWidened bool

+ FromContentHash string

+ FromInterfaceHash string

+ FromVersion string

+ NewEffectCeiling []string

+ PrevEffectCeiling []string

+ RootPackage string

+ ToContentHash string

+ ToInterfaceHash string

+ ToVersion string

+ type CascadeMessageData struct

+ Envelope *CascadeEnvelopeFields

+ MessageID string

type MessageAttributes

+ Source string

type Publisher

+ func (p *Publisher) PublishCascade(ctx context.Context, messageID string, attrs MessageAttributes, ...) error

+ func (p *Publisher) PublishCascadeWithEnvelope(ctx context.Context, messageID string, attrs MessageAttributes, ...) error

Apr 26, 2026

Changes in this version

type TaskCompletion

+ ArtifactGCSPath string

+ CacheCreationTokens int

+ CacheReadTokens int

Apr 21, 2026

Changes in this version

+ const DefaultTopicPrefix

+ const SubCompletionsCoordinator

+ const SubEventsDashboard

+ const SubEventsLaptop

+ const SubMessagesCoordinator

+ const SubMessagesLaptop

+ const SubTasksExecutor

+ const TopicCompletions

+ const TopicDeadLetter

+ const TopicEvents

+ const TopicMessages

+ const TopicTasks

+ func DecodePushEnvelope(body io.Reader) (data []byte, attrs map[string]string, messageID string, err error)

+ type Client struct

+ func NewClient(ctx context.Context, projectID, prefix string) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Prefix() string

+ func (c *Client) ProjectID() string

+ func (c *Client) Subscription(baseName string) *pubsub.Subscription

+ func (c *Client) SubscriptionName(baseName string) string

+ func (c *Client) Topic(baseName string) *pubsub.Topic

+ func (c *Client) TopicName(baseName string) string

+ type MessageAttributes struct

+ Category string

+ FromAgent string

+ Inbox string

+ MessageType string

+ Workspace string

+ func AttributesFromMap(m map[string]string) MessageAttributes

+ func (a MessageAttributes) ToMap() map[string]string

+ type MessageHandler func(ctx context.Context, data []byte, attrs map[string]string) error

+ type MessageNotification struct

+ MessageID string

+ func DecodeMessageNotification(data []byte) (MessageNotification, error)

+ type Publisher struct

+ func NewPublisher(client *Client) *Publisher

+ func (p *Publisher) PublishCompletion(ctx context.Context, completion TaskCompletion, workspace string) error

+ func (p *Publisher) PublishEvent(ctx context.Context, eventJSON []byte, eventType, taskID, workspace string) error

+ func (p *Publisher) PublishMessage(ctx context.Context, messageID string, attrs MessageAttributes) error

+ func (p *Publisher) PublishTask(ctx context.Context, taskID, agentID, workspace, provider string) error

+ func (p *Publisher) Stop()

+ type PushEnvelope struct

+ Message PushMessage

+ Subscription string

+ type PushMessage struct

+ Attributes map[string]string

+ Data string

+ MessageID string

+ PublishTime string

+ type Subscriber struct

+ func NewSubscriber(client *Client) *Subscriber

+ func (s *Subscriber) ReceiveOne(ctx context.Context, subName string) ([]byte, map[string]string, error)

+ func (s *Subscriber) Stop()

+ func (s *Subscriber) Subscribe(ctx context.Context, subName string, handler MessageHandler) error

+ type TaskCompletion struct

+ AgentID string

+ BranchName string

+ ChangedFiles []string

+ CostUSD float64

+ DurationMS int

+ ErrorMsg string

+ InputTokens int

+ NumTurns int

+ OutputTokens int

+ SessionID string

+ Status string

+ TaskID string

+ ToolCallCount int

+ func DecodeTaskCompletion(data []byte) (TaskCompletion, error)

+ type TaskDispatch struct

+ AgentID string

+ TaskID string

+ func DecodeTaskDispatch(data []byte) (TaskDispatch, error)