contract

package
v1.12.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 10, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

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 Deps

type Deps struct{ Runtime func() *core.Runtime }

Deps resolves the runtime when an intent executes.

type HookList

type HookList struct {
	Events []core.HookEvent `json:"events"`
}

HookList is bounded and contains metadata only.

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

type ServiceList struct {
	Instances []core.Instance `json:"instances"`
}

ServiceList includes distinct replica records with one shared logical service ID.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL