Documentation
¶
Overview ¶
Package contract exposes the Conduit runtime to Forge dashboard clients.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Register ¶
func Register(disp *dispatcher.Dispatcher, registry dash.Registry, wardens dash.WardenRegistry, deps Deps) error
Register installs typed, scoped intents and the dashboard manifest.
Types ¶
type BackfillList ¶
type BackfillList struct {
Jobs []core.Backfill `json:"jobs"`
NextCursor string `json:"nextCursor"`
}
BackfillList retains service scope and opaque paging.
type ConsumerList ¶
type ConsumerList struct {
Consumers []core.ConsumerInfo `json:"consumers"`
}
ConsumerList reports real broker cursor state with instance-local latency.
type LetterList ¶
type LetterList struct {
Letters []LetterSummary `json:"letters"`
NextCursor string `json:"nextCursor"`
}
LetterList is cursor-paged and scoped to the runtime's logical service.
type LetterSummary ¶
type LetterSummary struct {
ID string `json:"id"`
MessageID string `json:"messageID"`
MessageType string `json:"messageType"`
Delivery core.DeliveryInfo `json:"delivery"`
FailedAt time.Time `json:"failedAt"`
Replayed bool `json:"replayed"`
}
LetterSummary keeps payloads, headers and arbitrary handler error text out of operator listings.
type ListInput ¶
type ListInput struct {
Provider string `json:"provider"`
Subscription string `json:"subscription,omitempty"`
Cursor string `json:"cursor,omitempty"`
Limit int `json:"limit,omitempty"`
}
ListInput selects a provider and an opaque continuation cursor.
type PauseInput ¶
type PauseInput struct {
Subscription string `json:"subscription"`
}
type ReplayInput ¶
type ReplayInput struct {
Provider string `json:"provider"`
Subscription string `json:"subscription"`
ID string `json:"id"`
}
ReplayInput identifies one dead letter in a provider and logical subscription.
type ServiceList ¶
ServiceList includes distinct replica records with one shared logical service ID.