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 Info(ctx workflow.Context, msg string, fields ...zap.Field)
• 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
• 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 Info

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

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

Types

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