Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New() providerinvoker.Invoker
func NewPayload ¶
func NewPayload( armouryGenerator formulation.ArmouryGenerator, provider anysdk.Provider, method anysdk.OperationStore, tableName string, authCtx *dto.AuthCtx, runtimeCtx dto.RuntimeCtx, outErrFile io.Writer, maxResultsElement sdk_internal_dto.HTTPElement, elider methodElider, nilOK bool, polyHandler PolyHandler, selectItemsKey string, insertPreparator InsertPreparator, skipResponse bool, isMutation bool, isAwait bool, defaultHTTPClient *http.Client, messageHandler providerinvoker.MessageHandler, ) any
Types ¶
type AgnosticatePayload ¶
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 ¶
type InsertPreparator interface {
ActionInsertPreparation(payload providerinvoker.ActionInsertPayload) providerinvoker.ActionInsertResult
}
type Invoker ¶
type Invoker struct{}
func (*Invoker) Invoke ¶
func (i *Invoker) Invoke(ctx context.Context, req providerinvoker.Request) (providerinvoker.Result, error)
type PagingState ¶
type PolyHandler ¶
type PolyHandler interface {
LogHTTPResponseMap(target interface{})
MessageHandler([]string)
GetMessages() []string
}
func NewStandardPolyHandler ¶
func NewStandardPolyHandler(messageHandler providerinvoker.MessageHandler) PolyHandler
type Processor ¶
type Processor interface {
Process() ProcessorResponse
}
func NewProcessor ¶
func NewProcessor(payload ProcessorPayload) Processor
type ProcessorPayload ¶
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
}
func NewProcessorPayload ¶
func NewProcessorPayload( armouryParams anysdk.HTTPArmouryParameters, elider methodElider, provider anysdk.Provider, method anysdk.OperationStore, tableName string, runtimeCtx dto.RuntimeCtx, authCtx *dto.AuthCtx, outErrFile io.Writer, polyHandler PolyHandler, selectItemsKey string, insertPreparator InsertPreparator, isSkipResponse bool, isMaterialiseResponse bool, isAwait bool, isReverseRequired bool, isMutation bool, verb string, defaultHTTPClient *http.Client, ) ProcessorPayload
type ProcessorResponse ¶
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
}
Click to show internal directories.
Click to hide internal directories.