channels

type Channel interface {
	Type() ChannelType
	SendToAgent(ctx context.Context, workspaceID uint, agentID string, message Message) (*SendResult, error)
	SendToRun(ctx context.Context, workspaceID uint, runID string, message Message) (*SendResult, error)
}

type ChannelType string

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

type ErrChannelTypeNotRegistered struct {
	ChannelType ChannelType
}

type Message struct {
	Message           string                            `json:"message"`
	IdempotencyKey    string                            `json:"idempotency_key,omitempty"`
	TaskID            string                            `json:"task_id,omitempty"`
	SessionID         string                            `json:"session_id,omitempty"`
	SessionKey        *string                           `json:"session_key,omitempty"`
	Deliver           *bool                             `json:"deliver,omitempty"`
	TimeoutMs         *int                              `json:"timeout_ms,omitempty"`
	Policy            *orchestration.RunExecutionPolicy `json:"policy,omitempty"`
	Lane              *string                           `json:"lane,omitempty"`
	ExtraSystemPrompt *string                           `json:"extra_system_prompt,omitempty"`
	InputProvenance   *orchestration.InputProvenance    `json:"input_provenance,omitempty"`
	Routing           *orchestration.RoutingContext     `json:"routing,omitempty"`
	Attachments       []map[string]any                  `json:"attachments,omitempty"`
	Label             *string                           `json:"label,omitempty"`
	SpawnedBy         *string                           `json:"spawned_by,omitempty"`
	QueueMode         types.AgentQueueMode              `json:"queue_mode,omitempty"`
}

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

type SendResult struct {
	Accepted        bool                          `json:"accepted"`
	IdempotentHit   bool                          `json:"idempotent_hit"`
	Task            *types.AgentTask              `json:"task,omitempty"`
	RunID           *string                       `json:"run_id,omitempty"`
	DeliveryOutcome types.RunInputDeliveryOutcome `json:"delivery_outcome,omitempty"`
	Interaction     *types.RunInteraction         `json:"interaction,omitempty"`
}