formulation

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

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

type AddressSpace interface {
	ToRelation(p0 anysdk.AddressSpaceExpansionConfig) (Relation, error)
}

type AddressSpaceFormulator interface {
	Formulate() error
	GetAddressSpace() AddressSpace
}

type Addressable interface {
	ConditionIsValid(lhs string, rhs interface{}) bool
	GetName() string
	GetType() string
}

type AnySdkClientConfigurator interface {
	Auth(authCtx *AuthCtx, authTypeRequested string, enforceRevokeFirst bool) (client.AnySdkClient, error)
}

type AnySdkResponse interface {
	GetHttpResponse() (*http.Response, error)
}

type ArmouryGenerator interface {
	GetHTTPArmoury() (anysdk.HTTPArmoury, error)
}

type AuthContexts interface {
	Clone() AuthContexts
}

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

type AuthDTO interface {
	GetAccountID() string
	GetAccountIDEnvVar() string
	GetAuthStyle() int
	GetClientID() string
	GetClientIDEnvVar() string
	GetClientSecret() string
	GetClientSecretEnvVar() string
	GetEnvVarAPIKeyStr() string
	GetEnvVarAPISecretStr() string
	GetEnvVarPassword() string
	GetEnvVarUsername() string
	GetGrantType() string
	GetInlineBasicCredentials() string
	GetKeyEnvVar() string
	GetKeyFilePath() string
	GetKeyFilePathEnvVar() string
	GetKeyID() string
	GetKeyIDEnvVar() string
	GetLocation() string
	GetName() string
	GetScopes() []string
	GetSubject() string
	GetSuccessor() (AuthDTO, bool)
	GetTokenURL() string
	GetType() string
	GetValuePrefix() string
	GetValues() url.Values
}

type AuthMetadata interface {
	GetHeaders() []string
	ToMap() map[string]interface{}
}

type AuthUtility interface {
	ActivateAuth(authCtx *AuthCtx, principal string, authType string)
	ApiTokenAuth(authCtx *AuthCtx, httpContext netutils.HTTPContext, enforceBearer bool) (*http.Client, error)
	AuthRevoke(authCtx *AuthCtx) error
	AwsSigningAuth(authCtx *AuthCtx, httpContext netutils.HTTPContext) (*http.Client, error)
	AzureDefaultAuth(authCtx *AuthCtx, httpContext netutils.HTTPContext) (*http.Client, error)
	BasicAuth(authCtx *AuthCtx, httpContext netutils.HTTPContext) (*http.Client, error)
	CustomAuth(authCtx *AuthCtx, httpContext netutils.HTTPContext) (*http.Client, error)
	GCloudOAuth(runtimeCtx RuntimeCtx, authCtx *AuthCtx, enforceRevokeFirst bool) (*http.Client, error)
	GenericOauthClientCredentials(authCtx *AuthCtx, scopes []string, httpContext netutils.HTTPContext) (*http.Client, error)
	GetCurrentGCloudOauthUser() ([]byte, error)
	GoogleOauthServiceAccount(provider string, authCtx *AuthCtx, scopes []string, httpContext netutils.HTTPContext) (*http.Client, error)
	ParseServiceAccountFile(ac *AuthCtx) (any, error)
}

type Column interface {
	GetName() string
	GetSchema() Schema
	GetWidth() int
}

type ColumnDescriptor interface {
	GetAlias() string
	GetDecoratedCol() string
	GetIdentifier() string
	GetName() string
	GetNode() sqlparser.SQLNode
	GetQualifier() string
	GetRepresentativeSchema() anysdk.Schema
	GetSchema() anysdk.Schema
	GetVal() *sqlparser.SQLVal
	// contains filtered or unexported methods
}

type ControlAttributes interface {
	GetControlGCStatusColumnName() string
	GetControlGenIDColumnName() string
	GetControlInsIDColumnName() string
	GetControlInsertEncodedIDColumnName() string
	GetControlLatestUpdateColumnName() string
	GetControlMaxTxnColumnName() string
	GetControlSsnIDColumnName() string
	GetControlTxnIDColumnName() string
}

type DataFlowCfg interface {
	GetMaxDependencies() int
}

type ExecContext interface {
	GetExecPayload() internaldto.ExecPayload
	GetResource() Resource
	// contains filtered or unexported methods
}

type ExecPayload interface {
	GetPayloadMap() map[string]interface{}
}

type ExecutionResponse interface {
	GetStdErr() (*bytes.Buffer, bool)
	GetStdOut() (*bytes.Buffer, bool)
}

type Executor interface {
	Execute(p0 map[string]any) (ExecutionResponse, error)
}

type ExpectedRequest interface {
	GetBodyMediaType() string
}

type ExpectedResponse interface {
	GetObjectKey() string
	GetTransform() (Transform, bool)
}

type GQLReader interface {
	Read() ([]map[string]interface{}, error)
}

type GraphQL interface {
	GetCursorJSONPath() (string, bool)
	GetQuery() string
	GetResponseJSONPath() (string, bool)
}

type HTTPArmoury interface {
	GetRequestParams() []HTTPArmouryParameters
	SetRequestParams(p0 []HTTPArmouryParameters)
}

type HTTPArmouryParameters interface {
	Encode() string
	GetArgList() client.AnySdkArgList
	GetParameters() HttpParameters
	GetQuery() url.Values
	GetRequest() *http.Request
	SetNextPage(ops OperationStore, token string, tokenKey HTTPElement) (*http.Request, error)
	SetRawQuery(p0 string)
	ToFlatMap() (map[string]interface{}, error)
}

type HTTPElement interface {
	GetName() string
	GetType() internaldto.HTTPElementType
	SetTransformer(transformer func(interface{}) (interface{}, error))
	IsTransformerPresent() bool
	Transformer(t interface{}) (interface{}, error)
}

type HTTPHTTPElement interface {
	GetName() string
	GetLocation() httpelement.HTTPElementLocation
}

type HTTPPreparator interface {
	BuildHTTPRequestCtx(p0 anysdk.HTTPPreparatorConfig) (HTTPArmoury, error)
}

type HttpParameters interface {
	GetInlineParameterFlatMap() (map[string]interface{}, error)
	ToFlatMap() (map[string]interface{}, error)
}

type HttpPreparatorStream interface {
	Next() (HTTPPreparator, bool)
	Write(p0 HTTPPreparator) error
}

type IDiscoveryAdapter interface {
	GetProvider(providerKey string) (Provider, error)
	GetResourcesMap(prov Provider, serviceKey string) (map[string]Resource, error)
	GetServiceHandlesMap(prov Provider) (map[string]ProviderService, error)
	GetServiceShard(prov Provider, serviceKey string, resourceKey string) (Service, error)
	PersistStaticExternalSQLDataSource(prov Provider) error
}

type ITable interface {
	GetKey(p0 string) (interface{}, error)
	GetKeyAsSqlVal(p0 string) (sqltypes.Value, error)
	GetName() string
	KeyExists(p0 string) bool
}

type InsertPreparator interface {
	ActionInsertPreparation(payload ActionInsertPayload) ActionInsertResult
}

type Invoker interface {
	Invoke(ctx context.Context, req providerinvoker.Request) (providerinvoker.Result, error)
}

type ItemisationResult interface {
	GetItems() (interface{}, bool)
}

type MapReader interface {
	Read() ([]map[string]interface{}, error)
}

type MapStream interface {
	Write(p0 []map[string]interface{}) error
}

type MapStreamCollection interface {
	Len() int
	Push(p0 MapStream)
}

type MethodAnalysisOutput interface {
	GetInsertTabulation() Tabulation
	GetItemSchema() (Schema, bool)
	GetOrderedStarColumnsNames() ([]string, error)
	GetSelectTabulation() Tabulation
	IsAwait() bool
	IsNilResponseAllowed() bool
}

type MethodAnalyzer interface {
	AnalyzeUnaryAction(p0 anysdk.MethodAnalysisInput) (MethodAnalysisOutput, error)
}

type MethodSet interface {
	GetFirstMatch(params map[string]interface{}) (StandardOperationStore, map[string]interface{}, bool)
	GetFirstNamespaceMatch(params map[string]any) (StandardOperationStore, map[string]any, bool)
	GetFirst() (StandardOperationStore, string, bool)
}

type Methods interface {
	OrderMethods() ([]StandardOperationStore, error)
}

type NameMangler interface {
	MangleName(p0 string, p1 ...any) string
}

type NamespaceCfg interface {
	GetRegex() (*regexp.Regexp, error)
	GetTemplate() (*template.Template, error)
}

type OpenAPIService interface {
	Service
	// contains filtered or unexported methods
}

type OperationInverse interface {
	GetOperationStore() (StandardOperationStore, bool)
}

type OperationStore interface {
	DeprecatedProcessResponse(response *http.Response) (map[string]interface{}, error)
	GetName() string
	GetNonBodyParameters() map[string]Addressable
	GetPaginationRequestTokenSemantic() (TokenSemantic, bool)
	GetPaginationResponseTokenSemantic() (TokenSemantic, bool)
	GetParameter(paramKey string) (Addressable, bool)
	GetRequestBodySchema() (Schema, error)
	GetRequiredNonBodyParameters() map[string]Addressable
	GetRequiredParameters() map[string]Addressable
	GetResource() Resource
	GetResponseBodySchemaAndMediaType() (Schema, string, error)
	GetSelectItemsKey() string
	GetService() OpenAPIService
	IsRequestBodyAttributeRenamed(p0 string) bool
	IsRequiredRequestBodyProperty(key string) bool
	ProcessResponse(p0 *http.Response) (ProcessedOperationResponse, error)
	RenameRequestBodyAttribute(p0 string) (string, error)
	RevertRequestBodyAttributeRename(p0 string) (string, error)
	// contains filtered or unexported methods
}

type OutputPacket interface {
	GetColumnNames() []string
	GetColumnOIDs() []oid.Oid
	GetRawRows() map[int]map[int]interface{}
	GetRows() map[string]map[string]interface{}
}

type PgTLSCfg interface {
	GetKeyPair() (tls.Certificate, error)
}

type ProcessedOperationResponse interface {
	GetResponse() (Response, bool)
	GetReversal() (HTTPPreparator, bool)
}

type Provider interface {
	GetAuth() (AuthDTO, bool)
	GetDeleteItemsKey() string
	GetMinStackQLVersion() string
	GetName() string
	GetProtocolType() (client.ClientProtocolType, error)
	// contains filtered or unexported methods
}

type ProviderDescription interface {
	GetLatestVersion() (string, error)
}

type ProviderService interface {
	GetDescription() string
	GetID() string
	GetName() string
	GetTitle() string
	GetVersion() string
	IsPreferred() bool
}

type RegistryAPI interface {
	ClearProviderCache(p0 string) error
	GetLatestPublishedVersion(p0 string) (string, error)
	ListAllAvailableProviders() (map[string]ProviderDescription, error)
	ListAllProviderVersions(p0 string) (map[string]ProviderDescription, error)
	ListLocallyAvailableProviders() map[string]ProviderDescription
	LoadProviderByName(p0 string, p1 string) (Provider, error)
	PullAndPersistProviderArchive(p0 string, p1 string) error
	RemoveProviderVersion(p0 string, p1 string) error
}

type RegistryConfig struct {
	RegistryURL      string                   `json:"url" yaml:"url"`
	SrcPrefix        *string                  `json:"srcPrefix" yaml:"srcPrefix"`
	DistPrefix       *string                  `json:"distPrefix" yaml:"distPrefix"`
	AllowSrcDownload bool                     `json:"allowSrcDownload" yaml:"allowSrcDownload"`
	LocalDocRoot     string                   `json:"localDocRoot" yaml:"localDocRoot"`
	VerifyConfig     *edcrypto.VerifierConfig `json:"verifyConfig" yaml:"verifyConfig"`
}

type Relation interface {
	GetColumnDescriptors() []anysdk.ColumnDescriptor
	GetColumns() []Column
}

type Resource interface {
	FindMethod(key string) (StandardOperationStore, error)
	GetFirstMethodFromSQLVerb(sqlVerb string) (StandardOperationStore, string, bool)
	GetFirstNamespaceMethodMatchFromSQLVerb(sqlVerb string, parameters map[string]interface{}) (StandardOperationStore, map[string]interface{}, bool)
	GetID() string
	GetMethodsMatched() Methods
	GetName() string
	GetViewsForSqlDialect(sqlDialect string) ([]View, bool)
	ToMap(extended bool) map[string]interface{}
}

type Response interface {
	Error() string
	ExtractElement(e HTTPHTTPElement) (interface{}, error)
	GetHttpResponse() *http.Response
	GetProcessedBody() interface{}
	HasError() bool
}

type RuntimeCtx interface {
	Copy() RuntimeCtx
}

type SQLBackendCfg interface {
	GetDatabaseName() (string, error)
	GetIntelViewSchemaName() string
	GetOpsViewSchemaName() string
	GetSQLDialect() string
	GetSchemaType() string
	GetTableSchemaName() string
}

type SQLEngine interface {
	CacheStoreGet(p0 string) ([]byte, error)
	CacheStorePut(p0 string, p1 []byte, p2 string, p3 int) error
	Exec(p0 string, p1 ...interface{}) (sql.Result, error)
	ExecInTxn(queries []string) error
	GetCurrentDiscoveryGenerationID(discoveryID string) (int, error)
	GetCurrentGenerationID() (int, error)
	GetDB() (*sql.DB, error)
	GetNextDiscoveryGenerationID(discoveryID string) (int, error)
	GetNextGenerationID() (int, error)
	GetNextSessionID(p0 int) (int, error)
	GetTx() (*sql.Tx, error)
	Query(p0 string, p1 ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
}

type SQLExternalColumn interface {
	GetName() string
	GetOid() uint32
	GetPrecision() int
	GetType() string
	GetWidth() int
}

type SQLExternalTable interface {
	GetCatalogName() string
	GetColumns() []SQLExternalColumn
	GetName() string
	GetSchemaName() string
}

type Schema interface {
	FindByPath(path string, visited map[string]bool) Schema
	GetAdditionalProperties() (Schema, bool)
	GetAllColumns(p0 string) []string
	GetItemsSchema() (Schema, error)
	GetName() string
	GetProperties() (anysdk.Schemas, error)
	GetProperty(propertyKey string) (Schema, bool)
	GetPropertySchema(key string) (Schema, error)
	GetSelectSchema(itemsKey string, mediaType string) (Schema, string, error)
	GetSelectionName() string
	GetTitle() string
	GetType() string
	IsBoolean() bool
	IsFloat() bool
	IsIntegral() bool
	IsReadOnly() bool
	IsRequired(key string) bool
	SetKey(p0 string)
	Tabulate(p0 bool, p1 string) Tabulation
	ToDescriptionMap(extended bool) map[string]interface{}
	// contains filtered or unexported methods
}

type Service interface {
	GetResource(resourceName string) (Resource, error)
	GetSchema(key string) (Schema, error)
	GetServers() (openapi3.Servers, bool)
	// contains filtered or unexported methods
}

type SessionContext interface {
	GetIsolationLevel() constants.IsolationLevel
	GetRollbackType() constants.RollbackType
	UpdateIsolationLevel(p0 string) error
}

type StandardOperationStore interface {
	OperationStore
	// contains filtered or unexported methods
}

type StreamTransformer interface {
	GetOutStream() io.Reader
	Transform() error
}

type StreamTransformerFactory interface {
	GetTransformer(input string) (StreamTransformer, error)
	IsTransformable() bool
}

type Tabulation interface {
	GetColumns() []anysdk.ColumnDescriptor
	PushBackColumn(col anysdk.ColumnDescriptor)
	RenameColumnsToXml() Tabulation
}

type TokenSemantic interface {
	GetKey() string
	GetLocation() string
	GetTransformer() (anysdk.TokenTransformer, error)
}

type Transform interface {
	GetBody() string
	GetType() string
}

type TxnCoordinatorCfg interface {
	GetMaxTxnDepth() int
}

type View interface {
	GetDDL() string
	GetNameNaive() string
	GetRequiredParamNames() []string
}