asyncmonitor

package
v0.5.643 Latest Latest
Warning

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

 Go to latest Published: May 15, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	MonitorPollIntervalSeconds int = 10 //nolint:revive,gochecknoglobals // TODO: global vars refactor
)

Functions

This section is empty.

Types

type AsyncHTTPMonitorPrimitive added in v0.5.375 

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

func (*AsyncHTTPMonitorPrimitive) Execute added in v0.5.375 

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

func (*AsyncHTTPMonitorPrimitive) GetInputFromAlias added in v0.5.375 

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

func (*AsyncHTTPMonitorPrimitive) GetRedoLog added in v0.5.375 

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

func (*AsyncHTTPMonitorPrimitive) GetUndoLog added in v0.5.375 

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

func (*AsyncHTTPMonitorPrimitive) ID added in v0.5.375 

func (pr *AsyncHTTPMonitorPrimitive) ID() int64

func (*AsyncHTTPMonitorPrimitive) IncidentData added in v0.5.375 

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

func (*AsyncHTTPMonitorPrimitive) IsReadOnly added in v0.5.375 

func (pr *AsyncHTTPMonitorPrimitive) IsReadOnly() bool

func (*AsyncHTTPMonitorPrimitive) Optimise added in v0.5.375 

func (pr *AsyncHTTPMonitorPrimitive) Optimise() error

func (*AsyncHTTPMonitorPrimitive) SetExecutor added in v0.5.375 

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

func (*AsyncHTTPMonitorPrimitive) SetInputAlias added in v0.5.375 

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

func (*AsyncHTTPMonitorPrimitive) SetRedoLog added in v0.5.375 

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

func (*AsyncHTTPMonitorPrimitive) SetTxnID added in v0.5.375 

func (pr *AsyncHTTPMonitorPrimitive) SetTxnID(_ int)

func (*AsyncHTTPMonitorPrimitive) SetUndoLog added in v0.5.375 

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

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,
) (primitive.IPrimitive, error)

type IAsyncMonitor 

type IAsyncMonitor interface {
	GetMonitorPrimitive(
		prov provider.IProvider,
		op anysdk.OperationStore,
		precursor primitive.IPrimitive,
		initialCtx primitive.IPrimitiveCtx,
		comments sqlparser.CommentDirectives,
	) (primitive.IPrimitive, error)
}

func NewAsyncMonitor 

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

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.