tableinsertioncontainer

Documentation

Index

• type StandardTableInsertionContainer
  • func (ic *StandardTableInsertionContainer) GetTableMetadata() tablemetadata.ExtendedTableMetadata
  • func (ic *StandardTableInsertionContainer) GetTableTxnCounters() (string, internaldto.TxnControlCounters)
  • func (ic *StandardTableInsertionContainer) IsCountersSet() bool
  • func (ic *StandardTableInsertionContainer) SetTableTxnCounters(tableName string, tcc internaldto.TxnControlCounters) error
• type TableInsertionContainer
  • func NewTableInsertionContainer(tm tablemetadata.ExtendedTableMetadata, sqlEngine sqlengine.SQLEngine, ...) (TableInsertionContainer, error)

Types

type StandardTableInsertionContainer

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

func (*StandardTableInsertionContainer) GetTableMetadata

func (ic *StandardTableInsertionContainer) GetTableMetadata() tablemetadata.ExtendedTableMetadata

func (*StandardTableInsertionContainer) GetTableTxnCounters

func (ic *StandardTableInsertionContainer) GetTableTxnCounters() (string, internaldto.TxnControlCounters)

func (*StandardTableInsertionContainer) IsCountersSet

func (ic *StandardTableInsertionContainer) IsCountersSet() bool

func (*StandardTableInsertionContainer) SetTableTxnCounters

func (ic *StandardTableInsertionContainer) SetTableTxnCounters(
	tableName string,
	tcc internaldto.TxnControlCounters,
) error

type TableInsertionContainer

type TableInsertionContainer interface {
	GetTableMetadata() tablemetadata.ExtendedTableMetadata
	IsCountersSet() bool
	SetTableTxnCounters(string, internaldto.TxnControlCounters) error
	GetTableTxnCounters() (string, internaldto.TxnControlCounters)
}

func NewTableInsertionContainer

func NewTableInsertionContainer(
	tm tablemetadata.ExtendedTableMetadata,
	sqlEngine sqlengine.SQLEngine,
	txnCtrMgr txncounter.Manager,
) (TableInsertionContainer, error)