fakeplugins

Documentation

Index

• type HandleResponse
  • func NewHandleError(err error) HandleResponse
  • func NewHandleTransition(transition pluginCore.Transition) HandleResponse
• type NextPhaseState
• type NextPhaseStatePlugin
  • func NewPhaseBasedPlugin() NextPhaseStatePlugin
  • func (n NextPhaseStatePlugin) Abort(ctx context.Context, tCtx pluginCore.TaskExecutionContext) error
  • func (n NextPhaseStatePlugin) Finalize(ctx context.Context, tCtx pluginCore.TaskExecutionContext) error
  • func (n NextPhaseStatePlugin) GetID() string
  • func (n NextPhaseStatePlugin) GetProperties() pluginCore.PluginProperties
  • func (n NextPhaseStatePlugin) Handle(ctx context.Context, tCtx pluginCore.TaskExecutionContext) (pluginCore.Transition, error)
• type ReplayerPlugin
  • func NewReplayer(forPluginID string, props pluginCore.PluginProperties, ...) *ReplayerPlugin
  • func (r ReplayerPlugin) Abort(_ context.Context, tCtx pluginCore.TaskExecutionContext) error
  • func (r ReplayerPlugin) Finalize(_ context.Context, tCtx pluginCore.TaskExecutionContext) error
  • func (r ReplayerPlugin) GetID() string
  • func (r ReplayerPlugin) GetProperties() pluginCore.PluginProperties
  • func (r ReplayerPlugin) Handle(_ context.Context, tCtx pluginCore.TaskExecutionContext) (pluginCore.Transition, error)
  • func (r ReplayerPlugin) VerifyAllCallsCompleted(taskExecID string) error

Types

type HandleResponse

type HandleResponse struct {
	T   pluginCore.Transition
	Err error
}

func NewHandleError

func NewHandleError(err error) HandleResponse

func NewHandleTransition

func NewHandleTransition(transition pluginCore.Transition) HandleResponse

type NextPhaseState

type NextPhaseState struct {
	Phase        pluginCore.Phase
	PhaseVersion uint32
	TaskInfo     *pluginCore.TaskInfo
	TaskErr      *io.ExecutionError
	OutputExists bool
	OrError      bool
}

type NextPhaseStatePlugin

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

func NewPhaseBasedPlugin

func NewPhaseBasedPlugin() NextPhaseStatePlugin

func (NextPhaseStatePlugin) Abort

func (n NextPhaseStatePlugin) Abort(ctx context.Context, tCtx pluginCore.TaskExecutionContext) error

func (NextPhaseStatePlugin) Finalize

func (n NextPhaseStatePlugin) Finalize(ctx context.Context, tCtx pluginCore.TaskExecutionContext) error

func (NextPhaseStatePlugin) GetID

func (n NextPhaseStatePlugin) GetID() string

func (NextPhaseStatePlugin) GetProperties

func (n NextPhaseStatePlugin) GetProperties() pluginCore.PluginProperties

func (NextPhaseStatePlugin) Handle

func (n NextPhaseStatePlugin) Handle(ctx context.Context, tCtx pluginCore.TaskExecutionContext) (pluginCore.Transition, error)

type ReplayerPlugin

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

This is a test plugin and can be used to play any scenario responses from a plugin, (exceptions: panic) The plugin is to be invoked within a single thread (not thread safe) and is very simple in terms of usage It does not use any state and does not drive the state machine using that state. It drives the state machine constantly forward for a taskID

func NewReplayer

func NewReplayer(forPluginID string, props pluginCore.PluginProperties, orderedOnHandleResponses []HandleResponse, orderedAbortResponses, orderedFinalizeResponses []error) *ReplayerPlugin

func (ReplayerPlugin) Abort

func (r ReplayerPlugin) Abort(_ context.Context, tCtx pluginCore.TaskExecutionContext) error

func (ReplayerPlugin) Finalize

func (r ReplayerPlugin) Finalize(_ context.Context, tCtx pluginCore.TaskExecutionContext) error

func (ReplayerPlugin) GetID

func (r ReplayerPlugin) GetID() string

func (ReplayerPlugin) GetProperties

func (r ReplayerPlugin) GetProperties() pluginCore.PluginProperties

func (ReplayerPlugin) Handle

func (r ReplayerPlugin) Handle(_ context.Context, tCtx pluginCore.TaskExecutionContext) (pluginCore.Transition, error)

func (ReplayerPlugin) VerifyAllCallsCompleted

func (r ReplayerPlugin) VerifyAllCallsCompleted(taskExecID string) error