internaldto

type BackendMessages interface {
	AppendMessages([]string)
	GetMessages() []string
}

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

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

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

type ExecutorOutput interface {
	GetSQLResult() sqldata.ISQLResultStream
	GetRawResult() IRawResultStream
	GetOutputBody() map[string]interface{}
	GetStream() streaming.MapStream
	SetStream(s streaming.MapStream)
	ResultToMap() (IRawResultStream, error)
	GetError() error
	SetSQLResultFn(f func() sqldata.ISQLResultStream)
	SetRawResultFn(f func() IRawResultStream)
	SetOutputBodyFn(f func() map[string]interface{})
	GetMessages() []string
	AppendMessages(m []string)
	GetUndoLog() (binlog.LogEntry, bool)
	GetRedoLog() (binlog.LogEntry, bool)
	SetUndoLog(binlog.LogEntry)
	SetRedoLog(binlog.LogEntry)
	WithUndoLog(binlog.LogEntry) ExecutorOutput
	WithRedoLog(binlog.LogEntry) ExecutorOutput
}

type Heirarchy interface {
	GetServiceHdl() anysdk.Service
	GetResource() anysdk.Resource
	GetMethodSet() anysdk.MethodSet
	GetMethod() anysdk.OperationStore
	SetServiceHdl(anysdk.Service)
	SetResource(anysdk.Resource)
	SetMethodSet(anysdk.MethodSet)
	SetMethod(anysdk.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() (RelationDTO, bool)
	GetSubAST() sqlparser.Statement
	ContainsNativeDBMSTable() bool
	SetContainsNativeDBMSTable(bool)
	SetSubAST(sqlparser.Statement)
	SetMethodStr(string)
	WithView(RelationDTO) HeirarchyIdentifiers

	WithProviderStr(string) HeirarchyIdentifiers
	WithResponseSchemaStr(rss string) HeirarchyIdentifiers
	IsPgInternalObject() bool
	IsPhysicalTable() bool
	SetIsPhysicalTable(isPhysical bool)
	SetIsMaterializedView(isMaterialized bool)
	IsMaterializedView() bool
	// 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 PrepStmt interface {
	GetRawQuery() string
	GetArgs() []any
}

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
	TypCfg      typing.Config
}

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

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

type RelationDTO interface {
	GetRawQuery() string
	GetName() string
	IsMaterialized() bool
	IsTable() bool
	GetColumns() []typing.RelationalColumn
	SetColumns(columns []typing.RelationalColumn)
}

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)
	CloneAndIncrementInsertID() TxnControlCounters
}