workflow

type ActivityOptions struct {
	RetryOptions RetryOptions
}

type CancelFunc = sync.CancelFunc

type Channel[T any] interface {
	Send(ctx Context, v T)

	SendNonblocking(v T) (ok bool)

	Receive(ctx Context) (v T, ok bool)

	ReceiveNonBlocking() (v T, ok bool)

	Close()
}

type Context = sync.Context

type Future[T any] interface {
	// Get returns the value if set, blocks otherwise
	Get(ctx Context) (T, error)
}

type Instance = core.WorkflowInstance

type Metadata = core.WorkflowMetadata

type RetryOptions struct {
	// Maximum number of times to retry
	MaxAttempts int

	// Time to wait before first retry
	FirstRetryInterval time.Duration

	// Maximum delay for any individual retry attempt
	MaxRetryInterval time.Duration

	// Coeffecient for calculation the next retry delay
	BackoffCoefficient float64

	// Timeout after which retries are aborted
	RetryTimeout time.Duration
}

type SelectCase = sync.SelectCase

type Span interface {
	End()
}

type SubWorkflowOptions struct {
	InstanceID string

	RetryOptions RetryOptions
}

type WaitGroup = sync.WaitGroup

type Workflow = interface{}

type WorkflowTracer interface {
	Start(ctx Context, name string, opts ...trace.SpanStartOption) (Context, Span)
}