Documentation ¶
Index ¶
- Variables
- type AsyncHTTPMonitorPrimitive
- func (pr *AsyncHTTPMonitorPrimitive) Execute(pc primitive.IPrimitiveCtx) internaldto.ExecutorOutput
- func (pr *AsyncHTTPMonitorPrimitive) GetInputFromAlias(string) (internaldto.ExecutorOutput, bool)
- func (pr *AsyncHTTPMonitorPrimitive) GetRedoLog() (binlog.LogEntry, bool)
- func (pr *AsyncHTTPMonitorPrimitive) GetUndoLog() (binlog.LogEntry, bool)
- func (pr *AsyncHTTPMonitorPrimitive) ID() int64
- func (pr *AsyncHTTPMonitorPrimitive) IncidentData(fromID int64, input internaldto.ExecutorOutput) error
- func (pr *AsyncHTTPMonitorPrimitive) IsReadOnly() bool
- func (pr *AsyncHTTPMonitorPrimitive) Optimise() error
- func (pr *AsyncHTTPMonitorPrimitive) SetExecutor(_ func(pc primitive.IPrimitiveCtx) internaldto.ExecutorOutput) error
- func (pr *AsyncHTTPMonitorPrimitive) SetInputAlias(alias string, id int64) error
- func (pr *AsyncHTTPMonitorPrimitive) SetRedoLog(_ binlog.LogEntry)
- func (pr *AsyncHTTPMonitorPrimitive) SetTxnID(_ int)
- func (pr *AsyncHTTPMonitorPrimitive) SetUndoLog(_ binlog.LogEntry)
- type DefaultGoogleAsyncMonitor
- type IAsyncMonitor
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)
Click to show internal directories.
Click to hide internal directories.