keeltemporal

Documentation

Index

• func Debug(l tlog.Logger, msg string, fields ...zap.Field)
• func Error(l tlog.Logger, err error, msg string, fields ...zap.Field)
• func GetActivityLogger(ctx context.Context, fields ...zap.Field) tlog.Logger
• func GetWorkflowLogger(ctx workflow.Context, fields ...zap.Field) tlog.Logger
• func Info(l tlog.Logger, msg string, fields ...zap.Field)
• func LoggerWith(l 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 Warn(l tlog.Logger, msg string, fields ...zap.Field)
• func WithActivityOptions(ctx workflow.Context, opts ...ActivityOption) workflow.Context
• type ActivityCanceledError
  • func NewActivityCanceledError(err error) *ActivityCanceledError
• type ActivityFailedError
  • func NewActivityFailedError(err error) *ActivityFailedError
• 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 ActivityUnprocessableError
  • func NewActivityUnprocessableError(err error) *ActivityUnprocessableError
• 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(l tlog.Logger, msg string, fields ...zap.Field)

func Error

func Error(l tlog.Logger, err error, msg string, fields ...zap.Field)

func GetActivityLogger

func GetActivityLogger(ctx context.Context, fields ...zap.Field) tlog.Logger

func GetWorkflowLogger

func GetWorkflowLogger(ctx workflow.Context, fields ...zap.Field) tlog.Logger

func Info

func Info(l tlog.Logger, msg string, fields ...zap.Field)

func LoggerWith

func LoggerWith(l 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 Warn

func Warn(l tlog.Logger, msg string, fields ...zap.Field)

func WithActivityOptions

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

Types

type ActivityCanceledError

type ActivityCanceledError struct {
	// contains filtered or unexported fields
}

ActivityCanceledError indicated that the activity is canceled on purpose

func NewActivityCanceledError

func NewActivityCanceledError(err error) *ActivityCanceledError

type ActivityFailedError

type ActivityFailedError struct {
	// contains filtered or unexported fields
}

ActivityFailedError indicated that sth in the activity failed

func NewActivityFailedError

func NewActivityFailedError(err error) *ActivityFailedError

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 ActivityUnprocessableError

type ActivityUnprocessableError struct {
	// contains filtered or unexported fields
}

ActivityUnprocessableError indicates that the activity is not

func NewActivityUnprocessableError

func NewActivityUnprocessableError(err error) *ActivityUnprocessableError

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