Documentation
¶
Index ¶
- Constants
- 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 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 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 LoggerWith(l tlog.Logger, fields ...zap.Field) tlog.Logger
- func NewActivityError(msg string, err error, details ...interface{}) error
- 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 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
- type ClientOptions
Constants ¶
View Source
const ActivityErrorType = "keeltemporal.ActivityError"
Variables ¶
This section is empty.
Functions ¶
func AsApplicationError ¶ added in v0.10.19
func AsApplicationError(err error) *temporal.ApplicationError
func AsCanceledError ¶ added in v0.10.19
func AsCanceledError(err error) *temporal.CanceledError
func AsPanicError ¶ added in v0.10.19
func AsPanicError(err error) *temporal.PanicError
func AsTimeoutError ¶ added in v0.10.19
func AsTimeoutError(err error) *temporal.TimeoutError
func GetActivityLogger ¶ added in v0.10.12
func GetWorkflowLogger ¶ added in v0.10.12
func IsActivityError ¶ added in v0.10.19
func IsApplicationError ¶ added in v0.10.19
func IsApplicationError(err error, handler func(applicationErr *temporal.ApplicationError)) bool
func IsCanceledError ¶ added in v0.10.19
func IsCanceledError(err error, handler func(canceledErr *temporal.CanceledError)) bool
func IsErrorType ¶ added in v0.10.19
func IsPanicError ¶ added in v0.10.19
func IsPanicError(err error, handler func(panicErr *temporal.PanicError)) bool
func IsTimeoutError ¶ added in v0.10.19
func IsTimeoutError(err error, handler func(timeoutErr *temporal.TimeoutError)) bool
func NewActivityError ¶ added in v0.10.19
func NewMetricsHandler ¶
func NewMetricsHandler(meter metric.Meter) client.MetricsHandler
func NewTestService ¶
func WithActivityOptions ¶ added in v0.10.12
func WithActivityOptions(ctx workflow.Context, opts ...ActivityOption) workflow.Context
Types ¶
type ActivityOption ¶ added in v0.10.12
type ActivityOption func(options *workflow.ActivityOptions)
func ActivityOptionsWithActivityID ¶ added in v0.10.12
func ActivityOptionsWithActivityID(v string) ActivityOption
func ActivityOptionsWithHeartbeatTimeout ¶ added in v0.10.12
func ActivityOptionsWithHeartbeatTimeout(v time.Duration) ActivityOption
func ActivityOptionsWithRetryPolicy ¶ added in v0.10.12
func ActivityOptionsWithRetryPolicy(v *temporal.RetryPolicy) ActivityOption
func ActivityOptionsWithScheduleToCloseTimeout ¶ added in v0.10.12
func ActivityOptionsWithScheduleToCloseTimeout(v time.Duration) ActivityOption
func ActivityOptionsWithScheduleToStartTimeout ¶ added in v0.10.12
func ActivityOptionsWithScheduleToStartTimeout(v time.Duration) ActivityOption
func ActivityOptionsWithStartToCloseTimeout ¶ added in v0.10.12
func ActivityOptionsWithStartToCloseTimeout(v time.Duration) ActivityOption
func ActivityOptionsWithTaskQueue ¶ added in v0.10.12
func ActivityOptionsWithTaskQueue(v string) ActivityOption
func ActivityOptionsWithWaitForCancellation ¶ added in v0.10.12
func ActivityOptionsWithWaitForCancellation(v bool) ActivityOption
type ClientOption ¶ added in v0.8.2
type ClientOption func(o *ClientOptions)
func ClientWithNamespace ¶ added in v0.8.2
func ClientWithNamespace(v string) ClientOption
func ClientWithOtelEnabled ¶ added in v0.8.2
func ClientWithOtelEnabled(v bool) ClientOption
func ClientWithRegisterNamespace ¶ added in v0.8.2
func ClientWithRegisterNamespace(v *workflowservice.RegisterNamespaceRequest) ClientOption
type ClientOptions ¶ added in v0.8.2
type ClientOptions struct {
Logger *zap.Logger
Namespace string
RegisterNamespace *workflowservice.RegisterNamespaceRequest
OtelEnabled bool
}
func DefaultClientOptions ¶ added in v0.8.2
func DefaultClientOptions() ClientOptions
Source Files
Click to show internal directories.
Click to hide internal directories.