keeltemporal

package

v0.13.1 Latest Latest Go to latest Published: Feb 23, 2023 License: MIT Imports: 26 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/foomo/keel

Links

Open Source Insights

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
- func ClientWithNamespace(v string) ClientOption
- func ClientWithOtelEnabled(v bool) ClientOption
- func ClientWithRegisterNamespace(v *workflowservice.RegisterNamespaceRequest) ClientOption
type ClientOptions
- func DefaultClientOptions() 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 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 ¶ added in v0.10.12

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

func GetWorkflowLogger ¶ added in v0.10.12

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

func Info ¶

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

func IsActivityError ¶ added in v0.10.19

func IsActivityError(err error) bool

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 IsErrorType(err error, errorType string) bool

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 LoggerWith ¶ added in v0.10.12

func LoggerWith(l tlog.Logger, fields ...zap.Field) tlog.Logger

func NewActivityError ¶ added in v0.10.19

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

func NewClient ¶ added in v0.8.2

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

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 ¶ added in v0.10.18

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

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 ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL