keeltemporal

Documentation

Index

• func Debug(ctx workflow.Context, msg string, fields ...zap.Field)
• func Error(ctx workflow.Context, err error, msg string, fields ...zap.Field)
• func GetActivityLogger(ctx context.Context) tlog.Logger
• func GetWorkflowLogger(ctx workflow.Context) tlog.Logger
• func Info(ctx workflow.Context, msg string, fields ...zap.Field)
• func LoggerWith(logger tlog.Logger, fields ...zap.Field) tlog.Logger
• func NewClient(ctx context.Context, endpoint string, opts ...ClientOption) (client.Client, error)
• func NewLogger(l *zap.Logger) *logger
• func NewMetricsHandler(meter metric.Meter) client.MetricsHandler
• func NewService(l *zap.Logger, name string, w worker.Worker) *service
• func NewTestService(name string, w worker.Worker) *test
• func WithActivityOptions(ctx workflow.Context, opts ...ActivityOption) workflow.Context
• type ActivityOption
  • func ActivityOptionsWithActivityID(v string) ActivityOption
  • func ActivityOptionsWithHeartbeatTimeout(v time.Duration) ActivityOption
  • func ActivityOptionsWithRetryPolicy(v *temporal.RetryPolicy) ActivityOption
  • func ActivityOptionsWithScheduleToCloseTimeout(v time.Duration) ActivityOption
  • func ActivityOptionsWithScheduleToStartTimeout(v time.Duration) ActivityOption
  • func ActivityOptionsWithStartToCloseTimeout(v time.Duration) ActivityOption
  • func ActivityOptionsWithTaskQueue(v string) ActivityOption
  • func ActivityOptionsWithWaitForCancellation(v bool) ActivityOption
• type ClientOption
  • func ClientWithNamespace(v string) ClientOption
  • func ClientWithOtelEnabled(v bool) ClientOption
  • func ClientWithRegisterNamespace(v *workflowservice.RegisterNamespaceRequest) ClientOption
• type ClientOptions
  • func DefaultClientOptions() ClientOptions

Functions

func Debug

func Debug(ctx workflow.Context, msg string, fields ...zap.Field)

func Error

func Error(ctx workflow.Context, err error, msg string, fields ...zap.Field)

func GetActivityLogger

func GetActivityLogger(ctx context.Context) tlog.Logger

func GetWorkflowLogger

func GetWorkflowLogger(ctx workflow.Context) tlog.Logger

func Info

func Info(ctx workflow.Context, msg string, fields ...zap.Field)

func LoggerWith

func LoggerWith(logger tlog.Logger, fields ...zap.Field) tlog.Logger

func NewClient

func NewClient(ctx context.Context, endpoint string, opts ...ClientOption) (client.Client, error)

func NewLogger

func NewLogger(l *zap.Logger) *logger

func NewMetricsHandler

func NewMetricsHandler(meter metric.Meter) client.MetricsHandler

scope, _ := tally.NewRootScope(opts, time.Second)

func NewService

func NewService(l *zap.Logger, name string, w worker.Worker) *service

func NewTestService

func NewTestService(name string, w worker.Worker) *test

func WithActivityOptions

func WithActivityOptions(ctx workflow.Context, opts ...ActivityOption) workflow.Context

Types

type ActivityOption

type ActivityOption func(options *workflow.ActivityOptions)

func ActivityOptionsWithActivityID

func ActivityOptionsWithActivityID(v string) ActivityOption

func ActivityOptionsWithHeartbeatTimeout

func ActivityOptionsWithHeartbeatTimeout(v time.Duration) ActivityOption

func ActivityOptionsWithRetryPolicy

func ActivityOptionsWithRetryPolicy(v *temporal.RetryPolicy) ActivityOption

func ActivityOptionsWithScheduleToCloseTimeout

func ActivityOptionsWithScheduleToCloseTimeout(v time.Duration) ActivityOption

func ActivityOptionsWithScheduleToStartTimeout

func ActivityOptionsWithScheduleToStartTimeout(v time.Duration) ActivityOption

func ActivityOptionsWithStartToCloseTimeout

func ActivityOptionsWithStartToCloseTimeout(v time.Duration) ActivityOption

func ActivityOptionsWithTaskQueue

func ActivityOptionsWithTaskQueue(v string) ActivityOption

func ActivityOptionsWithWaitForCancellation

func ActivityOptionsWithWaitForCancellation(v bool) ActivityOption

type ClientOption

type ClientOption func(o *ClientOptions)

func ClientWithNamespace

func ClientWithNamespace(v string) ClientOption

func ClientWithOtelEnabled

func ClientWithOtelEnabled(v bool) ClientOption

func ClientWithRegisterNamespace

func ClientWithRegisterNamespace(v *workflowservice.RegisterNamespaceRequest) ClientOption

type ClientOptions

type ClientOptions struct {
	Logger            *zap.Logger
	Namespace         string
	RegisterNamespace *workflowservice.RegisterNamespaceRequest
	OtelEnabled       bool
}

func DefaultClientOptions

func DefaultClientOptions() ClientOptions