anysdkhttp

package
v0.4.4-alpha21 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 22, 2026 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

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

type PagingState

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

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL