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 ...any) 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 ¶
func AsApplicationError(err error) *temporal.ApplicationError
func AsCanceledError ¶
func AsCanceledError(err error) *temporal.CanceledError
func AsPanicError ¶
func AsPanicError(err error) *temporal.PanicError
func AsTimeoutError ¶
func AsTimeoutError(err error) *temporal.TimeoutError
func GetActivityLogger ¶
func GetWorkflowLogger ¶
func IsActivityError ¶
func IsApplicationError ¶
func IsApplicationError(err error, handler func(applicationErr *temporal.ApplicationError)) bool
func IsCanceledError ¶
func IsCanceledError(err error, handler func(canceledErr *temporal.CanceledError)) bool
func IsErrorType ¶
func IsPanicError ¶
func IsPanicError(err error, handler func(panicErr *temporal.PanicError)) bool
func IsTimeoutError ¶
func IsTimeoutError(err error, handler func(timeoutErr *temporal.TimeoutError)) bool
func NewMetricsHandler ¶
func NewMetricsHandler(meter metric.Meter) client.MetricsHandler
func NewTestService ¶
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
Source Files
Click to show internal directories.
Click to hide internal directories.