Versions in this module Expand all Collapse all v3 v3.0.0 Jan 10, 2023 Changes in this version + var HeaderContextKey = &ContextKey + func ActivityHeadersFromCtx(ctx context.Context) *commonpb.Header + type Codec interface + Decode func(pld *payload.Payload, msg *[]*internal.Message) error + DecodeWorkerInfo func(p *payload.Payload, wi *[]*internal.WorkerInfo) error + Encode func(ctx *internal.Context, p *payload.Payload, msg ...*internal.Message) error + type Configurer interface + GracefulTimeout func() time.Duration + Has func(name string) bool + RRVersion func() string + UnmarshalKey func(name string, out any) error + type ContextKey struct + func (ck *ContextKey) String() string + type Informer interface + Workers func() []*process.State + type Pool interface + Exec func(ctx context.Context, p *payload.Payload) (*payload.Payload, error) + QueueSize func() uint64 + Reset func(ctx context.Context) error + Workers func() (workers []*worker.Process) + type Server interface + NewPool func(ctx context.Context, cfg *pool.Config, env map[string]string, _ *zap.Logger) (*staticPool.Pool, error) Other modules containing this package github.com/temporalio/roadrunner-temporal/v2 github.com/temporalio/roadrunner-temporal/v4 github.com/temporalio/roadrunner-temporal/v5
Go to main page