Help us shape the future of Go! Take the 2026 Go Developer Survey

primitive

package
v0.12.824 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2026 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 GenericPrimitive added in v0.7.131 

type GenericPrimitive struct {
	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 (*GenericPrimitive) Execute added in v0.7.131 

func (pr *GenericPrimitive) Execute(pc IPrimitiveCtx) internaldto.ExecutorOutput

func (*GenericPrimitive) GetInputFromAlias added in v0.7.131 

func (pr *GenericPrimitive) GetInputFromAlias(alias string) (internaldto.ExecutorOutput, bool)

func (*GenericPrimitive) GetRedoLog added in v0.7.131 

func (pr *GenericPrimitive) GetRedoLog() (binlog.LogEntry, bool)

func (*GenericPrimitive) GetUndoLog added in v0.7.131 

func (pr *GenericPrimitive) GetUndoLog() (binlog.LogEntry, bool)

func (*GenericPrimitive) ID added in v0.7.131 

func (pr *GenericPrimitive) ID() int64

func (*GenericPrimitive) IncidentData added in v0.7.131 

func (pr *GenericPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error

func (*GenericPrimitive) IsReadOnly added in v0.7.131 

func (pr *GenericPrimitive) IsReadOnly() bool

func (*GenericPrimitive) Optimise added in v0.7.131 

func (pr *GenericPrimitive) Optimise() error

func (*GenericPrimitive) SetExecutor added in v0.7.131 

func (pr *GenericPrimitive) SetExecutor(ex func(pc IPrimitiveCtx) internaldto.ExecutorOutput) error

func (*GenericPrimitive) SetInputAlias added in v0.7.131 

func (pr *GenericPrimitive) SetInputAlias(alias string, id int64) error

func (*GenericPrimitive) SetRedoLog added in v0.7.131 

func (pr *GenericPrimitive) SetRedoLog(log binlog.LogEntry)

func (*GenericPrimitive) SetTxnID added in v0.7.131 

func (pr *GenericPrimitive) SetTxnID(id int)

func (*GenericPrimitive) SetUndoLog added in v0.7.131 

func (pr *GenericPrimitive) SetUndoLog(log binlog.LogEntry)

func (*GenericPrimitive) WithDebugName added in v0.7.131 

func (pr *GenericPrimitive) 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 NewGenericPrimitive added in v0.7.131 

func NewGenericPrimitive(
	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.