interfaces

type ActivityInfo struct {
	ScheduledTime     time.Time // Time of activity scheduled by a workflow
	Attempt           int32     // Attempt starts from 1, and increased by 1 for every retry if retry policy is specified.
	IsLocalActivity   bool      // Whether the activity is at local activity
	WorkflowExecution WorkflowExecution
}

type ActivityOptions struct {
	StartToCloseTimeout time.Duration
	RetryPolicy         *iwfidl.RetryPolicy
}

type ActivityProvider interface {
	GetLogger(ctx context.Context) UnifiedLogger
	NewApplicationError(errType string, details interface{}) error
	GetActivityInfo(ctx context.Context) ActivityInfo
}

type Future interface {
	Get(ctx UnifiedContext, valuePtr interface{}) error
	IsReady() bool
}

type HandlerOutput struct {
	RpcOutput   *iwfidl.WorkflowRpcResponse
	StatusError *errors.ErrorAndStatus
}

type InvokeRpcActivityOutput struct {
	RpcOutput   *iwfidl.WorkflowWorkerRpcResponse
	StatusError *errors.ErrorAndStatus
}

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

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

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

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

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

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

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

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

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

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

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

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

type ReceiveChannel interface {
	ReceiveAsync(valuePtr interface{}) (ok bool)
	ReceiveBlocking(ctx UnifiedContext, valuePtr interface{}) (ok bool)
}

type TimerProcessor interface {
	Dump() []service.StaleSkipTimerSignal
	SkipTimer(stateExeId string, timerId string, timerIdx int) bool
	RetryStaleSkipTimer() bool
	WaitForTimerFiredOrSkipped(ctx UnifiedContext, stateExeId string, timerIdx int, cancelWaiting *bool) service.InternalTimerStatus
	RemovePendingTimersOfState(stateExeId string)
	AddTimers(stateExeId string, commands []iwfidl.TimerCommand, completedTimerCmds map[int]service.InternalTimerStatus)
	GetTimerInfos() map[string][]*service.TimerInfo
	GetTimerStartedUnixTimestamps() []int64
}

type UnifiedContext interface {
	GetContext() interface{}
}

type UnifiedLogger interface {
	Debug(msg string, keyvals ...interface{})
	Info(msg string, keyvals ...interface{})
	Warn(msg string, keyvals ...interface{})
	Error(msg string, keyvals ...interface{})
}

type UnifiedRpcHandler func(ctx UnifiedContext, input iwfidl.WorkflowRpcRequest) (*HandlerOutput, error)

type UnifiedRpcValidator func(ctx UnifiedContext, input iwfidl.WorkflowRpcRequest) error

type WorkflowExecution struct {
	ID    string
	RunID string
}

type WorkflowInfo struct {
	WorkflowExecution        WorkflowExecution
	WorkflowStartTime        time.Time
	WorkflowExecutionTimeout time.Duration
	FirstRunID               string
	CurrentRunID             string
}

type WorkflowProvider interface {
	NewApplicationError(errType string, details interface{}) error
	IsApplicationError(err error) bool
	GetWorkflowInfo(ctx UnifiedContext) WorkflowInfo
	GetSearchAttributes(
		ctx UnifiedContext, requestedSearchAttributes []iwfidl.SearchAttributeKeyAndType,
	) (map[string]iwfidl.SearchAttribute, error)
	UpsertSearchAttributes(ctx UnifiedContext, attributes map[string]interface{}) error
	UpsertMemo(ctx UnifiedContext, memo map[string]iwfidl.EncodedObject) error
	SetQueryHandler(ctx UnifiedContext, queryType string, handler interface{}) error
	SetRpcUpdateHandler(
		ctx UnifiedContext, updateType string, validator UnifiedRpcValidator, handler UnifiedRpcHandler,
	) error
	ExtendContextWithValue(parent UnifiedContext, key string, val interface{}) UnifiedContext
	GoNamed(ctx UnifiedContext, name string, f func(ctx UnifiedContext))
	GetThreadCount() int
	GetPendingThreadNames() map[string]int
	Await(ctx UnifiedContext, condition func() bool) error
	WithActivityOptions(ctx UnifiedContext, options ActivityOptions) UnifiedContext
	ExecuteActivity(
		valuePtr interface{}, optimizeByLocalActivity bool, ctx UnifiedContext, activity interface{},
		args ...interface{},
	) (err error)
	ExecuteLocalActivity(
		valuePtr interface{}, ctx UnifiedContext, activity interface{}, args ...interface{},
	) (err error)
	Now(ctx UnifiedContext) time.Time
	IsReplaying(ctx UnifiedContext) bool
	Sleep(ctx UnifiedContext, d time.Duration) (err error)
	NewTimer(ctx UnifiedContext, d time.Duration) Future
	GetSignalChannel(ctx UnifiedContext, signalName string) (receiveChannel ReceiveChannel)
	GetContextValue(ctx UnifiedContext, key string) interface{}
	GetVersion(ctx UnifiedContext, changeID string, minSupported, maxSupported int) int
	GetUnhandledSignalNames(ctx UnifiedContext) []string
	GetBackendType() service.BackendType
	GetLogger(ctx UnifiedContext) UnifiedLogger
	NewInterpreterContinueAsNewError(ctx UnifiedContext, input service.InterpreterWorkflowInput) error
}