formulation

package
v0.4.4-alpha03 Latest Latest
Warning

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

 Go to latest Published: Feb 19, 2026 License: MIT Imports: 33 Imported by: 0

Documentation

Overview

Code generated by tools/surfacegen (wrappers) - DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMethodAnalysisInput 

func NewMethodAnalysisInput(
	method anysdk.OperationStore,
	service anysdk.Service,
	isNilResponseAllowed bool,
	columns []ColumnDescriptor,
	isAwait bool,
) anysdk.MethodAnalysisInput

Types

type ActionInsertPayload 

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

func (ActionInsertPayload) GetItemisationResult 

func (w ActionInsertPayload) GetItemisationResult() ItemisationResult

func (ActionInsertPayload) GetParamsUsed 

func (w ActionInsertPayload) GetParamsUsed() map[string]interface{}

func (ActionInsertPayload) GetReqEncoding 

func (w ActionInsertPayload) GetReqEncoding() string

func (ActionInsertPayload) GetTableName 

func (w ActionInsertPayload) GetTableName() string

func (ActionInsertPayload) IsHousekeepingDone 

func (w ActionInsertPayload) IsHousekeepingDone() bool

type ActionInsertResult 

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

func (ActionInsertResult) GetError 

func (w ActionInsertResult) GetError() (error, bool)

func (ActionInsertResult) IsHousekeepingDone 

func (w ActionInsertResult) IsHousekeepingDone() bool

type AddressSpace 

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

func (AddressSpace) ToRelation 

func (w AddressSpace) ToRelation(p0 anysdk.AddressSpaceExpansionConfig) (Relation, error)

type AddressSpaceFormulator 

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

func (AddressSpaceFormulator) Formulate 

func (w AddressSpaceFormulator) Formulate() error

func (AddressSpaceFormulator) GetAddressSpace 

func (w AddressSpaceFormulator) GetAddressSpace() AddressSpace

type Addressable 

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

func (Addressable) ConditionIsValid 

func (w Addressable) ConditionIsValid(lhs string, rhs interface{}) bool

func (Addressable) GetName 

func (w Addressable) GetName() string

func (Addressable) GetType 

func (w Addressable) GetType() string

type AnySdkClientConfigurator 

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

func (AnySdkClientConfigurator) Auth 

func (w AnySdkClientConfigurator) Auth(authCtx *AuthCtx, authTypeRequested string, enforceRevokeFirst bool) (client.AnySdkClient, error)

type AnySdkResponse 

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

func (AnySdkResponse) GetHttpResponse 

func (w AnySdkResponse) GetHttpResponse() (*http.Response, error)

type ArmouryGenerator 

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

type AuthContexts 

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

func (AuthContexts) Clone 

func (w AuthContexts) Clone() AuthContexts

type AuthCtx 

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

func (*AuthCtx) Clone 

func (w *AuthCtx) Clone() *AuthCtx

func (*AuthCtx) GetCredentialsBytes 

func (w *AuthCtx) GetCredentialsBytes() ([]byte, error)

func (*AuthCtx) GetCredentialsSourceDescriptorString 

func (w *AuthCtx) GetCredentialsSourceDescriptorString() string

func (*AuthCtx) GetSQLCfg 

func (w *AuthCtx) GetSQLCfg() (SQLBackendCfg, bool)

func (*AuthCtx) HasKey 

func (w *AuthCtx) HasKey() bool

type AuthDTO 

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

func (AuthDTO) GetAccountID 

func (w AuthDTO) GetAccountID() string

func (AuthDTO) GetAccountIDEnvVar 

func (w AuthDTO) GetAccountIDEnvVar() string

func (AuthDTO) GetAuthStyle 

func (w AuthDTO) GetAuthStyle() int

func (AuthDTO) GetClientID 

func (w AuthDTO) GetClientID() string

func (AuthDTO) GetClientIDEnvVar 

func (w AuthDTO) GetClientIDEnvVar() string

func (AuthDTO) GetClientSecret 

func (w AuthDTO) GetClientSecret() string

func (AuthDTO) GetClientSecretEnvVar 

func (w AuthDTO) GetClientSecretEnvVar() string

func (AuthDTO) GetEnvVarAPIKeyStr 

func (w AuthDTO) GetEnvVarAPIKeyStr() string

func (AuthDTO) GetEnvVarAPISecretStr 

func (w AuthDTO) GetEnvVarAPISecretStr() string

func (AuthDTO) GetEnvVarPassword 

func (w AuthDTO) GetEnvVarPassword() string

func (AuthDTO) GetEnvVarUsername 

func (w AuthDTO) GetEnvVarUsername() string

func (AuthDTO) GetGrantType 

func (w AuthDTO) GetGrantType() string

func (AuthDTO) GetInlineBasicCredentials 

func (w AuthDTO) GetInlineBasicCredentials() string

func (AuthDTO) GetKeyEnvVar 

func (w AuthDTO) GetKeyEnvVar() string

func (AuthDTO) GetKeyFilePath 

func (w AuthDTO) GetKeyFilePath() string

func (AuthDTO) GetKeyFilePathEnvVar 

func (w AuthDTO) GetKeyFilePathEnvVar() string

func (AuthDTO) GetKeyID 

func (w AuthDTO) GetKeyID() string

func (AuthDTO) GetKeyIDEnvVar 

func (w AuthDTO) GetKeyIDEnvVar() string

func (AuthDTO) GetLocation 

func (w AuthDTO) GetLocation() string

func (AuthDTO) GetName 

func (w AuthDTO) GetName() string

func (AuthDTO) GetScopes 

func (w AuthDTO) GetScopes() []string

func (AuthDTO) GetSubject 

func (w AuthDTO) GetSubject() string

func (AuthDTO) GetSuccessor 

func (w AuthDTO) GetSuccessor() (AuthDTO, bool)

func (AuthDTO) GetTokenURL 

func (w AuthDTO) GetTokenURL() string

func (AuthDTO) GetType 

func (w AuthDTO) GetType() string

func (AuthDTO) GetValuePrefix 

func (w AuthDTO) GetValuePrefix() string

func (AuthDTO) GetValues 

func (w AuthDTO) GetValues() url.Values

type AuthMetadata 

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

func (*AuthMetadata) GetHeaders 

func (w *AuthMetadata) GetHeaders() []string

func (*AuthMetadata) ToMap 

func (w *AuthMetadata) ToMap() map[string]interface{}

type AuthUtility 

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

func (AuthUtility) ActivateAuth 

func (w AuthUtility) ActivateAuth(authCtx *AuthCtx, principal string, authType string)

func (AuthUtility) ApiTokenAuth 

func (w AuthUtility) ApiTokenAuth(authCtx *AuthCtx, httpContext netutils.HTTPContext, enforceBearer bool) (*http.Client, error)

func (AuthUtility) AuthRevoke 

func (w AuthUtility) AuthRevoke(authCtx *AuthCtx) error

func (AuthUtility) AwsSigningAuth 

func (w AuthUtility) AwsSigningAuth(authCtx *AuthCtx, httpContext netutils.HTTPContext) (*http.Client, error)

func (AuthUtility) AzureDefaultAuth 

func (w AuthUtility) AzureDefaultAuth(authCtx *AuthCtx, httpContext netutils.HTTPContext) (*http.Client, error)

func (AuthUtility) BasicAuth 

func (w AuthUtility) BasicAuth(authCtx *AuthCtx, httpContext netutils.HTTPContext) (*http.Client, error)

func (AuthUtility) CustomAuth 

func (w AuthUtility) CustomAuth(authCtx *AuthCtx, httpContext netutils.HTTPContext) (*http.Client, error)

func (AuthUtility) GCloudOAuth 

func (w AuthUtility) GCloudOAuth(runtimeCtx RuntimeCtx, authCtx *AuthCtx, enforceRevokeFirst bool) (*http.Client, error)

func (AuthUtility) GenericOauthClientCredentials 

func (w AuthUtility) GenericOauthClientCredentials(authCtx *AuthCtx, scopes []string, httpContext netutils.HTTPContext) (*http.Client, error)

func (AuthUtility) GetCurrentGCloudOauthUser 

func (w AuthUtility) GetCurrentGCloudOauthUser() ([]byte, error)

func (AuthUtility) GoogleOauthServiceAccount 

func (w AuthUtility) GoogleOauthServiceAccount(provider string, authCtx *AuthCtx, scopes []string, httpContext netutils.HTTPContext) (*http.Client, error)

func (AuthUtility) ParseServiceAccountFile 

func (w AuthUtility) ParseServiceAccountFile(ac *AuthCtx) (any, error)

type Column 

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

func (Column) GetName 

func (w Column) GetName() string

func (Column) GetSchema 

func (w Column) GetSchema() Schema

func (Column) GetWidth 

func (w Column) GetWidth() int

type ColumnDescriptor 

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
}

func NewColumnDescriptor 

func NewColumnDescriptor(alias string, name string, qualifier string, decoratedCol string, node sqlparser.SQLNode, schema anysdk.Schema, val *sqlparser.SQLVal) ColumnDescriptor

type ControlAttributes 

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

func (ControlAttributes) GetControlGCStatusColumnName 

func (w ControlAttributes) GetControlGCStatusColumnName() string

func (ControlAttributes) GetControlGenIDColumnName 

func (w ControlAttributes) GetControlGenIDColumnName() string

func (ControlAttributes) GetControlInsIDColumnName 

func (w ControlAttributes) GetControlInsIDColumnName() string

func (ControlAttributes) GetControlInsertEncodedIDColumnName 

func (w ControlAttributes) GetControlInsertEncodedIDColumnName() string

func (ControlAttributes) GetControlLatestUpdateColumnName 

func (w ControlAttributes) GetControlLatestUpdateColumnName() string

func (ControlAttributes) GetControlMaxTxnColumnName 

func (w ControlAttributes) GetControlMaxTxnColumnName() string

func (ControlAttributes) GetControlSsnIDColumnName 

func (w ControlAttributes) GetControlSsnIDColumnName() string

func (ControlAttributes) GetControlTxnIDColumnName 

func (w ControlAttributes) GetControlTxnIDColumnName() string

type DataFlowCfg 

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

func (DataFlowCfg) GetMaxDependencies 

func (w DataFlowCfg) GetMaxDependencies() int

type ExecPayload 

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

func (ExecPayload) GetPayloadMap 

func (w ExecPayload) GetPayloadMap() map[string]interface{}

type ExecutionResponse 

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

func (ExecutionResponse) GetStdErr 

func (w ExecutionResponse) GetStdErr() (*bytes.Buffer, bool)

func (ExecutionResponse) GetStdOut 

func (w ExecutionResponse) GetStdOut() (*bytes.Buffer, bool)

type Executor 

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

func (Executor) Execute 

func (w Executor) Execute(p0 map[string]any) (ExecutionResponse, error)

type ExpectedRequest 

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

func (ExpectedRequest) GetBodyMediaType 

func (w ExpectedRequest) GetBodyMediaType() string

type ExpectedResponse 

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

func (ExpectedResponse) GetObjectKey 

func (w ExpectedResponse) GetObjectKey() string

func (ExpectedResponse) GetTransform 

func (w ExpectedResponse) GetTransform() (Transform, bool)

type GQLReader 

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

func (GQLReader) Read 

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

type GraphQL 

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

func (GraphQL) GetCursorJSONPath 

func (w GraphQL) GetCursorJSONPath() (string, bool)

func (GraphQL) GetQuery 

func (w GraphQL) GetQuery() string

func (GraphQL) GetResponseJSONPath 

func (w GraphQL) GetResponseJSONPath() (string, bool)

type HTTPArmoury 

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

func (HTTPArmoury) GetRequestParams 

func (w HTTPArmoury) GetRequestParams() []HTTPArmouryParameters

func (HTTPArmoury) SetRequestParams 

func (w HTTPArmoury) SetRequestParams(p0 []HTTPArmouryParameters)

type HTTPArmouryParameters 

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

func (HTTPArmouryParameters) Encode 

func (w HTTPArmouryParameters) Encode() string

func (HTTPArmouryParameters) GetArgList 

func (w HTTPArmouryParameters) GetArgList() client.AnySdkArgList

func (HTTPArmouryParameters) GetParameters 

func (w HTTPArmouryParameters) GetParameters() HttpParameters

func (HTTPArmouryParameters) GetQuery 

func (w HTTPArmouryParameters) GetQuery() url.Values

func (HTTPArmouryParameters) GetRequest 

func (w HTTPArmouryParameters) GetRequest() *http.Request

func (HTTPArmouryParameters) SetNextPage 

func (w HTTPArmouryParameters) SetNextPage(ops OperationStore, token string, tokenKey HTTPElement) (*http.Request, error)

func (HTTPArmouryParameters) SetRawQuery 

func (w HTTPArmouryParameters) SetRawQuery(p0 string)

func (HTTPArmouryParameters) ToFlatMap 

func (w HTTPArmouryParameters) ToFlatMap() (map[string]interface{}, error)

type HTTPElement 

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

func (HTTPElement) GetName 

func (w HTTPElement) GetName() string

func (HTTPElement) GetType 

func (w HTTPElement) GetType() internaldto.HTTPElementType

func (HTTPElement) IsTransformerPresent 

func (w HTTPElement) IsTransformerPresent() bool

func (HTTPElement) SetTransformer 

func (w HTTPElement) SetTransformer(transformer func(interface{}) (interface{}, error))

func (HTTPElement) Transformer 

func (w HTTPElement) Transformer(t interface{}) (interface{}, error)

type HTTPHTTPElement 

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

func (HTTPHTTPElement) GetLocation 

func (w HTTPHTTPElement) GetLocation() httpelement.HTTPElementLocation

func (HTTPHTTPElement) GetName 

func (w HTTPHTTPElement) GetName() string

type HTTPPreparator 

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

func (HTTPPreparator) BuildHTTPRequestCtx 

func (w HTTPPreparator) BuildHTTPRequestCtx(p0 anysdk.HTTPPreparatorConfig) (HTTPArmoury, error)

type HttpParameters 

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

func (HttpParameters) GetInlineParameterFlatMap 

func (w HttpParameters) GetInlineParameterFlatMap() (map[string]interface{}, error)

func (HttpParameters) ToFlatMap 

func (w HttpParameters) ToFlatMap() (map[string]interface{}, error)

type HttpPreparatorStream 

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

func (HttpPreparatorStream) Next 

func (w HttpPreparatorStream) Next() (HTTPPreparator, bool)

func (HttpPreparatorStream) Write 

func (w HttpPreparatorStream) Write(p0 HTTPPreparator) error

type IDiscoveryAdapter 

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

func (IDiscoveryAdapter) GetProvider 

func (w IDiscoveryAdapter) GetProvider(providerKey string) (Provider, error)

func (IDiscoveryAdapter) GetResourcesMap 

func (w IDiscoveryAdapter) GetResourcesMap(prov Provider, serviceKey string) (map[string]Resource, error)

func (IDiscoveryAdapter) GetServiceHandlesMap 

func (w IDiscoveryAdapter) GetServiceHandlesMap(prov Provider) (map[string]ProviderService, error)

func (IDiscoveryAdapter) GetServiceShard 

func (w IDiscoveryAdapter) GetServiceShard(prov Provider, serviceKey string, resourceKey string) (Service, error)

func (IDiscoveryAdapter) PersistStaticExternalSQLDataSource 

func (w IDiscoveryAdapter) PersistStaticExternalSQLDataSource(prov Provider) error

type ITable 

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

func (ITable) GetKey 

func (w ITable) GetKey(p0 string) (interface{}, error)

func (ITable) GetKeyAsSqlVal 

func (w ITable) GetKeyAsSqlVal(p0 string) (sqltypes.Value, error)

func (ITable) GetName 

func (w ITable) GetName() string

func (ITable) KeyExists 

func (w ITable) KeyExists(p0 string) bool

type InsertPreparator 

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

func (InsertPreparator) ActionInsertPreparation 

func (w InsertPreparator) ActionInsertPreparation(payload ActionInsertPayload) ActionInsertResult

type Invoker 

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

func (Invoker) Invoke 

func (w Invoker) Invoke(ctx context.Context, req providerinvoker.Request) (providerinvoker.Result, error)

type ItemisationResult 

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

func (ItemisationResult) GetItems 

func (w ItemisationResult) GetItems() (interface{}, bool)

type MapReader 

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

func (MapReader) Read 

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

type MapStream 

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

func (MapStream) Write 

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

type MapStreamCollection 

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

func (MapStreamCollection) Len 

func (w MapStreamCollection) Len() int

func (MapStreamCollection) Push 

func (w MapStreamCollection) Push(p0 MapStream)

type MethodAnalysisOutput 

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

func (MethodAnalysisOutput) GetInsertTabulation 

func (w MethodAnalysisOutput) GetInsertTabulation() Tabulation

func (MethodAnalysisOutput) GetItemSchema 

func (w MethodAnalysisOutput) GetItemSchema() (Schema, bool)

func (MethodAnalysisOutput) GetOrderedStarColumnsNames 

func (w MethodAnalysisOutput) GetOrderedStarColumnsNames() ([]string, error)

func (MethodAnalysisOutput) GetSelectTabulation 

func (w MethodAnalysisOutput) GetSelectTabulation() Tabulation

func (MethodAnalysisOutput) IsAwait 

func (w MethodAnalysisOutput) IsAwait() bool

func (MethodAnalysisOutput) IsNilResponseAllowed 

func (w MethodAnalysisOutput) IsNilResponseAllowed() bool

type MethodAnalyzer 

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

func (MethodAnalyzer) AnalyzeUnaryAction 

func (w MethodAnalyzer) AnalyzeUnaryAction(p0 anysdk.MethodAnalysisInput) (MethodAnalysisOutput, error)

type Methods 

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

func (Methods) OrderMethods 

func (w Methods) OrderMethods() ([]StandardOperationStore, error)

type NameMangler 

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

func (NameMangler) MangleName 

func (w NameMangler) MangleName(p0 string, p1 ...any) string

type NamespaceCfg 

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

func (NamespaceCfg) GetRegex 

func (w NamespaceCfg) GetRegex() (*regexp.Regexp, error)

func (NamespaceCfg) GetTemplate 

func (w NamespaceCfg) GetTemplate() (*template.Template, error)

type OperationInverse 

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

func (OperationInverse) GetOperationStore 

func (w OperationInverse) GetOperationStore() (StandardOperationStore, bool)

type OperationStore 

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

func (OperationStore) DeprecatedProcessResponse 

func (w OperationStore) DeprecatedProcessResponse(response *http.Response) (map[string]interface{}, error)

func (OperationStore) GetName 

func (w OperationStore) GetName() string

func (OperationStore) GetNonBodyParameters 

func (w OperationStore) GetNonBodyParameters() map[string]Addressable

func (OperationStore) GetPaginationRequestTokenSemantic 

func (w OperationStore) GetPaginationRequestTokenSemantic() (TokenSemantic, bool)

func (OperationStore) GetPaginationResponseTokenSemantic 

func (w OperationStore) GetPaginationResponseTokenSemantic() (TokenSemantic, bool)

func (OperationStore) GetParameter 

func (w OperationStore) GetParameter(paramKey string) (Addressable, bool)

func (OperationStore) GetRequestBodySchema 

func (w OperationStore) GetRequestBodySchema() (Schema, error)

func (OperationStore) GetRequiredNonBodyParameters 

func (w OperationStore) GetRequiredNonBodyParameters() map[string]Addressable

func (OperationStore) GetRequiredParameters 

func (w OperationStore) GetRequiredParameters() map[string]Addressable

func (OperationStore) GetResource 

func (w OperationStore) GetResource() Resource

func (OperationStore) GetResponseBodySchemaAndMediaType 

func (w OperationStore) GetResponseBodySchemaAndMediaType() (Schema, string, error)

func (OperationStore) GetSelectItemsKey 

func (w OperationStore) GetSelectItemsKey() string

func (OperationStore) GetService 

func (w OperationStore) GetService() anysdk.OpenAPIService

func (OperationStore) IsRequestBodyAttributeRenamed 

func (w OperationStore) IsRequestBodyAttributeRenamed(p0 string) bool

func (OperationStore) IsRequiredRequestBodyProperty 

func (w OperationStore) IsRequiredRequestBodyProperty(key string) bool

func (OperationStore) ProcessResponse 

func (w OperationStore) ProcessResponse(p0 *http.Response) (ProcessedOperationResponse, error)

func (OperationStore) RenameRequestBodyAttribute 

func (w OperationStore) RenameRequestBodyAttribute(p0 string) (string, error)

func (OperationStore) RevertRequestBodyAttributeRename 

func (w OperationStore) RevertRequestBodyAttributeRename(p0 string) (string, error)

type OutputPacket 

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

func (OutputPacket) GetColumnNames 

func (w OutputPacket) GetColumnNames() []string

func (OutputPacket) GetColumnOIDs 

func (w OutputPacket) GetColumnOIDs() []oid.Oid

func (OutputPacket) GetRawRows 

func (w OutputPacket) GetRawRows() map[int]map[int]interface{}

func (OutputPacket) GetRows 

func (w OutputPacket) GetRows() map[string]map[string]interface{}

type PgTLSCfg 

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

func (PgTLSCfg) GetKeyPair 

func (w PgTLSCfg) GetKeyPair() (tls.Certificate, error)

type ProcessedOperationResponse 

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

func (ProcessedOperationResponse) GetResponse 

func (w ProcessedOperationResponse) GetResponse() (Response, bool)

func (ProcessedOperationResponse) GetReversal 

func (w ProcessedOperationResponse) GetReversal() (HTTPPreparator, bool)

type Provider 

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

func (Provider) GetAuth 

func (w Provider) GetAuth() (AuthDTO, bool)

func (Provider) GetDeleteItemsKey 

func (w Provider) GetDeleteItemsKey() string

func (Provider) GetMinStackQLVersion 

func (w Provider) GetMinStackQLVersion() string

func (Provider) GetName 

func (w Provider) GetName() string

func (Provider) GetProtocolType 

func (w Provider) GetProtocolType() (client.ClientProtocolType, error)

type ProviderDescription 

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

func (ProviderDescription) GetLatestVersion 

func (w ProviderDescription) GetLatestVersion() (string, error)

type ProviderService 

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

func (ProviderService) GetDescription 

func (w ProviderService) GetDescription() string

func (ProviderService) GetID 

func (w ProviderService) GetID() string

func (ProviderService) GetName 

func (w ProviderService) GetName() string

func (ProviderService) GetTitle 

func (w ProviderService) GetTitle() string

func (ProviderService) GetVersion 

func (w ProviderService) GetVersion() string

func (ProviderService) IsPreferred 

func (w ProviderService) IsPreferred() bool

type RegistryAPI 

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

func (RegistryAPI) ClearProviderCache 

func (w RegistryAPI) ClearProviderCache(p0 string) error

func (RegistryAPI) GetLatestPublishedVersion 

func (w RegistryAPI) GetLatestPublishedVersion(p0 string) (string, error)

func (RegistryAPI) ListAllAvailableProviders 

func (w RegistryAPI) ListAllAvailableProviders() (map[string]ProviderDescription, error)

func (RegistryAPI) ListAllProviderVersions 

func (w RegistryAPI) ListAllProviderVersions(p0 string) (map[string]ProviderDescription, error)

func (RegistryAPI) ListLocallyAvailableProviders 

func (w RegistryAPI) ListLocallyAvailableProviders() map[string]ProviderDescription

func (RegistryAPI) LoadProviderByName 

func (w RegistryAPI) LoadProviderByName(p0 string, p1 string) (Provider, error)

func (RegistryAPI) PullAndPersistProviderArchive 

func (w RegistryAPI) PullAndPersistProviderArchive(p0 string, p1 string) error

func (RegistryAPI) RemoveProviderVersion 

func (w RegistryAPI) RemoveProviderVersion(p0 string, p1 string) error

type Relation 

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

func (Relation) GetColumnDescriptors 

func (w Relation) GetColumnDescriptors() []anysdk.ColumnDescriptor

func (Relation) GetColumns 

func (w Relation) GetColumns() []Column

type Resource 

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

func (Resource) FindMethod 

func (w Resource) FindMethod(key string) (StandardOperationStore, error)

func (Resource) GetFirstMethodFromSQLVerb 

func (w Resource) GetFirstMethodFromSQLVerb(sqlVerb string) (StandardOperationStore, string, bool)

func (Resource) GetFirstNamespaceMethodMatchFromSQLVerb 

func (w Resource) GetFirstNamespaceMethodMatchFromSQLVerb(sqlVerb string, parameters map[string]interface{}) (StandardOperationStore, map[string]interface{}, bool)

func (Resource) GetID 

func (w Resource) GetID() string

func (Resource) GetMethodsMatched 

func (w Resource) GetMethodsMatched() Methods

func (Resource) GetName 

func (w Resource) GetName() string

func (Resource) GetViewsForSqlDialect 

func (w Resource) GetViewsForSqlDialect(sqlDialect string) ([]View, bool)

func (Resource) ToMap 

func (w Resource) ToMap(extended bool) map[string]interface{}

type Response 

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

func (Response) Error 

func (w Response) Error() string

func (Response) ExtractElement 

func (w Response) ExtractElement(e HTTPHTTPElement) (interface{}, error)

TODO: fix this crap

func (Response) GetHttpResponse 

func (w Response) GetHttpResponse() *http.Response

func (Response) GetProcessedBody 

func (w Response) GetProcessedBody() interface{}

func (Response) HasError 

func (w Response) HasError() bool

type RuntimeCtx 

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

func (RuntimeCtx) Copy 

func (w RuntimeCtx) Copy() RuntimeCtx

type SQLBackendCfg 

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

func (SQLBackendCfg) GetDatabaseName 

func (w SQLBackendCfg) GetDatabaseName() (string, error)

func (SQLBackendCfg) GetIntelViewSchemaName 

func (w SQLBackendCfg) GetIntelViewSchemaName() string

func (SQLBackendCfg) GetOpsViewSchemaName 

func (w SQLBackendCfg) GetOpsViewSchemaName() string

func (SQLBackendCfg) GetSQLDialect 

func (w SQLBackendCfg) GetSQLDialect() string

func (SQLBackendCfg) GetSchemaType 

func (w SQLBackendCfg) GetSchemaType() string

func (SQLBackendCfg) GetTableSchemaName 

func (w SQLBackendCfg) GetTableSchemaName() string

type SQLEngine 

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

func (SQLEngine) CacheStoreGet 

func (w SQLEngine) CacheStoreGet(p0 string) ([]byte, error)

func (SQLEngine) CacheStorePut 

func (w SQLEngine) CacheStorePut(p0 string, p1 []byte, p2 string, p3 int) error

func (SQLEngine) Exec 

func (w SQLEngine) Exec(p0 string, p1 ...interface{}) (sql.Result, error)

func (SQLEngine) ExecInTxn 

func (w SQLEngine) ExecInTxn(queries []string) error

func (SQLEngine) GetCurrentDiscoveryGenerationID 

func (w SQLEngine) GetCurrentDiscoveryGenerationID(discoveryID string) (int, error)

func (SQLEngine) GetCurrentGenerationID 

func (w SQLEngine) GetCurrentGenerationID() (int, error)

func (SQLEngine) GetDB 

func (w SQLEngine) GetDB() (*sql.DB, error)

func (SQLEngine) GetNextDiscoveryGenerationID 

func (w SQLEngine) GetNextDiscoveryGenerationID(discoveryID string) (int, error)

func (SQLEngine) GetNextGenerationID 

func (w SQLEngine) GetNextGenerationID() (int, error)

func (SQLEngine) GetNextSessionID 

func (w SQLEngine) GetNextSessionID(p0 int) (int, error)

func (SQLEngine) GetTx 

func (w SQLEngine) GetTx() (*sql.Tx, error)

func (SQLEngine) Query 

func (w SQLEngine) Query(p0 string, p1 ...interface{}) (*sql.Rows, error)

func (SQLEngine) QueryRow 

func (w SQLEngine) QueryRow(query string, args ...any) *sql.Row

type SQLExternalColumn 

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

func (SQLExternalColumn) GetName 

func (w SQLExternalColumn) GetName() string

func (SQLExternalColumn) GetOid 

func (w SQLExternalColumn) GetOid() uint32

func (SQLExternalColumn) GetPrecision 

func (w SQLExternalColumn) GetPrecision() int

func (SQLExternalColumn) GetType 

func (w SQLExternalColumn) GetType() string

func (SQLExternalColumn) GetWidth 

func (w SQLExternalColumn) GetWidth() int

type SQLExternalTable 

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

func (SQLExternalTable) GetCatalogName 

func (w SQLExternalTable) GetCatalogName() string

func (SQLExternalTable) GetColumns 

func (w SQLExternalTable) GetColumns() []SQLExternalColumn

func (SQLExternalTable) GetName 

func (w SQLExternalTable) GetName() string

func (SQLExternalTable) GetSchemaName 

func (w SQLExternalTable) GetSchemaName() string

type Schema 

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

func (Schema) FindByPath 

func (w Schema) FindByPath(path string, visited map[string]bool) Schema

func (Schema) GetAdditionalProperties 

func (w Schema) GetAdditionalProperties() (Schema, bool)

func (Schema) GetAllColumns 

func (w Schema) GetAllColumns(p0 string) []string

func (Schema) GetItemsSchema 

func (w Schema) GetItemsSchema() (Schema, error)

func (Schema) GetName 

func (w Schema) GetName() string

func (Schema) GetProperties 

func (w Schema) GetProperties() (anysdk.Schemas, error)

func (Schema) GetProperty 

func (w Schema) GetProperty(propertyKey string) (Schema, bool)

func (Schema) GetPropertySchema 

func (w Schema) GetPropertySchema(key string) (Schema, error)

func (Schema) GetSelectSchema 

func (w Schema) GetSelectSchema(itemsKey string, mediaType string) (Schema, string, error)

func (Schema) GetSelectionName 

func (w Schema) GetSelectionName() string

func (Schema) GetTitle 

func (w Schema) GetTitle() string

func (Schema) GetType 

func (w Schema) GetType() string

func (Schema) IsBoolean 

func (w Schema) IsBoolean() bool

func (Schema) IsFloat 

func (w Schema) IsFloat() bool

func (Schema) IsIntegral 

func (w Schema) IsIntegral() bool

func (Schema) IsReadOnly 

func (w Schema) IsReadOnly() bool

func (Schema) IsRequired 

func (w Schema) IsRequired(key string) bool

func (Schema) SetKey 

func (w Schema) SetKey(p0 string)

func (Schema) Tabulate 

func (w Schema) Tabulate(p0 bool, p1 string) Tabulation

func (Schema) ToDescriptionMap 

func (w Schema) ToDescriptionMap(extended bool) map[string]interface{}

type Service 

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

func (Service) GetResource 

func (w Service) GetResource(resourceName string) (Resource, error)

func (Service) GetSchema 

func (w Service) GetSchema(key string) (Schema, error)

func (Service) GetServers 

func (w Service) GetServers() (openapi3.Servers, bool)

type SessionContext 

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

func (SessionContext) GetIsolationLevel 

func (w SessionContext) GetIsolationLevel() constants.IsolationLevel

func (SessionContext) GetRollbackType 

func (w SessionContext) GetRollbackType() constants.RollbackType

func (SessionContext) UpdateIsolationLevel 

func (w SessionContext) UpdateIsolationLevel(p0 string) error

type StandardOperationStore 

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

func (StandardOperationStore) GetAddressSpace 

func (w StandardOperationStore) GetAddressSpace() (AddressSpace, bool)

func (StandardOperationStore) GetColumnOrder 

func (w StandardOperationStore) GetColumnOrder(extended bool) []string

func (StandardOperationStore) GetGraphQL 

func (w StandardOperationStore) GetGraphQL() GraphQL

func (StandardOperationStore) GetInline 

func (w StandardOperationStore) GetInline() []string

func (StandardOperationStore) GetInverse 

func (w StandardOperationStore) GetInverse() (OperationInverse, bool)

func (StandardOperationStore) GetName 

func (w StandardOperationStore) GetName() string

func (StandardOperationStore) GetOptionalParameters 

func (w StandardOperationStore) GetOptionalParameters() map[string]Addressable

func (StandardOperationStore) GetPaginationRequestTokenSemantic 

func (w StandardOperationStore) GetPaginationRequestTokenSemantic() (TokenSemantic, bool)

func (StandardOperationStore) GetPaginationResponseTokenSemantic 

func (w StandardOperationStore) GetPaginationResponseTokenSemantic() (TokenSemantic, bool)

func (StandardOperationStore) GetParameter 

func (w StandardOperationStore) GetParameter(paramKey string) (Addressable, bool)

func (StandardOperationStore) GetProjections 

func (w StandardOperationStore) GetProjections() map[string]string

func (StandardOperationStore) GetRequest 

func (w StandardOperationStore) GetRequest() (ExpectedRequest, bool)

func (StandardOperationStore) GetRequestBodySchema 

func (w StandardOperationStore) GetRequestBodySchema() (Schema, error)

func (StandardOperationStore) GetRequiredParameters 

func (w StandardOperationStore) GetRequiredParameters() map[string]Addressable

func (StandardOperationStore) GetResponse 

func (w StandardOperationStore) GetResponse() (ExpectedResponse, bool)

func (StandardOperationStore) GetResponseBodySchemaAndMediaType 

func (w StandardOperationStore) GetResponseBodySchemaAndMediaType() (Schema, string, error)

func (StandardOperationStore) GetSelectItemsKey 

func (w StandardOperationStore) GetSelectItemsKey() string

func (StandardOperationStore) GetSelectSchemaAndObjectPath 

func (w StandardOperationStore) GetSelectSchemaAndObjectPath() (Schema, string, error)

func (StandardOperationStore) GetServers 

func (w StandardOperationStore) GetServers() (openapi3.Servers, bool)

func (StandardOperationStore) IsAwaitable 

func (w StandardOperationStore) IsAwaitable() bool

func (StandardOperationStore) IsNullary 

func (w StandardOperationStore) IsNullary() bool

func (StandardOperationStore) ToPresentationMap 

func (w StandardOperationStore) ToPresentationMap(extended bool) map[string]interface{}

type StreamTransformer 

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

func (StreamTransformer) GetOutStream 

func (w StreamTransformer) GetOutStream() io.Reader

func (StreamTransformer) Transform 

func (w StreamTransformer) Transform() error

type StreamTransformerFactory 

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

func (StreamTransformerFactory) GetTransformer 

func (w StreamTransformerFactory) GetTransformer(input string) (StreamTransformer, error)

func (StreamTransformerFactory) IsTransformable 

func (w StreamTransformerFactory) IsTransformable() bool

type Tabulation 

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

func (Tabulation) GetColumns 

func (w Tabulation) GetColumns() []anysdk.ColumnDescriptor

func (Tabulation) PushBackColumn 

func (w Tabulation) PushBackColumn(col anysdk.ColumnDescriptor)

func (Tabulation) RenameColumnsToXml 

func (w Tabulation) RenameColumnsToXml() Tabulation

type TokenSemantic 

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

func (TokenSemantic) GetKey 

func (w TokenSemantic) GetKey() string

func (TokenSemantic) GetLocation 

func (w TokenSemantic) GetLocation() string

func (TokenSemantic) GetTransformer 

func (w TokenSemantic) GetTransformer() (anysdk.TokenTransformer, error)

type Transform 

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

func (Transform) GetBody 

func (w Transform) GetBody() string

func (Transform) GetType 

func (w Transform) GetType() string

type TxnCoordinatorCfg 

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

func (TxnCoordinatorCfg) GetMaxTxnDepth 

func (w TxnCoordinatorCfg) GetMaxTxnDepth() int

type View 

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

func (View) GetDDL 

func (w View) GetDDL() string

func (View) GetNameNaive 

func (w View) GetNameNaive() string

func (View) GetRequiredParamNames 

func (w View) GetRequiredParamNames() []string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.