interpreter

Documentation

Index

• func InterpreterImpl(ctx UnifiedContext, provider WorkflowProvider, ...) (*service.InterpreterWorkflowOutput, error)
• func RegisterActivityProvider(backendType service.BackendType, provider ActivityProvider)
• func StateDecide(ctx context.Context, backendType service.BackendType, ...) (*iwfidl.WorkflowStateDecideResponse, error)
• func StateStart(ctx context.Context, backendType service.BackendType, ...) (*iwfidl.WorkflowStateStartResponse, error)
• type ActivityLogger
• type ActivityOptions
• type ActivityProvider
• type Future
• type InterStateChannel
  • func NewInterStateChannel() *InterStateChannel
  • func (i *InterStateChannel) HasData(channelName string) bool
  • func (i *InterStateChannel) ProcessPublishing(publishes []iwfidl.InterStateChannelPublishing)
  • func (i *InterStateChannel) Retrieve(channelName string) *iwfidl.EncodedObject
• type PersistenceManager
  • func NewPersistenceManager(searchAttributeUpserter func(attributes map[string]interface{}) error) *PersistenceManager
  • func (am *PersistenceManager) GetAllDataObjects() []iwfidl.KeyValue
  • func (am *PersistenceManager) GetAllSearchAttributes() []iwfidl.SearchAttribute
  • func (am *PersistenceManager) GetDataObjectsByKey(request service.GetDataObjectsQueryRequest) service.GetDataObjectsQueryResponse
  • func (am *PersistenceManager) LoadDataObjects(stateOptions *iwfidl.WorkflowStateOptions) []iwfidl.KeyValue
  • func (am *PersistenceManager) LoadSearchAttributes(stateOptions *iwfidl.WorkflowStateOptions) []iwfidl.SearchAttribute
  • func (am *PersistenceManager) ProcessUpsertDataObject(attributes []iwfidl.KeyValue) error
  • func (am *PersistenceManager) ProcessUpsertSearchAttribute(attributes []iwfidl.SearchAttribute) error
• type ReceiveChannel
• type StateExecutionIdManager
  • func NewStateExecutionIdManager() *StateExecutionIdManager
  • func (sm *StateExecutionIdManager) IncAndGetNextExecutionId(stateId string) string
• type UnifiedContext
  • func NewUnifiedContext(ctx interface{}) UnifiedContext
• type WorkflowExecution
• type WorkflowInfo
• type WorkflowProvider

Functions

func InterpreterImpl

func InterpreterImpl(ctx UnifiedContext, provider WorkflowProvider, input service.InterpreterWorkflowInput) (*service.InterpreterWorkflowOutput, error)

func RegisterActivityProvider

func RegisterActivityProvider(backendType service.BackendType, provider ActivityProvider)

func StateDecide

func StateDecide(ctx context.Context, backendType service.BackendType, input service.StateDecideActivityInput) (*iwfidl.WorkflowStateDecideResponse, error)

func StateStart

func StateStart(ctx context.Context, backendType service.BackendType, input service.StateStartActivityInput) (*iwfidl.WorkflowStateStartResponse, error)

Types

type ActivityLogger

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

type ActivityOptions

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

type ActivityProvider

type ActivityProvider interface {
	GetLogger(ctx context.Context) ActivityLogger
	NewApplicationError(message, errType string, details ...interface{}) error
}

type Future

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

type InterStateChannel

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

func NewInterStateChannel

func NewInterStateChannel() *InterStateChannel

func (*InterStateChannel) HasData

func (i *InterStateChannel) HasData(channelName string) bool

func (*InterStateChannel) ProcessPublishing

func (i *InterStateChannel) ProcessPublishing(publishes []iwfidl.InterStateChannelPublishing)

func (*InterStateChannel) Retrieve

func (i *InterStateChannel) Retrieve(channelName string) *iwfidl.EncodedObject

type PersistenceManager

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

func NewPersistenceManager

func NewPersistenceManager(searchAttributeUpserter func(attributes map[string]interface{}) error) *PersistenceManager

func (*PersistenceManager) GetAllDataObjects

func (am *PersistenceManager) GetAllDataObjects() []iwfidl.KeyValue

func (*PersistenceManager) GetAllSearchAttributes

func (am *PersistenceManager) GetAllSearchAttributes() []iwfidl.SearchAttribute

func (*PersistenceManager) GetDataObjectsByKey

func (am *PersistenceManager) GetDataObjectsByKey(request service.GetDataObjectsQueryRequest) service.GetDataObjectsQueryResponse

func (*PersistenceManager) LoadDataObjects

func (am *PersistenceManager) LoadDataObjects(stateOptions *iwfidl.WorkflowStateOptions) []iwfidl.KeyValue

func (*PersistenceManager) LoadSearchAttributes

func (am *PersistenceManager) LoadSearchAttributes(stateOptions *iwfidl.WorkflowStateOptions) []iwfidl.SearchAttribute

func (*PersistenceManager) ProcessUpsertDataObject

func (am *PersistenceManager) ProcessUpsertDataObject(attributes []iwfidl.KeyValue) error

func (*PersistenceManager) ProcessUpsertSearchAttribute

func (am *PersistenceManager) ProcessUpsertSearchAttribute(attributes []iwfidl.SearchAttribute) error

type ReceiveChannel

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

type StateExecutionIdManager

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

func NewStateExecutionIdManager

func NewStateExecutionIdManager() *StateExecutionIdManager

func (*StateExecutionIdManager) IncAndGetNextExecutionId

func (sm *StateExecutionIdManager) IncAndGetNextExecutionId(stateId string) string

type UnifiedContext

type UnifiedContext interface {
	GetContext() interface{}
}

func NewUnifiedContext

func NewUnifiedContext(ctx interface{}) UnifiedContext

type WorkflowExecution

type WorkflowExecution struct {
	ID    string
	RunID string
}

WorkflowExecution details.

type WorkflowInfo

type WorkflowInfo struct {
	WorkflowExecution WorkflowExecution
	WorkflowStartTime time.Time
}

WorkflowInfo information about currently executing workflow

type WorkflowProvider

type WorkflowProvider interface {
	NewApplicationError(message, errType string, details ...interface{}) error
	GetWorkflowInfo(ctx UnifiedContext) WorkflowInfo
	UpsertSearchAttributes(ctx UnifiedContext, attributes map[string]interface{}) error
	SetQueryHandler(ctx UnifiedContext, queryType string, handler interface{}) error
	ExtendContextWithValue(parent UnifiedContext, key string, val interface{}) UnifiedContext
	GoNamed(ctx UnifiedContext, name string, f func(ctx UnifiedContext))
	Await(ctx UnifiedContext, condition func() bool) error
	WithActivityOptions(ctx UnifiedContext, options ActivityOptions) UnifiedContext
	ExecuteActivity(ctx UnifiedContext, activity interface{}, args ...interface{}) (future Future)
	Now(ctx UnifiedContext) time.Time
	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
	GetBackendType() service.BackendType
}