asynccompose

package

v0.9.315 Latest Latest Go to latest Published: Dec 5, 2025 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/stackql/stackql

Links

Open Source Insights

Documentation ¶

Index ¶

func ComposeAsyncMonitor(handlerCtx handler.HandlerContext, precursor primitive.IPrimitive, ...) (primitive.IPrimitive, error)
type AsyncHTTPMonitorPrimitive
type DefaultGoogleAsyncMonitor
- func (gm *DefaultGoogleAsyncMonitor) GetMonitorPrimitive(prov provider.IProvider, op anysdk.OperationStore, ...) (primitive.IPrimitive, error)
type IAsyncMonitor
- func NewAsyncMonitor(handlerCtx handler.HandlerContext, prov provider.IProvider, ...) (IAsyncMonitor, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ComposeAsyncMonitor ¶

func ComposeAsyncMonitor(
	handlerCtx handler.HandlerContext,
	precursor primitive.IPrimitive,
	prov provider.IProvider,
	method anysdk.OperationStore,
	commentDirectives sqlparser.CommentDirectives,
	isReturning bool,
	insertCtx drm.PreparedStatementCtx,
	drmCfg drm.Config,
) (primitive.IPrimitive, error)

Types ¶

type AsyncHTTPMonitorPrimitive ¶

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

func (*AsyncHTTPMonitorPrimitive) Execute ¶

func (pr *AsyncHTTPMonitorPrimitive) Execute(pc primitive.IPrimitiveCtx) internaldto.ExecutorOutput

func (*AsyncHTTPMonitorPrimitive) GetInputFromAlias ¶

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

func (*AsyncHTTPMonitorPrimitive) GetRedoLog ¶

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

func (*AsyncHTTPMonitorPrimitive) GetUndoLog ¶

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

func (*AsyncHTTPMonitorPrimitive) ID ¶

func (pr *AsyncHTTPMonitorPrimitive) ID() int64

func (*AsyncHTTPMonitorPrimitive) IncidentData ¶

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

func (*AsyncHTTPMonitorPrimitive) IsReadOnly ¶

func (pr *AsyncHTTPMonitorPrimitive) IsReadOnly() bool

func (*AsyncHTTPMonitorPrimitive) Optimise ¶

func (pr *AsyncHTTPMonitorPrimitive) Optimise() error

func (*AsyncHTTPMonitorPrimitive) SetExecutor ¶

func (pr *AsyncHTTPMonitorPrimitive) SetExecutor(_ func(pc primitive.IPrimitiveCtx) internaldto.ExecutorOutput) error

func (*AsyncHTTPMonitorPrimitive) SetInputAlias ¶

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

func (*AsyncHTTPMonitorPrimitive) SetRedoLog ¶

func (pr *AsyncHTTPMonitorPrimitive) SetRedoLog(_ binlog.LogEntry)

func (*AsyncHTTPMonitorPrimitive) SetTxnID ¶

func (pr *AsyncHTTPMonitorPrimitive) SetTxnID(_ int)

func (*AsyncHTTPMonitorPrimitive) SetUndoLog ¶

func (pr *AsyncHTTPMonitorPrimitive) SetUndoLog(_ binlog.LogEntry)

func (*AsyncHTTPMonitorPrimitive) WithDebugName ¶

func (pr *AsyncHTTPMonitorPrimitive) WithDebugName(_ string) primitive.IPrimitive

type DefaultGoogleAsyncMonitor ¶

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

func (*DefaultGoogleAsyncMonitor) GetMonitorPrimitive ¶

func (gm *DefaultGoogleAsyncMonitor) GetMonitorPrimitive(
	prov provider.IProvider,
	op anysdk.OperationStore,
	precursor primitive.IPrimitive,
	initialCtx primitive.IPrimitiveCtx,
	comments sqlparser.CommentDirectives,
	isReturning bool,
	insertCtx drm.PreparedStatementCtx,
	drmCfg drm.Config,
) (primitive.IPrimitive, error)

type IAsyncMonitor ¶

type IAsyncMonitor interface {
	GetMonitorPrimitive(
		prov provider.IProvider,
		op anysdk.OperationStore,
		precursor primitive.IPrimitive,
		initialCtx primitive.IPrimitiveCtx,
		comments sqlparser.CommentDirectives,
		isReturning bool,
		insertCtx drm.PreparedStatementCtx,
		drmCfg drm.Config,
	) (primitive.IPrimitive, error)
}

func NewAsyncMonitor ¶

func NewAsyncMonitor(
	handlerCtx handler.HandlerContext,
	prov provider.IProvider,
	op anysdk.OperationStore,
	isReturning bool,
) (IAsyncMonitor, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL