Files
agent-radar 2ed3415fb7
Publish Claude Code Binaries / Stage and publish binaries (push) Canceled after 0s
Publish Tutti App Runtime / Build darwin-arm64 (push) Canceled after 0s
Publish Tutti App Runtime / Build darwin-amd64 (push) Canceled after 0s
Publish Tutti App Runtime / Build linux-amd64 (push) Canceled after 0s
Publish Tutti App Runtime / Build windows-amd64 (push) Canceled after 0s
Sync Tutti Agent Skills / sync (push) Canceled after 0s
Windows Agent Adapters / Test Windows agent adapters (push) Canceled after 0s
Windows Daemon Adapters / Test Windows daemon adapters (push) Canceled after 0s
Publish Tutti App Runtime / Publish runtime catalog (push) Canceled after 0s
源码快照 @ 2026-09-01 (source-only, 剔除非源码素材)
2026-09-01 20:17:27 +08:00

41 lines
2.2 KiB
Go

package host
import "context"
// SnapshotReader is the read-only connector-market state boundary used by
// consumers that must not depend on repository persistence details.
type SnapshotReader interface {
Snapshot(ctx context.Context) (Snapshot, error)
}
type ScopedSnapshotReader interface {
SnapshotForScope(ctx context.Context, scope OperationScope) (Snapshot, error)
}
type ScopedOperationReader interface {
GetOperationForScope(ctx context.Context, scope OperationScope, operationID string) (Operation, error)
}
// Service is the host-neutral connector-market application boundary. Host
// daemons provide ports for persistence, artifacts, authorization, scheduling,
// and events; transports adapt their generated OpenAPI DTOs to this interface.
type Service interface {
SnapshotReader
ListCatalogCategories(ctx context.Context) ([]CatalogCategory, error)
ListCatalogPage(ctx context.Context, query CatalogPageQuery) (CatalogPage, error)
GetConnector(ctx context.Context, connectorKey string) (Connector, error)
GetOperationForScope(ctx context.Context, scope OperationScope, operationID string) (Operation, error)
RefreshCatalog(ctx context.Context, mutation Mutation) (MutationResult, error)
Install(ctx context.Context, mutation ConnectorMutation) (MutationResult, error)
Uninstall(ctx context.Context, mutation ConnectorMutation) (MutationResult, error)
SetRuntimeEnabled(ctx context.Context, mutation ConnectorMutation, enabled bool) (Connector, error)
ReconcileRuntime(ctx context.Context, mutation ConnectorMutation) (MutationResult, error)
GetAuthorizationProjection(ctx context.Context, accountID, connectorKey string) (AuthorizationProjection, error)
ObserveAuthorization(ctx context.Context, mutation ConnectorMutation, projection AuthorizationProjection) (MutationResult, error)
BeginAuthorization(ctx context.Context, mutation ConnectorMutation, secret []byte) (AuthorizationResult, error)
CancelAuthorization(ctx context.Context, scope OperationScope, connectorKey string) error
DisconnectAuthorization(ctx context.Context, mutation ConnectorMutation) (MutationResult, error)
ExecuteOperation(ctx context.Context, operationID string) error
Recover(ctx context.Context) error
}