keeltemporal

Jun 21, 2022

Changes in this version

+ const ActivityErrorType

+ func AsApplicationError(err error) *temporal.ApplicationError

+ func AsCanceledError(err error) *temporal.CanceledError

+ func AsPanicError(err error) *temporal.PanicError

+ func AsTimeoutError(err error) *temporal.TimeoutError

+ func IsActivityError(err error) bool

+ func IsApplicationError(err error, handler func(applicationErr *temporal.ApplicationError)) bool

+ func IsCanceledError(err error, handler func(canceledErr *temporal.CanceledError)) bool

+ func IsErrorType(err error, errorType string) bool

+ func IsPanicError(err error, handler func(panicErr *temporal.PanicError)) bool

+ func IsTimeoutError(err error, handler func(timeoutErr *temporal.TimeoutError)) bool

+ func NewActivityError(msg string, err error, details ...interface{}) error

Jun 20, 2022

Changes in this version

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

+ type ActivityCanceledError struct

+ func NewActivityCanceledError(err error) *ActivityCanceledError

+ type ActivityFailedError struct

+ func NewActivityFailedError(err error) *ActivityFailedError

+ type ActivityUnprocessableError struct

+ func NewActivityUnprocessableError(err error) *ActivityUnprocessableError

Jun 2, 2022

Changes in this version

+ func GetActivityLogger(ctx context.Context) tlog.Logger

+ func GetWorkflowLogger(ctx workflow.Context) tlog.Logger

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

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

+ type ActivityOption func(options *workflow.ActivityOptions)

+ 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

Mar 10, 2022

Changes in this version

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

+ type ClientOption func(o *ClientOptions)

+ func ClientWithNamespace(v string) ClientOption

+ func ClientWithOtelEnabled(v bool) ClientOption

+ func ClientWithRegisterNamespace(v *workflowservice.RegisterNamespaceRequest) ClientOption

+ type ClientOptions struct

+ Logger *zap.Logger

+ Namespace string

+ OtelEnabled bool

+ RegisterNamespace *workflowservice.RegisterNamespaceRequest

+ func DefaultClientOptions() ClientOptions

Mar 8, 2022

Changes in this version

+ 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 New(ctx context.Context, endpoint string, opts ...Option) (client.Client, error)

+ func NewLogger(l *zap.Logger) *logger

+ func NewMetricsHandler(meter metric.MeterMust) client.MetricsHandler

+ func NewService(name string, w worker.Worker) *service

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

+ type Option func(o *Options)

+ func WithNamespace(v *workflowservice.RegisterNamespaceRequest) Option

+ func WithOtelEnabled(v bool) Option

+ type Options struct

+ Logger *zap.Logger

+ Namespace *workflowservice.RegisterNamespaceRequest

+ OtelEnabled bool

+ func DefaultOptions() Options