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
• type AutoHeartbeat
  • func StartAutoHeartbeat(ctx context.Context) *AutoHeartbeat
  • func (m *AutoHeartbeat) Stop()

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

Types

type AutoHeartbeat

type AutoHeartbeat struct {
	// contains filtered or unexported fields
}

func StartAutoHeartbeat

func StartAutoHeartbeat(ctx context.Context) *AutoHeartbeat

StartAutoHeartbeat is an auto-heartbeat helper that chooses the heartbeat frequency based on the activity hearbeat timeout configuration.

Temporal is planning to provide auto-heartbeating capabilities in the future, see https://github.com/temporalio/features/issues/229 for more.

func (*AutoHeartbeat) Stop

func (m *AutoHeartbeat) Stop()