support

Documentation

Index

• func NewFactory(resolver resolve.CompositeResolver) mapper.Factory
• func RegisterTelemetryService(service TelemetryService)
• type ExprMapperFactory
  • func (mf *ExprMapperFactory) NewMapper(mappings map[string]interface{}) (mapper.Mapper, error)
• type OverrideExprMapper
  • func (m *OverrideExprMapper) Apply(inputScope data.Scope) (map[string]interface{}, error)
• type TelemetryService
  • func GetTelemetryService() TelemetryService
• type TimerCallback
• type TimerSupport
  • func GetTimerSupport(ctx interface{}) (TimerSupport, bool)

Functions

func NewFactory

func NewFactory(resolver resolve.CompositeResolver) mapper.Factory

func RegisterTelemetryService

func RegisterTelemetryService(service TelemetryService)

Types

type ExprMapperFactory

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

func (*ExprMapperFactory) NewMapper

func (mf *ExprMapperFactory) NewMapper(mappings map[string]interface{}) (mapper.Mapper, error)

type OverrideExprMapper

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

func (*OverrideExprMapper) Apply

func (m *OverrideExprMapper) Apply(inputScope data.Scope) (map[string]interface{}, error)

type TelemetryService

type TelemetryService interface {
	PipelineStarted(pipelineId, instanceId string, data map[string]interface{})
	StageStarted(pipelineId, instanceId, stageId string, data map[string]interface{})
	StageFinished(pipelineId, instanceId, stageId string, data map[string]interface{})
	PipelineFinished(pipelineId, instanceId string, data map[string]interface{})
}

func GetTelemetryService

func GetTelemetryService() TelemetryService

type TimerCallback

type TimerCallback func(ctx activity.Context) (resume bool)

type TimerSupport

type TimerSupport interface {
	// HasTimer indicates if a timer already exists
	HasTimer(repeating bool) bool

	// CancelTimer cancels the existing timer
	CancelTimer(repeating bool)

	UpdateTimer(repeating bool)

	// CreateTimer creates a timer, note: can only have one active timer at a time for an activity
	CreateTimer(interval time.Duration, callback TimerCallback, repeating bool) error
}

TimerSupport is used to create a timer on behalf of the activity

func GetTimerSupport

func GetTimerSupport(ctx interface{}) (TimerSupport, bool)

GetTimerSupport for the activity //activity.Context