temporal

Documentation

Index

• func ContextWithTestLogConfig(ctx context.Context, config TestLogConfig) context.Context
• func NewClient(ctx context.Context, logger log.Logger, hostPort string, namespace string) (client.Client, error)
• func NewWorkerLogInterceptor(logger log.Logger, publisher LogPublisher) interceptor.WorkerInterceptor
• func WorkflowContextWithTestLogConfig(ctx workflow.Context, config TestLogConfig) workflow.Context
• type CaseOption
  • func WithCaseExecID(caseExecID test.CaseExecutionID) CaseOption
• type Level
  • func (l Level) SlogLevel() slog.Level
• type LogPublisher
• type Logger
  • func FromLogger(base log.Logger) *Logger
  • func (l *Logger) Debug(msg string, keyvals ...any)
  • func (l *Logger) Error(msg string, keyvals ...any)
  • func (l *Logger) Info(msg string, keyvals ...any)
  • func (l *Logger) Warn(msg string, keyvals ...any)
  • func (l *Logger) With(keyvals ...any) tlog.Logger
• type TestActivityLogger
  • func NewTestActivityLogger(logger log.Logger, pub LogPublisher, testExecID test.TestExecutionID, ...) *TestActivityLogger
  • func (l *TestActivityLogger) Debug(msg string, keyvals ...any)
  • func (l *TestActivityLogger) Error(msg string, keyvals ...any)
  • func (l *TestActivityLogger) Info(msg string, keyvals ...any)
  • func (l *TestActivityLogger) Warn(msg string, keyvals ...any)
• type TestLogActivity
  • func NewTestLogActivity(pub LogPublisher) *TestLogActivity
  • func (t *TestLogActivity) Publish(ctx context.Context, req TestLogRequest) (*TestLogResponse, error)
• type TestLogConfig
  • func TestLogConfigFromContext(ctx context.Context) (TestLogConfig, bool)
  • func TestLogConfigFromWorkflowContext(ctx workflow.Context) (TestLogConfig, bool)
• type TestLogRequest
• type TestLogResponse
• type TestWorkflowLogger
  • func NewTestWorkflowLogger(ctx workflow.Context, logger log.Logger, testExecID test.TestExecutionID) *TestWorkflowLogger
  • func (l *TestWorkflowLogger) Debug(msg string, keyvals ...any)
  • func (l *TestWorkflowLogger) Error(msg string, keyvals ...any)
  • func (l *TestWorkflowLogger) Info(msg string, keyvals ...any)
  • func (l *TestWorkflowLogger) Warn(msg string, keyvals ...any)

Functions

func ContextWithTestLogConfig

func ContextWithTestLogConfig(ctx context.Context, config TestLogConfig) context.Context

func NewClient

func NewClient(ctx context.Context, logger log.Logger, hostPort string, namespace string) (client.Client, error)

func NewWorkerLogInterceptor

func NewWorkerLogInterceptor(logger log.Logger, publisher LogPublisher) interceptor.WorkerInterceptor

func WorkflowContextWithTestLogConfig

func WorkflowContextWithTestLogConfig(ctx workflow.Context, config TestLogConfig) workflow.Context

Types

type CaseOption

type CaseOption func(logger *TestActivityLogger)

func WithCaseExecID

func WithCaseExecID(caseExecID test.CaseExecutionID) CaseOption

type Level

type Level string

const (
	LevelDebug Level = "DEBUG"
	LevelInfo  Level = "INFO"
	LevelWarn  Level = "WARN"
	LevelError Level = "ERROR"
)

func (Level) SlogLevel

func (l Level) SlogLevel() slog.Level

type LogPublisher

type LogPublisher interface {
	PublishLog(
		ctx context.Context,
		req *connect.Request[testsv1.PublishLogRequest],
	) (*connect.Response[testsv1.PublishLogResponse], error)
}

type Logger

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

func FromLogger

func FromLogger(base log.Logger) *Logger

func (*Logger) Debug

func (l *Logger) Debug(msg string, keyvals ...any)

func (*Logger) Error

func (l *Logger) Error(msg string, keyvals ...any)

func (*Logger) Info

func (l *Logger) Info(msg string, keyvals ...any)

func (*Logger) Warn

func (l *Logger) Warn(msg string, keyvals ...any)

func (*Logger) With

func (l *Logger) With(keyvals ...any) tlog.Logger

With returns new logger the prepend every log entry with keyvals.

type TestActivityLogger

type TestActivityLogger struct {
	*Logger
	// contains filtered or unexported fields
}

func NewTestActivityLogger

func NewTestActivityLogger(logger log.Logger, pub LogPublisher, testExecID test.TestExecutionID, opts ...CaseOption) *TestActivityLogger

func (*TestActivityLogger) Debug

func (l *TestActivityLogger) Debug(msg string, keyvals ...any)

func (*TestActivityLogger) Error

func (l *TestActivityLogger) Error(msg string, keyvals ...any)

func (*TestActivityLogger) Info

func (l *TestActivityLogger) Info(msg string, keyvals ...any)

func (*TestActivityLogger) Warn

func (l *TestActivityLogger) Warn(msg string, keyvals ...any)

type TestLogActivity

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

TestLogActivity is used to publish test logs from a workflow. This must be executed as a local activity to minimize the number of workflow events.

func NewTestLogActivity

func NewTestLogActivity(pub LogPublisher) *TestLogActivity

func (*TestLogActivity) Publish

func (t *TestLogActivity) Publish(ctx context.Context, req TestLogRequest) (*TestLogResponse, error)

type TestLogConfig

type TestLogConfig struct {
	TestExecID test.TestExecutionID
	CaseExecID *test.CaseExecutionID
}

func TestLogConfigFromContext

func TestLogConfigFromContext(ctx context.Context) (TestLogConfig, bool)

func TestLogConfigFromWorkflowContext

func TestLogConfigFromWorkflowContext(ctx workflow.Context) (TestLogConfig, bool)

type TestLogRequest

type TestLogRequest struct {
	Level           Level
	Message         string
	KeyVals         []any
	GlobalKeyVals   string
	TestExecutionID test.TestExecutionID
}

type TestLogResponse

type TestLogResponse struct {
	LogID uuid.UUID
}

type TestWorkflowLogger

type TestWorkflowLogger struct {
	*Logger
	// contains filtered or unexported fields
}

func NewTestWorkflowLogger

func NewTestWorkflowLogger(ctx workflow.Context, logger log.Logger, testExecID test.TestExecutionID) *TestWorkflowLogger

func (*TestWorkflowLogger) Debug

func (l *TestWorkflowLogger) Debug(msg string, keyvals ...any)

func (*TestWorkflowLogger) Error

func (l *TestWorkflowLogger) Error(msg string, keyvals ...any)

func (*TestWorkflowLogger) Info

func (l *TestWorkflowLogger) Info(msg string, keyvals ...any)

func (*TestWorkflowLogger) Warn

func (l *TestWorkflowLogger) Warn(msg string, keyvals ...any)