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

invocation

package

Go to main page

Versions in this module

v0

v0.4.0

Sep 2, 2026

Changes in this version

+ const HTTPResolverID

+ const HeaderRequestID

+ const HeaderVerb

+ type Descriptor struct

+ func NewDescriptor(spec DescriptorSpec) (Descriptor, error)

+ func ParseDescriptor(data []byte) (Descriptor, error)

+ func (descriptor *Descriptor) UnmarshalJSON(data []byte) error

+ func (descriptor Descriptor) CanonicalJSON() ([]byte, error)

+ func (descriptor Descriptor) Headers() map[string]string

+ func (descriptor Descriptor) MarshalJSON() ([]byte, error)

+ func (descriptor Descriptor) Reference() string

+ func (descriptor Descriptor) ResolverID() string

+ func (descriptor Descriptor) Settings() map[string]string

+ func (descriptor Descriptor) Type() DescriptorType

+ type DescriptorKV struct

+ Name string

+ Value string

+ type DescriptorSpec struct

+ Headers map[string]string

+ Reference string

+ ResolverID string

+ Settings map[string]string

+ Type DescriptorType

+ type DescriptorType string

+ const DescriptorEmbedded

+ const DescriptorGRPC

+ const DescriptorHTTP

+ const DescriptorOCI

+ const DescriptorStream

type HTTPExecutor

+ func (executor *HTTPExecutor) InvocationResolverDescriptor() (Descriptor, error)

+ type HTTPResolver struct

+ func (HTTPResolver) Resolve(_ context.Context, descriptor Descriptor) (Executor, io.Closer, error)

+ type Registry struct

+ func NewRegistry(registrations []ResolverRegistration) (*Registry, error)

+ func (registry *Registry) Resolve(ctx context.Context, descriptor Descriptor) (Executor, io.Closer, error)

+ type Resolver interface

+ Resolve func(context.Context, Descriptor) (Executor, io.Closer, error)

+ type ResolverFunc func(context.Context, Descriptor) (Executor, io.Closer, error)

+ func (function ResolverFunc) Resolve(ctx context.Context, descriptor Descriptor) (Executor, io.Closer, error)

+ type ResolverRegistration struct

+ ID string

+ Resolver Resolver

v0.3.0

Sep 1, 2026

Changes in this version

+ const HeaderArgumentHash

+ const HeaderAttempt

+ const HeaderContractHash

+ const HeaderDeadline

+ const HeaderDirection

+ const HeaderEffectID

+ const HeaderExecutionID

+ const HeaderFencingGrants

+ const HeaderIdempotencyKey

+ const HeaderOutcome

+ const HeaderSagaID

+ func ValidateOutcome(outcome Outcome) error

+ type Context struct

+ Deadline time.Time

+ ExecutionID string

+ FencingGrants []FencingGrant

+ RequestID string

+ Saga Saga

+ type Direction string

+ const DirectionCompensation

+ const DirectionForward

+ type Executor interface

+ Invoke func(context.Context, Request) Outcome

+ type FencingGrant struct

+ Authority string

+ Resource string

+ Token uint64

+ type FencingStatus string

+ const FencingAcknowledged

+ const FencingLocalLockOnly

+ const FencingNotRequested

+ const FencingPropagated

+ const FencingStaleRejected

+ type HTTPExecutor struct

+ Client *http.Client

+ Headers map[string]string

+ MaxResponseBytes int64

+ Method string

+ URL string

+ func NewHTTPExecutor(executor HTTPExecutor) (*HTTPExecutor, error)

+ func (executor *HTTPExecutor) Invoke(ctx context.Context, request Request) Outcome

+ type Outcome struct

+ Class OutcomeClass

+ Err error

+ Result any

+ type OutcomeClass string

+ const OutcomePermanentFailure

+ const OutcomeRetryableKnownNotCommitted

+ const OutcomeStaleFence

+ const OutcomeSuccess

+ const OutcomeUnknown

+ type Request struct

+ ArgumentHash string

+ Arguments map[string]any

+ ContractHash string

+ Metadata Context

+ Verb string

+ type ResolverDescriptorProvider interface

+ InvocationResolverDescriptor func() any

+ type Saga struct

+ Attempt uint64

+ Direction Direction

+ EffectID string

+ IdempotencyKey string

+ SagaID string