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 {
	GetGlobalSelectSchemas() map[string]Schema
	DereferenceAddress(address string) (any, bool)
	WriteToAddress(address string, val any) error
	ReadFromAddress(address string) (any, bool)
	ResolveSignature(map[string]any) (bool, map[string]any)
	Invoke(...any) error
	ToMap(AddressSpaceExpansionConfig) (map[string]any, error)
	ToRelation(AddressSpaceExpansionConfig) (Relation, error)
	// contains filtered or unexported methods
}

type AddressSpaceExpansionConfig interface {
	IsAsync() bool
	IsLegacy() bool
	IsAllowNilResponse() bool
	// contains filtered or unexported methods
}

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

type AddressSpaceGrammar radix_tree_address_space.AddressSpaceGrammar

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 struct {
	Principal string `json:"principal"`
	Type      string `json:"type"`
	Source    string `json:"source"`
}

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() Schema
	GetSchema() 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)
	// contains filtered or unexported methods
}

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

type GraphQL interface {
	GetCursorJSONPath() (string, bool)
	GetQuery() string
	GetResponseJSONPath() (string, bool)
	// contains filtered or unexported methods
}

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 HTTPPreparatorConfig interface {
	IsFromAnnotation() bool
	// contains filtered or unexported methods
}

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
	// contains filtered or unexported methods
}

type IDiscoveryStore interface {
	ProcessProviderDiscoveryDoc(string, string) (Provider, error)

	PersistServiceShard(Provider, ProviderService, string) (Service, error)
	// contains filtered or unexported methods
}

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)
	// contains filtered or unexported methods
}

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)
	Size() int
}

type Methods interface {
	OrderMethods() ([]StandardOperationStore, error)
	List() []MethodsKV
	Put(k string, v StandardOperationStore) error
	// contains filtered or unexported methods
}

type MethodsKV interface {
	GetKey() string
	GetValue() StandardOperationStore
}

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)
	GetProjections() map[string]string
	GetAddressSpace() (AddressSpace, bool)
	GetGraphQL() GraphQL
	IsAwaitable() bool
	GetSelectSchemaAndObjectPath() (Schema, string, error)
	GetResponse() (ExpectedResponse, bool)
	GetOptionalParameters() map[string]Addressable
	// 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 PersistenceSystem interface {
	GetSystemName() string
	HandleExternalTables(providerName string, externalTables map[string]SQLExternalTable) error
	HandleViewCollection([]View) error
	CacheStoreGet(key string) ([]byte, error)
	CacheStorePut(key string, value []byte, expiration string, ttl int) error
}

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)
	Versions() []string
}

type ProviderService interface {
	GetDescription() string
	GetID() string
	GetName() string
	GetTitle() string
	GetVersion() string
	IsPreferred() bool
	// contains filtered or unexported methods
}

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
	// contains filtered or unexported methods
}

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() []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{}
	// contains filtered or unexported methods
}

type ResourceRegister interface {
	//
	// GetServiceDocPath() *ServiceRef
	ObtainServiceDocUrl(resourceKey string) string
	SetProviderService(ps ProviderService)
	SetProvider(p Provider)
	GetResources() map[string]Resource
	GetResource(string) (Resource, bool)
	// contains filtered or unexported methods
}

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
	// contains filtered or unexported methods
}

type Schema interface {
	FindByPath(path string, visited map[string]bool) Schema
	GetAdditionalProperties() (Schema, bool)
	GetAllColumns(p0 string) []string
	GetItemsSchema() (Schema, error)
	GetName() string
	GetProperties() (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 Schemas map[string]Schema

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
	GetServers() (openapi3.Servers, bool)
	// 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() []ColumnDescriptor
	PushBackColumn(col ColumnDescriptor)
	RenameColumnsToXml() Tabulation
}

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

type TokenTransformer func(interface{}) (interface{}, error)

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

type TxnCoordinatorCfg interface {
	GetMaxTxnDepth() int
}

type View interface {
	GetDDL() string
	GetNameNaive() string
	GetRequiredParamNames() []string
	// contains filtered or unexported methods
}