temporal

Documentation

Index

• func FirstHistoryEvent(ctx context.Context, cc temporalsdk_client.Client, ...) (event *temporalapi_history.HistoryEvent, err error)
• func GetLogger(ctx context.Context) logr.Logger
• func HistoryEvents(ctx context.Context, cc temporalsdk_client.Client, ...) ([]*temporalapi_history.HistoryEvent, error)
• func Logger(logger logr.Logger) temporalsdk_log.Logger
• func NewLoggerInterceptor(logger logr.Logger) *workerInterceptor
• func NewNonRetryableError(err error) error
• func NonRetryableError(err error) bool
• func SetDefaults(v *viper.Viper)
• type Config

Functions

func FirstHistoryEvent

func FirstHistoryEvent(ctx context.Context, cc temporalsdk_client.Client, exec *temporalapi_common.WorkflowExecution) (event *temporalapi_history.HistoryEvent, err error)

func GetLogger

func GetLogger(ctx context.Context) logr.Logger

func HistoryEvents

func HistoryEvents(ctx context.Context, cc temporalsdk_client.Client, exec *temporalapi_common.WorkflowExecution, poll bool) ([]*temporalapi_history.HistoryEvent, error)

func Logger

func Logger(logger logr.Logger) temporalsdk_log.Logger

Logger returns a logger for the Temporal Go SDK.

func NewLoggerInterceptor

func NewLoggerInterceptor(logger logr.Logger) *workerInterceptor

NewWorkerInterceptor returns an interceptor that makes the application logger available to activities via context.

func NewNonRetryableError

func NewNonRetryableError(err error) error

func NonRetryableError

func NonRetryableError(err error) bool

func SetDefaults

func SetDefaults(v *viper.Viper)

Types

type Config

type Config struct {
	Address   string
	Namespace string
	TaskQueue string
}