execution

type ActionInsertPayload interface {
	GetItemisationResult() ItemisationResult
	IsHousekeepingDone() bool
	GetTableName() string
	GetParamsUsed() map[string]interface{}
	GetReqEncoding() string
}

type ActionInsertResult interface {
	GetError() (error, bool)
	IsHousekeepingDone() bool
}

type AgnosticatePayload interface {
	GetArmoury() (anysdk.HTTPArmoury, error)
	GetProvider() anysdk.Provider
	GetMethod() anysdk.OperationStore
	GetTableName() string
	GetAuthContext() *dto.AuthCtx
	GetRuntimeCtx() dto.RuntimeCtx
	GetOutErrFile() io.Writer
	GetMaxResultsElement() sdk_internal_dto.HTTPElement
	GetElider() methodElider
	IsNilResponseAcceptable() bool
	GetPolyHandler() PolyHandler
	GetSelectItemsKey() string
	GetInsertPreparator() InsertPreparator
	IsSkipResponse() bool
	IsMutation() bool
	IsAwait() bool
	GetDefaultHTTPClient() *http.Client // testing purposes only
}

type InsertPreparator interface {
	ActionInsertPreparation(payload ActionInsertPayload) ActionInsertResult
}

type ItemisationResult interface {
	GetItems() (interface{}, bool)
	GetSingltetonResponse() (map[string]interface{}, bool)
	IsOk() bool
	IsNilPayload() bool
}

type MonitorMonoValentExecutorFactory interface {
	GetMonitorExecutor(
		provider anysdk.Provider,
		op anysdk.OperationStore,
		precursor primitive.IPrimitive,
		initialCtx primitive.IPrimitiveCtx,
		comments sqlparser.CommentDirectives,
	) (func(pc primitive.IPrimitiveCtx, bd interface{}) internaldto.ExecutorOutput, error)
}

type MonoValentExecutorFactory interface {
	GetExecutor() (func(pc primitive.IPrimitiveCtx) internaldto.ExecutorOutput, error)
}

type PagingState interface {
	GetPageCount() int
	IsFinished() bool
	GetHTTPResponse() (*http.Response, error)
	GetAPIError() error
}

type PolyHandler interface {
	LogHTTPResponseMap(target interface{})
	MessageHandler([]string)
	GetMessages() []string
}

type Processor interface {
	Process() ProcessorResponse
}

type ProcessorPayload interface {
	GetArmouryParams() anysdk.HTTPArmouryParameters
	GetElider() methodElider
	GetProvider() anysdk.Provider
	GetMethod() anysdk.OperationStore
	GetTableName() string
	GetRuntimeCtx() dto.RuntimeCtx
	GetAuthCtx() *dto.AuthCtx
	GetOutErrFile() io.Writer
	GetPolyHandler() PolyHandler
	GetSelectItemsKey() string
	GetInsertPreparator() InsertPreparator
	IsSkipResponse() bool
	IsMutation() bool
	IsMaterialiseResponse() bool
	IsAwait() bool
	IsReverseRequired() bool
	GetVerb() string
	GetDefaultHTTPClient() *http.Client // testing purposes only
}

type ProcessorResponse interface {
	GetError() error
	GetSingletonBody() map[string]interface{}
	WithSuccessMessages([]string) ProcessorResponse
	GetSuccessMessages() []string
	AppendReversal(rev anysdk.HTTPPreparator)
	GetReversalStream() anysdk.HttpPreparatorStream
	IsFailed() bool
	GetFailedMessage() string
}