Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ankka

package module

Go to main page

Versions in this module

v0

v0.14.2

Oct 24, 2026

v0.14.1

Oct 24, 2026

v0.14.0

Oct 24, 2026

Changes in this version

+ const BinaryContent

+ const DefaultSignedURLSpan

+ const GraphDeltaSchema

+ const JSONContent

+ const MaxObjectNameBytes

+ const MaxSecretValue

+ const MaxServiceBody

+ const MaxSignedURLSpan

+ const ProtocolVersion

+ const SDKName

+ const TextContent

+ func AwaitEnd[R any](ctx context.Context, workflowID, id string, within time.Duration) (R, error)

+ func BucketNameProblem(name string) string

+ func Cancel(ctx context.Context, timerID string) error

+ func CancelTask(ctx context.Context, id, reason string) error

+ func CodecProblems[T any](c Codec[T]) []string

+ func ConfigFrom(ctx context.Context) map[string]string

+ func CreateTask(ctx context.Context, t AnyTaskType, instructions string, opts TaskOptions) (string, error)

+ func DecideApproval[R any](ctx context.Context, componentID, sessionID, handler, approvalID string, ...) (R, error)

+ func EdgeKey(id string) string

+ func Fingerprint(document []byte) (string, error)

+ func FormatDuration(d time.Duration) string

+ func FormatInstant(t time.Time) string

+ func InvokeStream(ctx context.Context, componentID, entityID, wire string, input any) iter.Seq2[string, error]

+ func Invoke[R any](ctx context.Context, componentID, entityID, wire string, input any) (R, error)

+ func NodeKey(id string) string

+ func ObjectNameProblem(name string) string

+ func ParseDuration(text string) (time.Duration, error)

+ func ParseInstant(text string) (time.Time, error)

+ func PrefixProblem(prefix string) string

+ func QueryStream[Row any](ctx context.Context, viewID string, q ViewQuery) iter.Seq2[Row, error]

+ func QueryView[Row any](ctx context.Context, viewID string, q ViewQuery) ([]Row, error)

+ func Refuse(code ErrorCode, message string) error

+ func Refusef(code ErrorCode, format string, args ...any) error

+ func RunSingleTask(ctx context.Context, componentID string, t AnyTaskType, instructions string, ...) (string, error)

+ func Schedule(ctx context.Context, timerID string, delay time.Duration, target TimerTarget, ...) error

+ func ScheduleRecurring(ctx context.Context, timerID string, delay, period time.Duration, ...) error

+ func SendAndAwait[R any](ctx context.Context, workflowID, id, wire string, input any, ...) (R, error)

+ func SpanProblem(span time.Duration) string

+ func TableOf(viewID string) string

+ func Version() string

+ func ViewRow[Row any](ctx context.Context, viewID, key string) (Row, bool, error)

+ func WatchEvents[Row any](watch iter.Seq2[WatchEvent[Row], error]) iter.Seq2[SSEEvent, error]

+ func Watch[Row any](ctx context.Context, viewID string, target WatchTarget) iter.Seq2[WatchEvent[Row], error]

+ func WithClient(ctx context.Context, c *Client) context.Context

+ func WithStorage(ctx context.Context, s Storage) context.Context

+ type ACL struct

+ func AllowAll() *ACL

+ func AllowClientKeys() *ACL

+ func AllowIf(first CallerMatch, rest ...CallerMatch) *ACL

+ func AnyOf(first *ACL, rest ...*ACL) *ACL

+ func Authenticate(issuers ...IssuerRef) *ACL

+ func DenyAll() *ACL

+ type ActionEffect struct

+ func ActionDone() ActionEffect

+ func ActionFail(code ErrorCode, message string) ActionEffect

+ type AgentComponent struct

+ func Agent(id string, parts ...Part) *AgentComponent

+ func (a *AgentComponent) ID() string

+ type AgentEffect struct

+ Context []string

+ GuardrailNames []string

+ JSONReply bool

+ Model string

+ SchemaHint string

+ SessionMemory bool

+ System string

+ ToolNames []string

+ User string

+ func AgentError(code ErrorCode, message string) AgentEffect

+ func AgentModel(name string) AgentEffect

+ func SystemMessage(text string) AgentEffect

+ func UserMessage(text string) AgentEffect

+ func (e AgentEffect) Failure() *Refusal

+ func (e AgentEffect) Guardrails(names ...string) AgentEffect

+ func (e AgentEffect) Memory(session bool) AgentEffect

+ func (e AgentEffect) SystemMessage(text string) AgentEffect

+ func (e AgentEffect) ThenReply() AgentEffect

+ func (e AgentEffect) ThenReplyJSON(schemaHint string) AgentEffect

+ func (e AgentEffect) Tools(names ...string) AgentEffect

+ func (e AgentEffect) UserMessage(text string) AgentEffect

+ func (e AgentEffect) WithContext(text string) AgentEffect

+ func (e AgentEffect) WithModel(name string) AgentEffect

+ type AgentGuardrail interface

+ func Guardrail(name string, ...) AgentGuardrail

+ func ResultGuardrail(name string, f func(ctx context.Context, tool, text string) (string, error)) AgentGuardrail

+ type AgentInstance struct

+ ComponentID string

+ InstanceID string

+ func Instance(componentID, instanceID string) AgentInstance

+ func (a AgentInstance) Assign(ctx context.Context, taskIDs ...string) (Assigned, error)

+ func (a AgentInstance) Decide(ctx context.Context, approvalID string, d Decision) error

+ func (a AgentInstance) Notifications(ctx context.Context) iter.Seq2[Notification, error]

+ func (a AgentInstance) Resume(ctx context.Context) error

+ func (a AgentInstance) State(ctx context.Context) (InstanceState, error)

+ func (a AgentInstance) Suspend(ctx context.Context) error

+ func (a AgentInstance) Terminate(ctx context.Context) error

+ type AgentScope struct

+ ComponentID string

+ Metadata Metadata

+ SessionID string

+ TaskID string

+ func AgentFrom(ctx context.Context) (AgentScope, bool)

+ type AgentTool interface

+ func ApprovedTool[I, R any](name, description string, within time.Duration, ...) AgentTool

+ func Tool[I, R any](name, description string, f func(ctx context.Context, input I) (R, error)) AgentTool

+ type AnyTaskType interface

+ Name func() string

+ type ApprovalAwaitedError struct

+ Requests []ApprovalRequest

+ func (e *ApprovalAwaitedError) Error() string

+ type ApprovalRequest struct

+ ArgumentsJSON string

+ ExpiresAt *time.Time

+ ID string

+ RequestedAt time.Time

+ Tool string

+ type Assigned struct

+ Accepted []string

+ Refused map[string]AssignmentRefusal

+ type Assignee struct

+ ComponentID string

+ InstanceID string

+ type AssignmentRefusal struct

+ Code string

+ Message string

+ type Attachment struct

+ Content string

+ ContentType string

+ Name string

+ URI string

+ type AutonomousComponent struct

+ func Autonomous(id, description string, parts ...Part) *AutonomousComponent

+ func (a *AutonomousComponent) ID() string

+ type AutonomousSettings struct

+ ApproachingBudgetAt float64

+ DependencyStuckAfter time.Duration

+ MaxConsecutiveFailures int

+ RepeatedFailureAt int

+ type Bucket interface

+ Delete func(ctx context.Context, name string) error

+ Exposure func() Exposure

+ Get func(ctx context.Context, name string) (*StoredObject, error)

+ List func(ctx context.Context, prefix string) iter.Seq2[ObjectEntry, error]

+ Name func() string

+ PublicURL func(name string) (string, error)

+ Put func(ctx context.Context, name string, body io.Reader, length int64, ...) error

+ SignedURL func(name string, access SignedAccess, span time.Duration) (string, error)

+ Stat func(ctx context.Context, name string) (*ObjectInfo, error)

+ type Caller struct

+ Kind CallerKind

+ Name string

+ Organization string

+ Project string

+ func CallerFrom(ctx context.Context) Caller

+ type CallerKind int

+ const CallerGateway

+ const CallerLocal

+ const CallerMachine

+ const CallerService

+ func (k CallerKind) String() string

+ type CallerMatch struct

+ func AnyInProject() CallerMatch

+ func Granted() CallerMatch

+ func Internet() CallerMatch

+ func Self() CallerMatch

+ func ServiceIn(project, name string) CallerMatch

+ func ServiceNamed(name string) CallerMatch

+ type CaseOf struct

+ func Case[I, T any](discriminator string) CaseOf[I]

+ type ChangeScope struct

+ ComponentID string

+ Deleted bool

+ Installation string

+ Local bool

+ Metadata Metadata

+ Sequence int64

+ SourceID string

+ Standing *Standing

+ Subject string

+ func ChangeFrom(ctx context.Context) (ChangeScope, bool)

+ type Client struct

+ func ClientFrom(ctx context.Context) *Client

+ func NewClient(address string) *Client

+ func (c *Client) Close() error

+ type ClientKey struct

+ Attributes map[string]string

+ Endpoint string

+ ExpiresAt *time.Time

+ ID string

+ IssuedAt time.Time

+ Label string

+ LastUsed *time.Time

+ RevokedAt *time.Time

+ Scope []string

+ Subject string

+ type ClientKeyRequest struct

+ Attributes map[string]string

+ Endpoint string

+ ExpiresAfter time.Duration

+ ExpiresAt time.Time

+ Label string

+ Never bool

+ Scope []string

+ Subject string

+ type ClientKeyStore struct

+ func ClientKeys(ctx context.Context) *ClientKeyStore

+ func (s *ClientKeyStore) Issue(req ClientKeyRequest) (IssuedClientKey, error)

+ func (s *ClientKeyStore) List() ([]ClientKey, error)

+ func (s *ClientKeyStore) Revoke(id string) error

+ type Codec interface

+ ContentType func() string

+ Decode func(data []byte) (T, error)

+ Encode func(value T) ([]byte, error)

+ Manifest func() string

+ func CodecFor[T any](opts ...CodecOption) Codec[T]

+ func CustomCodec[T any](manifest, contentType string, encode func(T) ([]byte, error), ...) Codec[T]

+ type CodecOption func(*codecSettings)

+ func Manifest(name string) CodecOption

+ type CommandScope struct

+ AtHome bool

+ Attribution string

+ ComponentID string

+ EntityID string

+ ForwardedFrom string

+ Installation string

+ Metadata Metadata

+ Sequence int64

+ func CommandFrom(ctx context.Context) (CommandScope, bool)

+ type ConsumerComponent struct

+ func Consumer[Msg any](id string, source Source, ...) *ConsumerComponent[Msg]

+ func GraphConsumer[Msg any](id string, source Source, topic string, ...) *ConsumerComponent[Msg]

+ func (c *ConsumerComponent[Msg]) ID() string

+ type ConsumerEffect struct

+ func ConsumerDone() ConsumerEffect

+ func ConsumerIgnore() ConsumerEffect

+ func Produce(payload any, md ...Metadata) ConsumerEffect

+ func ProduceAll(messages ...Message) ConsumerEffect

+ func (e ConsumerEffect) Messages() []Message

+ type Contract struct

+ Fingerprint string

+ Name string

+ func ContractFromBytes(document []byte, name string) (Contract, error)

+ func ContractFromFile(path, name string) (Contract, error)

+ type Decision struct

+ Approved bool

+ By string

+ Note string

+ type Declaration interface

+ type DeclaredQuery struct

+ Name string

+ Statement string

+ Watched bool

+ func Declared(name, statement string) DeclaredQuery

+ func WatchedQuery(name, statement string) DeclaredQuery

+ type DecodingError struct

+ Message string

+ Path string

+ func (e *DecodingError) Error() string

+ type Delta struct

+ Element string

+ From string

+ ID string

+ Kind string

+ Labels []string

+ Properties map[string]any

+ To string

+ Type string

+ Version int64

+ func ReadDelta(value []byte, key string) (Delta, error)

+ func (d Delta) Key() string

+ type DirectoryStorage struct

+ func NewDirectoryStorage(root, address string) *DirectoryStorage

+ func (s *DirectoryStorage) Bucket(name string) (Bucket, error)

+ func (s *DirectoryStorage) Buckets() []Bucket

+ func (s *DirectoryStorage) Default() (Bucket, error)

+ func (s *DirectoryStorage) Root() string

+ type Done struct

+ type Effect struct

+ func (e Effect[S, E, R]) Events() []E

+ type Element struct

+ func Edge(id, typ, from, to string, opts ...ElementOption) Element

+ func EdgeTombstone(id, typ, from, to string, opts ...ElementOption) Element

+ func Node(id string, opts ...ElementOption) Element

+ func NodeTombstone(id string, opts ...ElementOption) Element

+ func (e Element) Key() string

+ type ElementOption func(*Element)

+ func AtVersion(v int64) ElementOption

+ func Labels(labels ...string) ElementOption

+ func WithProperties(p Properties) ElementOption

+ type EncodingError struct

+ Message string

+ Path string

+ func (e *EncodingError) Error() string

+ type Endpoint struct

+ func NewEndpoint(prefix string, acl *ACL, routes ...RouteOrOption) *Endpoint

+ func (e *Endpoint) Prefix() string

+ type EndpointOption struct

+ func Issuers(issuers ...IssuerRef) EndpointOption

+ type Enum struct

+ func Enumeration[E ~string](values ...E) *Enum[E]

+ func (e *Enum[E]) Values() []E

+ type ErrorCode int

+ const BadRequest

+ const Conflict

+ const Forbidden

+ const Internal

+ const NotFound

+ const NotHome

+ const Timeout

+ const Unauthorized

+ const Unavailable

+ const WorkflowFailed

+ func (c ErrorCode) HTTPStatus() int

+ func (c ErrorCode) String() string

+ type EventScope struct

+ Attribution string

+ ForwardedFrom string

+ Installation string

+ Local bool

+ Sequence int64

+ func EventFrom(ctx context.Context) (EventScope, bool)

+ type EventSourcedEntity struct

+ func EventSourced[S, E any](id string, events *SumType[E], empty func(entityID string) S, ...) *EventSourcedEntity[S, E]

+ func (e *EventSourcedEntity[S, E]) ID() string

+ type Exposure string

+ const ExposurePrivate

+ const ExposurePublic

+ const ExposureSigned

+ const ExposureSupplied

+ type GraphEffect struct

+ func GraphDone() GraphEffect

+ func GraphIgnore() GraphEffect

+ func Publish(elements ...Element) GraphEffect

+ func (e GraphEffect) Elements() []Element

+ type GraphError struct

+ Message string

+ Why string

+ func (e *GraphError) Error() string

+ type GuardrailStage string

+ const GuardrailInput

+ const GuardrailOutput

+ type HttpProblem struct

+ Message string

+ Status int

+ func (e *HttpProblem) Error() string

+ type InstancePhase string

+ const PhaseIdle

+ const PhaseSuspended

+ const PhaseTerminated

+ const PhaseWaiting

+ const PhaseWorking

+ type InstanceState struct

+ Awaiting []ApprovalRequest

+ CurrentTask string

+ Iteration int

+ Phase InstancePhase

+ Queued []string

+ type IssuedClientKey struct

+ ClientKey string

+ ID string

+ type IssuerRef struct

+ func Issuer(name string) IssuerRef

+ type KeyValueBuilder struct

+ func DeleteState[S, R any]() KeyValueBuilder[S, R]

+ func KeepState[S, R any]() KeyValueBuilder[S, R]

+ func UpdateState[S, R any](s S) KeyValueBuilder[S, R]

+ func (b KeyValueBuilder[S, R]) DeleteEntity() KeyValueBuilder[S, R]

+ func (b KeyValueBuilder[S, R]) ExpireAfter(d time.Duration) KeyValueBuilder[S, R]

+ func (b KeyValueBuilder[S, R]) ThenNoReply() KeyValueEffect[S, R]

+ func (b KeyValueBuilder[S, R]) ThenReply(compute func(S) R) KeyValueEffect[S, R]

+ func (b KeyValueBuilder[S, R]) ThenReplyState() KeyValueEffect[S, R]

+ func (b KeyValueBuilder[S, R]) ThenReplyValue(v R) KeyValueEffect[S, R]

+ type KeyValueEffect struct

+ type KeyValueEntity struct

+ func KeyValue[S any](id string, empty func(entityID string) S, parts ...Part) *KeyValueEntity[S]

+ func (e *KeyValueEntity[S]) ID() string

+ type KeyedViewComponent struct

+ func KeyedView[Row any](id string, parts ...Part) *KeyedViewComponent[Row]

+ func (v *KeyedViewComponent[Row]) ID() string

+ type KeyedViewEffect struct

+ func AllRows[Row any](effects ...KeyedViewEffect[Row]) KeyedViewEffect[Row]

+ func DeleteRowAt[Row any](key string) KeyedViewEffect[Row]

+ func IgnoreRows[Row any]() KeyedViewEffect[Row]

+ func UpdateRowAt[Row any](key string, row Row) KeyedViewEffect[Row]

+ func (e KeyedViewEffect[Row]) Changes() []RowChange[Row]

+ type LocalDate struct

+ func LocalDateOf(t time.Time) LocalDate

+ func NewLocalDate(year int, month time.Month, day int) LocalDate

+ func ParseLocalDate(text string) (LocalDate, error)

+ func (d LocalDate) IsZero() bool

+ func (d LocalDate) String() string

+ func (d LocalDate) Time() time.Time

+ type LocalDateTime struct

+ func LocalDateTimeOf(t time.Time) LocalDateTime

+ func ParseLocalDateTime(text string) (LocalDateTime, error)

+ func (d LocalDateTime) IsZero() bool

+ func (d LocalDateTime) String() string

+ func (d LocalDateTime) Time() time.Time

+ type McpEndpoint struct

+ func NewMcpEndpoint(path string, acl *ACL, parts ...McpPart) *McpEndpoint

+ func (e *McpEndpoint) Path() string

+ type McpPart interface

+ func Brokered() McpPart

+ func McpCommandRef(name, description, componentID, handler, idArg string, opts ...McpToolOption) McpPart

+ func McpQueryRef(name, description, componentID, handler, idArg string, opts ...McpToolOption) McpPart

+ func McpRouteRef(name, description, method, path string, opts ...McpToolOption) McpPart

+ func McpTool[I, R any](name, description string, f func(ctx context.Context, input I) (R, error), ...) McpPart

+ func ServerInfo(name, version string) McpPart

+ type McpServerOption func(*pb.McpServer)

+ func McpApproval(within time.Duration) McpServerOption

+ func McpHeader(name, variable string) McpServerOption

+ func McpService(project, service, path string) McpServerOption

+ func McpURL(url string) McpServerOption

+ type McpServerRef struct

+ func McpServer(name string, opts ...McpServerOption) McpServerRef

+ type McpToolOption func(*mcpToolDecl)

+ func InputArgument(name string) McpToolOption

+ func ToolACL(acl *ACL) McpToolOption

+ type MemoryOption func(*MemoryStorage)

+ func MemoryPublicBase(f func(bucket string) string) MemoryOption

+ func MemoryUnnamed(has bool) MemoryOption

+ func MemoryUnnamedExposure(e Exposure) MemoryOption

+ type MemoryStorage struct

+ func NewMemoryStorage(opts ...MemoryOption) *MemoryStorage

+ func (m *MemoryStorage) Bucket(name string) (Bucket, error)

+ func (m *MemoryStorage) Buckets() []Bucket

+ func (m *MemoryStorage) Clear()

+ func (m *MemoryStorage) Declare(name string, exposure Exposure) error

+ func (m *MemoryStorage) Default() (Bucket, error)

+ type Message struct

+ Key string

+ Metadata Metadata

+ Payload any

+ type Metadata map[string]string

+ func MetadataFrom(ctx context.Context) Metadata

+ type Notification struct

+ At time.Time

+ ComponentID string

+ Fields map[string]json.RawMessage

+ InstanceID string

+ TaskID string

+ Type string

+ type ObjectEntry struct

+ LastKept time.Time

+ Length int64

+ Name string

+ type ObjectInfo struct

+ ContentType string

+ LastKept time.Time

+ Length int64

+ Name string

+ type Part interface

+ func Accepts(t AnyTaskType, maxIterations int) Part

+ func Action[I any](wire string, f func(ctx context.Context, input I) (ActionEffect, error)) Part

+ func ApplyWithContext[S, E any](apply func(ctx context.Context, state S, event E) S) Part

+ func AskStream[I any](wire string, f func(ctx context.Context, input I) (AgentEffect, error)) Part

+ func Ask[I any](wire string, f func(ctx context.Context, input I) (AgentEffect, error)) Part

+ func AutonomousModel(name string) Part

+ func Command[S, E, I, R any](wire string, ...) Part

+ func EventCodec[E any](c Codec[E]) Part

+ func ForStep(step string, opts ...WorkflowOption) Part

+ func Guardrails(guardrails ...AgentGuardrail) Part

+ func Instructions(text string) Part

+ func MaxToolCallSteps(n int) Part

+ func McpServers(servers ...McpServerRef) Part

+ func MirroredChanges() Part

+ func OnChange[Src, Row any](source Source, ...) Part

+ func OnDelete[Row any](f func(ctx context.Context, row *Row) (ViewEffect[Row], error)) Part

+ func On[Src, Row any](source Source, ...) Part

+ func ProducesTo[Out any](topic string, opts ...PublicationOption) Part

+ func ProducesWith[Out any](topic string, c Codec[Out], opts ...PublicationOption) Part

+ func Queries(queries ...DeclaredQuery) Part

+ func Query[S, I, R any](wire string, ...) Part

+ func Replicated() Part

+ func Role(text string) Part

+ func RowCodec[Row any](c Codec[Row]) Part

+ func SnapshotEvery(n int) Part

+ func SourceVersion(n int) Part

+ func StateCodec[S any](c Codec[S]) Part

+ func Step[S, I any](name string, ...) Part

+ func Tools(tools ...AgentTool) Part

+ func Update[S, I, R any](wire string, ...) Part

+ func WhenDeleted[Eff ConsumerEffect | GraphEffect](f func(ctx context.Context) (Eff, error)) Part

+ func WithAutonomousSettings(s AutonomousSettings) Part

+ func WorkflowCommand[S, I, R any](wire string, ...) Part

+ func WorkflowTimeout(d time.Duration) Part

+ type PauseOptions struct

+ After time.Duration

+ OnTimeout string

+ OnTimeoutInput any

+ type PersistBuilder struct

+ func Persist[S, E, R any](events ...E) PersistBuilder[S, E, R]

+ func (b PersistBuilder[S, E, R]) DeleteEntity() PersistBuilder[S, E, R]

+ func (b PersistBuilder[S, E, R]) ExpireAfter(d time.Duration) PersistBuilder[S, E, R]

+ func (b PersistBuilder[S, E, R]) HandOverTo(installation string) PersistBuilder[S, E, R]

+ func (b PersistBuilder[S, E, R]) ReplicateTo(installation string) PersistBuilder[S, E, R]

+ func (b PersistBuilder[S, E, R]) StopReplicatingTo(installation string) PersistBuilder[S, E, R]

+ func (b PersistBuilder[S, E, R]) ThenNoReply() Effect[S, E, R]

+ func (b PersistBuilder[S, E, R]) ThenReply(compute func(S) R) Effect[S, E, R]

+ func (b PersistBuilder[S, E, R]) ThenReplyState() Effect[S, E, R]

+ func (b PersistBuilder[S, E, R]) ThenReplyValue(v R) Effect[S, E, R]

+ func (b PersistBuilder[S, E, R]) ThenReplyWithMetadata(compute func(S) R, md Metadata) Effect[S, E, R]

+ type Principal struct

+ Claims map[string]string

+ Email string

+ EmailVerified bool

+ Issuer string

+ Name string

+ Roles []string

+ Subject string

+ func (p *Principal) Claim(name string) string

+ func (p *Principal) HasRole(role string) bool

+ type Problem struct

+ Message string

+ Where string

+ func (p Problem) String() string

+ type ProblemsError struct

+ Problems []Problem

+ func (e *ProblemsError) Error() string

+ type Properties map[string]any

+ type ProtocolTooOldError struct

+ Message string

+ Needs string

+ What string

+ func (e *ProtocolTooOldError) Error() string

+ type Publication struct

+ type PublicationOption func(*Publication)

+ func StatesContract(c Contract) PublicationOption

+ func ToBroker(name string) PublicationOption

+ func ToProject(project string) PublicationOption

+ type RawResponse struct

+ Body []byte

+ ContentType string

+ Headers http.Header

+ Status int

+ type ReadOnlyEffect struct

+ func NoReply[R any]() ReadOnlyEffect[R]

+ func ReplyWithMetadata[R any](v R, md Metadata) ReadOnlyEffect[R]

+ func Reply[R any](v R) ReadOnlyEffect[R]

+ type Recovery struct

+ FailoverTo string

+ MaxRetries int

+ type Refusal struct

+ Code ErrorCode

+ Message string

+ type RefusalError struct

+ Code ErrorCode

+ Details map[string]string

+ Message string

+ func AsRefusal(err error) (*RefusalError, bool)

+ func (e *RefusalError) Error() string

+ func (e *RefusalError) ProtocolError() *pb.Error

+ type ReplicationChange struct

+ Add []string

+ HandOverTo string

+ Remove []string

+ type Request struct

+ Body []byte

+ Caller Caller

+ ContentType string

+ Headers http.Header

+ Metadata Metadata

+ Method string

+ Params map[string]string

+ Path string

+ Principal *Principal

+ Query url.Values

+ func RequestFrom(ctx context.Context) *Request

+ func (r *Request) Header(name string) string

+ func (r *Request) Param(name string) string

+ type Route struct

+ func Delete[R any](template string, f func(ctx context.Context, req *Request) (R, error)) *Route

+ func Get[R any](template string, f func(ctx context.Context, req *Request) (R, error)) *Route

+ func Patch[B, R any](template string, f func(ctx context.Context, req *Request, body B) (R, error)) *Route

+ func Post[B, R any](template string, f func(ctx context.Context, req *Request, body B) (R, error)) *Route

+ func Put[B, R any](template string, f func(ctx context.Context, req *Request, body B) (R, error)) *Route

+ func SSE(template string, ...) *Route

+ func SSEEvents(template string, ...) *Route

+ func SocketRoute(template string, f func(ctx context.Context, s *Socket) error) *Route

+ func (r *Route) ACL(acl *ACL) *Route

+ type RouteOrOption interface

+ type RowChange struct

+ Deleted bool

+ Key string

+ Row Row

+ type S3Storage struct

+ func (s *S3Storage) Bucket(name string) (Bucket, error)

+ func (s *S3Storage) Buckets() []Bucket

+ func (s *S3Storage) Default() (Bucket, error)

+ type SSEEvent struct

+ Data any

+ Name string

+ Text string

+ type SecretStore struct

+ func Secrets(ctx context.Context) *SecretStore

+ func (s *SecretStore) Delete(name string) error

+ func (s *SecretStore) Get(name string) (string, bool, error)

+ func (s *SecretStore) Put(name, value string) error

+ type Service struct

+ func NewService(declarations ...Declaration) *Service

+ func (s *Service) Client() *Client

+ func (s *Service) Problems() []Problem

+ func (s *Service) Reported() []string

+ func (s *Service) Serve(ctx context.Context, lis net.Listener, opts ...StartOption) error

+ func (s *Service) SidecarProtocol() string

+ func (s *Service) Spec() *pb.Spec

+ func (s *Service) Start(ctx context.Context, opts ...StartOption) error

+ type ServiceError struct

+ Detail string

+ Reason ServiceFailureReason

+ Service string

+ func (e *ServiceError) Error() string

+ type ServiceFailureReason int

+ const ServiceIdentityMismatch

+ const ServiceUnanswered

+ const ServiceUnresolvable

+ type ServiceRequest struct

+ Body []byte

+ ContentType string

+ Headers http.Header

+ Method string

+ Path string

+ Project string

+ type ServiceResponse struct

+ Body []byte

+ ContentType string

+ Headers http.Header

+ Status int

+ func CallService(ctx context.Context, service string, req ServiceRequest) (*ServiceResponse, error)

+ type SignedAccess string

+ const AccessKeep

+ const AccessRead

+ type Socket struct

+ func (s *Socket) CloseReason() string

+ func (s *Socket) Receive() (string, error)

+ func (s *Socket) Request() *Request

+ func (s *Socket) Send(text string) error

+ type Source struct

+ func Changes(c changeSource) Source

+ func Topic(name string, opts ...TopicOption) Source

+ func WorkflowSource[S any](w *WorkflowComponent[S]) Source

+ type Standing struct

+ Failure string

+ Retries map[string]int

+ Status string

+ Step string

+ func (s Standing) Terminal() bool

+ type StartOption func(*startSettings)

+ func GracePeriod(d time.Duration) StartOption

+ func Host(host string) StartOption

+ func Logger(l *slog.Logger) StartOption

+ func Port(port int) StartOption

+ func ServiceDirectory(dir string) StartOption

+ func SidecarAddress(address string) StartOption

+ func StorageOf(store Storage) StartOption

+ type StartPosition struct

+ func Earliest() StartPosition

+ func Latest() StartPosition

+ func StartAt(t time.Time) StartPosition

+ type StepBuilder struct

+ func StepKeep[S any]() StepBuilder[S]

+ func StepUpdate[S any](s S) StepBuilder[S]

+ func (b StepBuilder[S]) ThenEnd() StepEffect[S]

+ func (b StepBuilder[S]) ThenFail(code ErrorCode, message string) StepEffect[S]

+ func (b StepBuilder[S]) ThenPause(opts PauseOptions) StepEffect[S]

+ func (b StepBuilder[S]) ThenTransitionTo(step string, input any) StepEffect[S]

+ type StepEffect struct

+ func End[S any]() StepEffect[S]

+ func FailWorkflow[S any](code ErrorCode, message string) StepEffect[S]

+ func Pause[S any](opts PauseOptions) StepEffect[S]

+ func TransitionTo[S any](step string, input any) StepEffect[S]

+ type StepRef struct

+ Input any

+ Step string

+ type Storage interface

+ Bucket func(name string) (Bucket, error)

+ Buckets func() []Bucket

+ Default func() (Bucket, error)

+ var NoStorage Storage = noStorage{}

+ func StorageFrom(ctx context.Context) Storage

+ type StorageBackend string

+ const BackendDirectory

+ const BackendMemory

+ const BackendS3

+ const BackendUnavailable

+ type StoredObject struct

+ Body io.ReadCloser

+ ContentType string

+ LastKept time.Time

+ Length int64

+ func (o *StoredObject) Bytes() ([]byte, error)

+ type SumType struct

+ func Cases[I any](cases ...CaseOf[I]) *SumType[I]

+ func (s *SumType[I]) Type() reflect.Type

+ type TaskOptions struct

+ Attachments []Attachment

+ DependsOn []string

+ ID string

+ type TaskRule struct

+ Check func(ctx context.Context, result R) (Verdict, error)

+ Name string

+ func Rule[R any](name string, check func(ctx context.Context, result R) (Verdict, error)) TaskRule[R]

+ type TaskSnapshot struct

+ Assignee *Assignee

+ ID string

+ Iterations int

+ Reason string

+ Record json.RawMessage

+ Result *R

+ Status TaskStatus

+ TypeName string

+ func GetTask[R any](ctx context.Context, t *TaskType[R], id string) (TaskSnapshot[R], error)

+ func WaitForTask[R any](ctx context.Context, t *TaskType[R], id string, within time.Duration) (TaskSnapshot[R], error)

+ type TaskStatus string

+ const TaskAssigned

+ const TaskCancelled

+ const TaskCompleted

+ const TaskFailed

+ const TaskInProgress

+ const TaskPending

+ const TaskResultRejected

+ func (s TaskStatus) Ended() bool

+ type TaskType struct

+ func NewTaskType[R any](name, description string, rules ...TaskRule[R]) *TaskType[R]

+ func (t *TaskType[R]) Name() string

+ type TimedActionComponent struct

+ func TimedAction(id string, parts ...Part) *TimedActionComponent

+ func (t *TimedActionComponent) ID() string

+ type TimerScope struct

+ Attempts int

+ Due time.Time

+ Name string

+ func TimerFrom(ctx context.Context) (TimerScope, bool)

+ type TimerTarget struct

+ ComponentID string

+ EntityID string

+ Handler string

+ type TopicOption func(*Source)

+ func ExpectContract(c Contract) TopicOption

+ func FromProject(project string) TopicOption

+ func OnBroker(name string) TopicOption

+ func Parallel() TopicOption

+ func StartFrom(p StartPosition) TopicOption

+ type Unit struct

+ type Verdict struct

+ func Accepted() Verdict

+ func Rejected(reason string) Verdict

+ type ViewComponent struct

+ func View[Row any](id string, parts ...Part) *ViewComponent[Row]

+ func (v *ViewComponent[Row]) ID() string

+ type ViewEffect struct

+ func DeleteRow[Row any]() ViewEffect[Row]

+ func IgnoreChange[Row any]() ViewEffect[Row]

+ func UpdateRow[Row any](row Row) ViewEffect[Row]

+ type ViewQuery struct

+ Limit uint32

+ Name string

+ Values map[string]string

+ func All() ViewQuery

+ func Named(name string, values map[string]string) ViewQuery

+ type ViewRows interface

+ Ask func(name string, values map[string]string) ([]Row, error)

+ Get func(key string) (Row, bool, error)

+ type WatchEndedError struct

+ Reason string

+ func (e *WatchEndedError) Error() string

+ type WatchEvent struct

+ CaughtUp bool

+ Key string

+ Removed bool

+ Row Row

+ type WatchTarget struct

+ func WatchKey(key string) WatchTarget

+ func WatchQuery(name string, values map[string]string) WatchTarget

+ type WorkflowBuilder struct

+ func WorkflowKeep[S, R any]() WorkflowBuilder[S, R]

+ func WorkflowUpdate[S, R any](s S) WorkflowBuilder[S, R]

+ func (b WorkflowBuilder[S, R]) ThenNoReply() WorkflowEffect[S, R]

+ func (b WorkflowBuilder[S, R]) ThenReply(compute func(S) R) WorkflowEffect[S, R]

+ func (b WorkflowBuilder[S, R]) ThenReplyState() WorkflowEffect[S, R]

+ func (b WorkflowBuilder[S, R]) ThenReplyValue(v R) WorkflowEffect[S, R]

+ func (b WorkflowBuilder[S, R]) ThenTransitionTo(step string, input any) WorkflowBuilder[S, R]

+ type WorkflowComponent struct

+ func Workflow[S any](id string, empty func(workflowID string) S, parts ...Part) *WorkflowComponent[S]

+ func (w *WorkflowComponent[S]) ID() string

+ type WorkflowEffect struct

+ type WorkflowOption struct

+ func StepRecovery(r Recovery) WorkflowOption

+ func StepTimeout(d time.Duration) WorkflowOption