primitive

package
v0.5.742 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

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)

func (*HTTPRestPrimitive) WithDebugName added in v0.5.686 

func (pr *HTTPRestPrimitive) WithDebugName(name string) IPrimitive

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)

	WithDebugName(string) IPrimitive
}

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 IPrimitiveCtx interface {
	GetAuthContext(string) (*dto.AuthCtx, error)
	GetWriter() io.Writer
	GetErrWriter() io.Writer
}

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)

func (*LocalPrimitive) WithDebugName added in v0.5.686 

func (pr *LocalPrimitive) WithDebugName(name string) IPrimitive

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)

func (*MetaDataPrimitive) WithDebugName added in v0.5.686 

func (pr *MetaDataPrimitive) WithDebugName(name string) IPrimitive

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)

func (*PassThroughPrimitive) WithDebugName added in v0.5.686 

func (pr *PassThroughPrimitive) WithDebugName(name string) IPrimitive

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.