internaldto

type BackendMessages struct {
	WorkingMessages []string
}

type BasicPrimitiveContext interface {
	GetAuthContext(prov string) (*dto.AuthCtx, error)
	GetErrWriter() io.Writer
	GetWriter() io.Writer
}

type ColumnMetadata interface {
	GetColumnOID() oid.Oid
	GetIdentifier() string
	GetName() string
	GetDecorated() string
	GetRelationalType() string
	GetType() string
}

type DBTable interface {
	GetBaseName() string
	GetDiscoveryID() int
	GetHeirarchyIdentifiers() HeirarchyIdentifiers
	IsAnalytics() bool
	GetName() string
	GetNameStump() string
}

type DRMCoupling interface {
	GetRelationalType() string
	GetGolangKind() reflect.Kind
}

type ExecPayload interface {
	GetHeader() map[string][]string
	GetPayload() []byte
	GetPayloadMap() map[string]interface{}
	SetHeaderKV(k string, v []string)
}

type ExecutorOutput struct {
	GetSQLResult  func() sqldata.ISQLResultStream
	GetRawResult  func() IRawResultStream
	GetOutputBody func() map[string]interface{}

	Msg *BackendMessages
	Err error
	// contains filtered or unexported fields
}

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

type HTTPElementType int

type Heirarchy interface {
	GetServiceHdl() *openapistackql.Service
	GetResource() *openapistackql.Resource
	GetMethodSet() openapistackql.MethodSet
	GetMethod() *openapistackql.OperationStore
	SetServiceHdl(*openapistackql.Service)
	SetResource(*openapistackql.Resource)
	SetMethodSet(openapistackql.MethodSet)
	SetMethod(*openapistackql.OperationStore)
	SetMethodStr(string)
}

type HeirarchyIdentifiers interface {
	GetMethodStr() string
	GetProviderStr() string
	GetServiceStr() string
	GetResourceStr() string
	GetResponseSchemaStr() string
	GetSQLDataSourceTableName() string
	GetStackQLTableName() string
	GetTableName() string
	GetSubquery() (SubqueryDTO, bool)
	GetView() (ViewDTO, bool)
	GetSubAST() sqlparser.Statement
	ContainsNativeDBMSTable() bool
	SetContainsNativeDBMSTable(bool)
	SetSubAST(sqlparser.Statement)
	SetMethodStr(string)
	WithView(ViewDTO) HeirarchyIdentifiers

	WithProviderStr(string) HeirarchyIdentifiers
	WithResponseSchemaStr(rss string) HeirarchyIdentifiers
	// contains filtered or unexported methods
}

type IRawResultStream interface {
	Read() (RawResult, error)
	IsNil() bool
}

type KeyVal struct {
	K string
	V []byte
}

type OutputContext struct {
	RuntimeContext dto.RuntimeCtx
	Result         sqldata.ISQLResultStream
}

type PrepareResultSetDTO struct {
	OutputBody  map[string]interface{}
	Msg         *BackendMessages
	RawRows     map[int]map[int]interface{}
	RowMap      map[string]map[string]interface{}
	ColumnOrder []string
	ColumnOIDs  []oid.Oid
	RowSort     func(map[string]map[string]interface{}) []string
	Err         error
}

type RawMap map[int]map[int]interface{}

type RawResult interface {
	GetMap() (RawMap, error)
}

type RowsDTO struct {
	RowMap      map[string]map[string]interface{}
	ColumnOrder []string
	Err         error
	RowSort     func(map[string]map[string]interface{}) []string
}

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

type SubqueryDTO interface {
	GetSubquery() *sqlparser.Subquery
	GetAlias() sqlparser.TableIdent
	GetAliasedTableExpr() *sqlparser.AliasedTableExpr
}

type TableParameterCollection interface {
	GetOptionalParams() suffix.ParameterSuffixMap
	GetRemainingRequiredParams() suffix.ParameterSuffixMap
	GetRequiredParams() suffix.ParameterSuffixMap
}

type TxnControlCounters interface {
	GetGenID() int
	GetInsertID() int
	GetSessionID() int
	GetTxnID() int
	SetTableName(string)
	SetTxnID(int)
	Clone() TxnControlCounters
	Copy(TxnControlCounters) TxnControlCounters
	CloneAndIncrementInsertID() TxnControlCounters
}

type ViewDTO interface {
	GetRawQuery() string
	GetName() string
}