basicexecuter

Documentation

Overview

Package basicexecuter provides interfaces as document execution logic

Index

• type BasicExecuter
  • func NewBasicExecuter(context context.T) *BasicExecuter
  • func (e *BasicExecuter) Run(cancelFlag task.CancelFlag, docStore executer.DocumentStore) chan contracts.DocumentResult

Types

type BasicExecuter

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

TODO currently BasicExecuter.Run() is not idempotent, we should make it so in future BasicExecuter is a thin wrapper over runPlugins().

func NewBasicExecuter

func NewBasicExecuter(context context.T) *BasicExecuter

NewBasicExecuter returns a pointer that impl the Executer interface using a pointer so that it can be shared among multiple threads(go-routines)

func (*BasicExecuter) Run

func (e *BasicExecuter) Run(
	cancelFlag task.CancelFlag,
	docStore executer.DocumentStore) chan contracts.DocumentResult