Versions in this module Expand all Collapse all v0 v0.3.0 Nov 10, 2026 Changes in this version + var ErrAcceptanceUnknown = errors.New("Temporal workflow acceptance is unresolved") + var ErrAdapterUnavailable = errors.New("Temporal adapter temporarily unavailable") + func Client(q *queue.Queue) (client.Client, error) + func NewWithConfig(cfg Config, opts ...queue.Option) (*queue.Queue, error) + func NewWorkflowReplayer(q *queue.Queue) (result worker.WorkflowReplayer, err error) + func RegistrationFingerprint(q *queue.Queue) (string, error) + type BoundedContextPropagator interface + MaxDecodedBytes func() int + type BoundedDataConverter interface + DecodingLimits func() SerializationLimits + MaxEncodedOverhead func() int + type ClientBinding struct + func NewClientBinding(options client.Options, limits SerializationLimits) (binding *ClientBinding, err error) + func (b *ClientBinding) Client() client.Client + func (b *ClientBinding) Close(ctx context.Context) error + func (b *ClientBinding) Namespace() string + type Config struct + ActivityTaskQueue string + ActivityWorkerOptions worker.Options + Binding *ClientBinding + ClientOptions client.Options + DefaultActivityTimeout time.Duration + Register func(worker.Registry) error + SerializationLimits SerializationLimits + ShutdownTimeout time.Duration + WorkerOptions worker.Options + WorkflowTaskQueue string + WorkflowWorkerOptions worker.Options + type ProtectedDataConverter interface + ValidateProtectedPayload func(*common.Payload) error + type ProtectedFailureConverter interface + ProtectsFailureDetails func() bool + func NewProtectedFailureConverter(dc ProtectedDataConverter) (result ProtectedFailureConverter, err error) + type Routing struct + ActivityTaskQueue string + WorkflowTaskQueue string + func WorkerRouting(q *queue.Queue) (Routing, error) + type SerializationLimits struct + MaxPayloadBytes int + MaxPayloads int + MaxTotalBytes int + func DefaultSerializationLimits() SerializationLimits
Go to main page