Documentation ¶
Index ¶
- type HTTPRestPrimitive
- func (pr *HTTPRestPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput
- func (pr *HTTPRestPrimitive) GetInputFromAlias(alias string) (internaldto.ExecutorOutput, bool)
- func (pr *HTTPRestPrimitive) GetRedoLog() (binlog.LogEntry, bool)
- func (pr *HTTPRestPrimitive) GetUndoLog() (binlog.LogEntry, bool)
- func (pr *HTTPRestPrimitive) ID() int64
- func (pr *HTTPRestPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error
- func (pr *HTTPRestPrimitive) IsReadOnly() bool
- func (pr *HTTPRestPrimitive) Optimise() error
- func (pr *HTTPRestPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error
- func (pr *HTTPRestPrimitive) SetInputAlias(alias string, id int64) error
- func (pr *HTTPRestPrimitive) SetRedoLog(log binlog.LogEntry)
- func (pr *HTTPRestPrimitive) SetTxnID(id int)
- func (pr *HTTPRestPrimitive) SetUndoLog(log binlog.LogEntry)
- type IPrimitive
- func NewHTTPRestPrimitive(provider provider.IProvider, ...) IPrimitive
- func NewLocalPrimitive(executor func(pc IPrimitiveCtx) internaldto.ExecutorOutput) IPrimitive
- func NewMetaDataPrimitive(provider provider.IProvider, ...) IPrimitive
- func NewPassThroughPrimitive(sqlSystem sql_system.SQLSystem, ...) IPrimitive
- type IPrimitiveCtx
- type LocalPrimitive
- func (pr *LocalPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput
- func (pr *LocalPrimitive) GetInputFromAlias(string) (internaldto.ExecutorOutput, bool)
- func (pr *LocalPrimitive) GetRedoLog() (binlog.LogEntry, bool)
- func (pr *LocalPrimitive) GetUndoLog() (binlog.LogEntry, bool)
- func (pr *LocalPrimitive) ID() int64
- func (pr *LocalPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error
- func (pr *LocalPrimitive) IsReadOnly() bool
- func (pr *LocalPrimitive) Optimise() error
- func (pr *LocalPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error
- func (pr *LocalPrimitive) SetInputAlias(_ string, _ int64) error
- func (pr *LocalPrimitive) SetRedoLog(log binlog.LogEntry)
- func (pr *LocalPrimitive) SetTxnID(_ int)
- func (pr *LocalPrimitive) SetUndoLog(log binlog.LogEntry)
- type MetaDataPrimitive
- func (pr *MetaDataPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput
- func (pr *MetaDataPrimitive) GetInputFromAlias(string) (internaldto.ExecutorOutput, bool)
- func (pr *MetaDataPrimitive) GetRedoLog() (binlog.LogEntry, bool)
- func (pr *MetaDataPrimitive) GetUndoLog() (binlog.LogEntry, bool)
- func (pr *MetaDataPrimitive) ID() int64
- func (pr *MetaDataPrimitive) IncidentData(_ int64, _ internaldto.ExecutorOutput) error
- func (pr *MetaDataPrimitive) IsReadOnly() bool
- func (pr *MetaDataPrimitive) Optimise() error
- func (pr *MetaDataPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error
- func (pr *MetaDataPrimitive) SetInputAlias(_ string, _ int64) error
- func (pr *MetaDataPrimitive) SetRedoLog(log binlog.LogEntry)
- func (pr *MetaDataPrimitive) SetTxnID(_ int)
- func (pr *MetaDataPrimitive) SetUndoLog(log binlog.LogEntry)
- type PassThroughPrimitive
- func (pr *PassThroughPrimitive) Execute(_ IPrimitiveCtx) internaldto.ExecutorOutput
- func (pr *PassThroughPrimitive) GetInputFromAlias(string) (internaldto.ExecutorOutput, bool)
- func (pr *PassThroughPrimitive) GetRedoLog() (binlog.LogEntry, bool)
- func (pr *PassThroughPrimitive) GetUndoLog() (binlog.LogEntry, bool)
- func (pr *PassThroughPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error
- func (pr *PassThroughPrimitive) IsReadOnly() bool
- func (pr *PassThroughPrimitive) Optimise() error
- func (pr *PassThroughPrimitive) SetExecutor(func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error
- func (pr *PassThroughPrimitive) SetInputAlias(_ string, _ int64) error
- func (pr *PassThroughPrimitive) SetRedoLog(log binlog.LogEntry)
- func (pr *PassThroughPrimitive) SetTxnID(_ int)
- func (pr *PassThroughPrimitive) SetUndoLog(log binlog.LogEntry)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HTTPRestPrimitive ¶
type HTTPRestPrimitive struct { Provider provider.IProvider Executor func(pc IPrimitiveCtx) internaldto.ExecutorOutput Preparator func() drm.PreparedStatementCtx TxnControlCtr internaldto.TxnControlCounters Inputs map[int64]internaldto.ExecutorOutput InputAliases map[string]int64 // contains filtered or unexported fields }
func (*HTTPRestPrimitive) Execute ¶
func (pr *HTTPRestPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput
func (*HTTPRestPrimitive) GetInputFromAlias ¶
func (pr *HTTPRestPrimitive) GetInputFromAlias(alias string) (internaldto.ExecutorOutput, bool)
func (*HTTPRestPrimitive) GetRedoLog ¶ added in v0.5.375
func (pr *HTTPRestPrimitive) GetRedoLog() (binlog.LogEntry, bool)
func (*HTTPRestPrimitive) GetUndoLog ¶ added in v0.5.375
func (pr *HTTPRestPrimitive) GetUndoLog() (binlog.LogEntry, bool)
func (*HTTPRestPrimitive) ID ¶
func (pr *HTTPRestPrimitive) ID() int64
func (*HTTPRestPrimitive) IncidentData ¶
func (pr *HTTPRestPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error
func (*HTTPRestPrimitive) IsReadOnly ¶ added in v0.5.375
func (pr *HTTPRestPrimitive) IsReadOnly() bool
func (*HTTPRestPrimitive) Optimise ¶
func (pr *HTTPRestPrimitive) Optimise() error
func (*HTTPRestPrimitive) SetExecutor ¶
func (pr *HTTPRestPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error
func (*HTTPRestPrimitive) SetInputAlias ¶
func (pr *HTTPRestPrimitive) SetInputAlias(alias string, id int64) error
func (*HTTPRestPrimitive) SetRedoLog ¶ added in v0.5.375
func (pr *HTTPRestPrimitive) SetRedoLog(log binlog.LogEntry)
func (*HTTPRestPrimitive) SetTxnID ¶ added in v0.5.375
func (pr *HTTPRestPrimitive) SetTxnID(id int)
func (*HTTPRestPrimitive) SetUndoLog ¶ added in v0.5.375
func (pr *HTTPRestPrimitive) SetUndoLog(log binlog.LogEntry)
type IPrimitive ¶
type IPrimitive interface { Optimise() error Execute(IPrimitiveCtx) internaldto.ExecutorOutput SetExecutor(func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error SetTxnID(int) // IsReadOnly() bool // Get the redo log entry. GetRedoLog() (binlog.LogEntry, bool) // Get the undo log entry. GetUndoLog() (binlog.LogEntry, bool) // Get the redo log entry. SetRedoLog(binlog.LogEntry) // Get the undo log entry. SetUndoLog(binlog.LogEntry) IncidentData(int64, internaldto.ExecutorOutput) error SetInputAlias(string, int64) error GetInputFromAlias(string) (internaldto.ExecutorOutput, bool) }
func NewHTTPRestPrimitive ¶
func NewHTTPRestPrimitive( provider provider.IProvider, executor func(pc IPrimitiveCtx) internaldto.ExecutorOutput, preparator func() drm.PreparedStatementCtx, txnCtrlCtr internaldto.TxnControlCounters, primitiveCtx primitive_context.IPrimitiveCtx, ) IPrimitive
func NewLocalPrimitive ¶
func NewLocalPrimitive(executor func(pc IPrimitiveCtx) internaldto.ExecutorOutput) IPrimitive
func NewMetaDataPrimitive ¶
func NewMetaDataPrimitive( provider provider.IProvider, executor func(pc IPrimitiveCtx) internaldto.ExecutorOutput, ) IPrimitive
func NewPassThroughPrimitive ¶
func NewPassThroughPrimitive( sqlSystem sql_system.SQLSystem, txnControlCounterSlice []internaldto.TxnControlCounters, shouldCollectGarbage bool) IPrimitive
type IPrimitiveCtx ¶
type LocalPrimitive ¶
type LocalPrimitive struct { Executor func(pc IPrimitiveCtx) internaldto.ExecutorOutput Preparator func() *drm.PreparedStatementCtx Inputs map[int64]internaldto.ExecutorOutput // contains filtered or unexported fields }
func (*LocalPrimitive) Execute ¶
func (pr *LocalPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput
func (*LocalPrimitive) GetInputFromAlias ¶
func (pr *LocalPrimitive) GetInputFromAlias(string) (internaldto.ExecutorOutput, bool)
func (*LocalPrimitive) GetRedoLog ¶ added in v0.5.375
func (pr *LocalPrimitive) GetRedoLog() (binlog.LogEntry, bool)
func (*LocalPrimitive) GetUndoLog ¶ added in v0.5.375
func (pr *LocalPrimitive) GetUndoLog() (binlog.LogEntry, bool)
func (*LocalPrimitive) ID ¶
func (pr *LocalPrimitive) ID() int64
func (*LocalPrimitive) IncidentData ¶
func (pr *LocalPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error
func (*LocalPrimitive) IsReadOnly ¶ added in v0.5.375
func (pr *LocalPrimitive) IsReadOnly() bool
func (*LocalPrimitive) Optimise ¶
func (pr *LocalPrimitive) Optimise() error
func (*LocalPrimitive) SetExecutor ¶
func (pr *LocalPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error
func (*LocalPrimitive) SetInputAlias ¶
func (pr *LocalPrimitive) SetInputAlias(_ string, _ int64) error
func (*LocalPrimitive) SetRedoLog ¶ added in v0.5.375
func (pr *LocalPrimitive) SetRedoLog(log binlog.LogEntry)
func (*LocalPrimitive) SetTxnID ¶ added in v0.5.375
func (pr *LocalPrimitive) SetTxnID(_ int)
func (*LocalPrimitive) SetUndoLog ¶ added in v0.5.375
func (pr *LocalPrimitive) SetUndoLog(log binlog.LogEntry)
type MetaDataPrimitive ¶
type MetaDataPrimitive struct { Provider provider.IProvider Executor func(pc IPrimitiveCtx) internaldto.ExecutorOutput Preparator func() *drm.PreparedStatementCtx // contains filtered or unexported fields }
func (*MetaDataPrimitive) Execute ¶
func (pr *MetaDataPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput
func (*MetaDataPrimitive) GetInputFromAlias ¶
func (pr *MetaDataPrimitive) GetInputFromAlias(string) (internaldto.ExecutorOutput, bool)
func (*MetaDataPrimitive) GetRedoLog ¶ added in v0.5.375
func (pr *MetaDataPrimitive) GetRedoLog() (binlog.LogEntry, bool)
func (*MetaDataPrimitive) GetUndoLog ¶ added in v0.5.375
func (pr *MetaDataPrimitive) GetUndoLog() (binlog.LogEntry, bool)
func (*MetaDataPrimitive) ID ¶
func (pr *MetaDataPrimitive) ID() int64
func (*MetaDataPrimitive) IncidentData ¶
func (pr *MetaDataPrimitive) IncidentData(_ int64, _ internaldto.ExecutorOutput) error
func (*MetaDataPrimitive) IsReadOnly ¶ added in v0.5.375
func (pr *MetaDataPrimitive) IsReadOnly() bool
func (*MetaDataPrimitive) Optimise ¶
func (pr *MetaDataPrimitive) Optimise() error
func (*MetaDataPrimitive) SetExecutor ¶
func (pr *MetaDataPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error
func (*MetaDataPrimitive) SetInputAlias ¶
func (pr *MetaDataPrimitive) SetInputAlias(_ string, _ int64) error
func (*MetaDataPrimitive) SetRedoLog ¶ added in v0.5.375
func (pr *MetaDataPrimitive) SetRedoLog(log binlog.LogEntry)
func (*MetaDataPrimitive) SetTxnID ¶ added in v0.5.375
func (pr *MetaDataPrimitive) SetTxnID(_ int)
func (*MetaDataPrimitive) SetUndoLog ¶ added in v0.5.375
func (pr *MetaDataPrimitive) SetUndoLog(log binlog.LogEntry)
type PassThroughPrimitive ¶
type PassThroughPrimitive struct { Inputs map[int64]internaldto.ExecutorOutput // contains filtered or unexported fields }
func (*PassThroughPrimitive) Execute ¶
func (pr *PassThroughPrimitive) Execute(_ IPrimitiveCtx) internaldto.ExecutorOutput
func (*PassThroughPrimitive) GetInputFromAlias ¶
func (pr *PassThroughPrimitive) GetInputFromAlias(string) (internaldto.ExecutorOutput, bool)
func (*PassThroughPrimitive) GetRedoLog ¶ added in v0.5.375
func (pr *PassThroughPrimitive) GetRedoLog() (binlog.LogEntry, bool)
func (*PassThroughPrimitive) GetUndoLog ¶ added in v0.5.375
func (pr *PassThroughPrimitive) GetUndoLog() (binlog.LogEntry, bool)
func (*PassThroughPrimitive) IncidentData ¶
func (pr *PassThroughPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error
func (*PassThroughPrimitive) IsReadOnly ¶ added in v0.5.375
func (pr *PassThroughPrimitive) IsReadOnly() bool
func (*PassThroughPrimitive) Optimise ¶
func (pr *PassThroughPrimitive) Optimise() error
func (*PassThroughPrimitive) SetExecutor ¶
func (pr *PassThroughPrimitive) SetExecutor(func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error
func (*PassThroughPrimitive) SetInputAlias ¶
func (pr *PassThroughPrimitive) SetInputAlias(_ string, _ int64) error
func (*PassThroughPrimitive) SetRedoLog ¶ added in v0.5.375
func (pr *PassThroughPrimitive) SetRedoLog(log binlog.LogEntry)
func (*PassThroughPrimitive) SetTxnID ¶ added in v0.5.375
func (pr *PassThroughPrimitive) SetTxnID(_ int)
func (*PassThroughPrimitive) SetUndoLog ¶ added in v0.5.375
func (pr *PassThroughPrimitive) SetUndoLog(log binlog.LogEntry)
Click to show internal directories.
Click to hide internal directories.