tlengine

package
v1.0.0-beta1 Latest Latest
Warning

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

 Go to latest Published: Nov 24, 2022 License: MPL-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Code generated by vktl/cmd/tlgen2; DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AlreadyInMasterMode 

type AlreadyInMasterMode = internal.EngineAlreadyInMasterMode

type AlreadyInReplicaMode 

type AlreadyInReplicaMode = internal.EngineAlreadyInReplicaMode

type AsyncSleep 

type AsyncSleep = internal.EngineAsyncSleep

type BinlogPrefix 

type BinlogPrefix = internal.EngineBinlogPrefix

type Client 

type Client struct {
	Client  *rpc.Client
	Network string // should be either "tcp4" or "unix"
	Address string
	ActorID uint64 // should be non-zero when using rpc-proxy
}

func (*Client) AsyncSleep 

func (c *Client) AsyncSleep(ctx context.Context, args AsyncSleep, extra *rpc.InvokeReqExtra, ret *bool) (err error)

func (*Client) Count 

func (c *Client) Count(ctx context.Context, args Count, extra *rpc.InvokeReqExtra, ret *internal.BoolStat) (err error)

func (*Client) DumpForceQueries 

func (c *Client) DumpForceQueries(ctx context.Context, args DumpForceQueries, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) DumpLastQueries 

func (c *Client) DumpLastQueries(ctx context.Context, args DumpLastQueries, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) DumpNextQueries 

func (c *Client) DumpNextQueries(ctx context.Context, args DumpNextQueries, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) EnableMetafilesAnalyzer 

func (c *Client) EnableMetafilesAnalyzer(ctx context.Context, args EnableMetafilesAnalyzer, extra *rpc.InvokeReqExtra, ret *bool) (err error)

func (*Client) FilteredStat 

func (c *Client) FilteredStat(ctx context.Context, args FilteredStat, extra *rpc.InvokeReqExtra, ret *internal.Stat) (err error)

func (*Client) GetBinlogPrefixes 

func (c *Client) GetBinlogPrefixes(ctx context.Context, args GetBinlogPrefixes, extra *rpc.InvokeReqExtra, ret *[]internal.EngineBinlogPrefix) (err error)

func (*Client) GetExpectedMetafilesStats 

func (c *Client) GetExpectedMetafilesStats(ctx context.Context, args GetExpectedMetafilesStats, extra *rpc.InvokeReqExtra, ret *map[string]internal.EngineMetafilesStat) (err error)

func (*Client) GetReadWriteMode 

func (c *Client) GetReadWriteMode(ctx context.Context, args GetReadWriteMode, extra *rpc.InvokeReqExtra, ret *ReadWriteMode) (err error)

func (*Client) GetReindexStatus 

func (c *Client) GetReindexStatus(ctx context.Context, args GetReindexStatus, extra *rpc.InvokeReqExtra, ret *ReindexStatusUnion) (err error)

func (*Client) InvokeHttpQuery 

func (c *Client) InvokeHttpQuery(ctx context.Context, args InvokeHttpQuery, extra *rpc.InvokeReqExtra, ret *HttpQueryResponse) (err error)

func (*Client) IsProduction 

func (c *Client) IsProduction(ctx context.Context, args IsProduction, extra *rpc.InvokeReqExtra, ret *bool) (err error)

func (*Client) Nop 

func (c *Client) Nop(ctx context.Context, args Nop, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) Pid 

func (c *Client) Pid(ctx context.Context, args Pid, extra *rpc.InvokeReqExtra, ret *internal.NetPid) (err error)

func (*Client) PushStat 

func (c *Client) PushStat(ctx context.Context, args PushStat, extra *rpc.InvokeReqExtra, ret *bool) (err error)

func (*Client) ReadNop 

func (c *Client) ReadNop(ctx context.Context, args ReadNop, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) RecordNextQueries 

func (c *Client) RecordNextQueries(ctx context.Context, args RecordNextQueries, extra *rpc.InvokeReqExtra, ret *bool) (err error)

func (*Client) RegisterDynamicLib 

func (c *Client) RegisterDynamicLib(ctx context.Context, args RegisterDynamicLib, extra *rpc.InvokeReqExtra, ret *internal.BoolStat) (err error)

func (*Client) ReloadDynamicLib 

func (c *Client) ReloadDynamicLib(ctx context.Context, args ReloadDynamicLib, extra *rpc.InvokeReqExtra, ret *internal.BoolStat) (err error)

func (*Client) ReplaceConfigServer 

func (c *Client) ReplaceConfigServer(ctx context.Context, args ReplaceConfigServer, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) SendSignal 

func (c *Client) SendSignal(ctx context.Context, args SendSignal, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) SetFsyncInterval 

func (c *Client) SetFsyncInterval(ctx context.Context, args SetFsyncInterval, extra *rpc.InvokeReqExtra, ret *internal.BoolStat) (err error)

func (*Client) SetMetafileMemory 

func (c *Client) SetMetafileMemory(ctx context.Context, args SetMetafileMemory, extra *rpc.InvokeReqExtra, ret *internal.BoolStat) (err error)

func (*Client) SetNoPersistentConfigArray 

func (c *Client) SetNoPersistentConfigArray(ctx context.Context, args SetNoPersistentConfigArray, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) SetNoPersistentConfigValue 

func (c *Client) SetNoPersistentConfigValue(ctx context.Context, args SetNoPersistentConfigValue, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) SetPersistentConfigArray 

func (c *Client) SetPersistentConfigArray(ctx context.Context, args SetPersistentConfigArray, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) SetPersistentConfigValue 

func (c *Client) SetPersistentConfigValue(ctx context.Context, args SetPersistentConfigValue, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) SetVerbosity 

func (c *Client) SetVerbosity(ctx context.Context, args SetVerbosity, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) SetVerbosityType 

func (c *Client) SetVerbosityType(ctx context.Context, args SetVerbosityType, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

func (*Client) Sleep 

func (c *Client) Sleep(ctx context.Context, args Sleep, extra *rpc.InvokeReqExtra, ret *bool) (err error)

func (*Client) Stat 

func (c *Client) Stat(ctx context.Context, args Stat, extra *rpc.InvokeReqExtra, ret *internal.Stat) (err error)

func (*Client) SwitchToMasterMode 

func (c *Client) SwitchToMasterMode(ctx context.Context, args SwitchToMasterMode, extra *rpc.InvokeReqExtra, ret *SwitchMasterReplicaModeResultUnion) (err error)

func (*Client) SwitchToMasterModeForcefully 

func (c *Client) SwitchToMasterModeForcefully(ctx context.Context, args SwitchToMasterModeForcefully, extra *rpc.InvokeReqExtra, ret *SwitchMasterReplicaModeResultUnion) (err error)

func (*Client) SwitchToReplicaMode 

func (c *Client) SwitchToReplicaMode(ctx context.Context, args SwitchToReplicaMode, extra *rpc.InvokeReqExtra, ret *SwitchMasterReplicaModeResultUnion) (err error)

func (*Client) UnregisterDynamicLib 

func (c *Client) UnregisterDynamicLib(ctx context.Context, args UnregisterDynamicLib, extra *rpc.InvokeReqExtra, ret *internal.BoolStat) (err error)

func (*Client) Version 

func (c *Client) Version(ctx context.Context, args Version, extra *rpc.InvokeReqExtra, ret *string) (err error)

func (*Client) WriteNop 

func (c *Client) WriteNop(ctx context.Context, args WriteNop, extra *rpc.InvokeReqExtra, ret *internal.True) (err error)

type Count 

type Count = internal.EngineCount

type DumpForceQueries 

type DumpForceQueries = internal.EngineDumpForceQueries

type DumpLastQueries 

type DumpLastQueries = internal.EngineDumpLastQueries

type DumpNextQueries 

type DumpNextQueries = internal.EngineDumpNextQueries

type EnableMetafilesAnalyzer 

type EnableMetafilesAnalyzer = internal.EngineEnableMetafilesAnalyzer

type FailedToSwitchMode 

type FailedToSwitchMode = internal.EngineFailedToSwitchMode

type FilteredStat 

type FilteredStat = internal.EngineFilteredStat

type GetBinlogPrefixes 

type GetBinlogPrefixes = internal.EngineGetBinlogPrefixes

type GetExpectedMetafilesStats 

type GetExpectedMetafilesStats = internal.EngineGetExpectedMetafilesStats

type GetReadWriteMode 

type GetReadWriteMode = internal.EngineGetReadWriteMode

type GetReindexStatus 

type GetReindexStatus = internal.EngineGetReindexStatus

type Handler 

type Handler struct {
	AsyncSleep                   func(ctx context.Context, args AsyncSleep) (bool, error)                                                   // engine.asyncSleep
	Count                        func(ctx context.Context, args Count) (internal.BoolStat, error)                                           // engine.count
	DumpForceQueries             func(ctx context.Context, args DumpForceQueries) (internal.True, error)                                    // engine.dumpForceQueries
	DumpLastQueries              func(ctx context.Context, args DumpLastQueries) (internal.True, error)                                     // engine.dumpLastQueries
	DumpNextQueries              func(ctx context.Context, args DumpNextQueries) (internal.True, error)                                     // engine.dumpNextQueries
	EnableMetafilesAnalyzer      func(ctx context.Context, args EnableMetafilesAnalyzer) (bool, error)                                      // engine.enableMetafilesAnalyzer
	FilteredStat                 func(ctx context.Context, args FilteredStat) (internal.Stat, error)                                        // engine.filteredStat
	GetBinlogPrefixes            func(ctx context.Context, args GetBinlogPrefixes) ([]internal.EngineBinlogPrefix, error)                   // engine.getBinlogPrefixes
	GetExpectedMetafilesStats    func(ctx context.Context, args GetExpectedMetafilesStats) (map[string]internal.EngineMetafilesStat, error) // engine.getExpectedMetafilesStats
	GetReadWriteMode             func(ctx context.Context, args GetReadWriteMode) (ReadWriteMode, error)                                    // engine.getReadWriteMode
	GetReindexStatus             func(ctx context.Context, args GetReindexStatus) (ReindexStatusUnion, error)                               // engine.getReindexStatus
	InvokeHttpQuery              func(ctx context.Context, args InvokeHttpQuery) (HttpQueryResponse, error)                                 // engine.invokeHttpQuery
	IsProduction                 func(ctx context.Context, args IsProduction) (bool, error)                                                 // engine.isProduction
	Nop                          func(ctx context.Context, args Nop) (internal.True, error)                                                 // engine.nop
	Pid                          func(ctx context.Context, args Pid) (internal.NetPid, error)                                               // engine.pid
	PushStat                     func(ctx context.Context, args PushStat) (bool, error)                                                     // engine.pushStat
	ReadNop                      func(ctx context.Context, args ReadNop) (internal.True, error)                                             // engine.readNop
	RecordNextQueries            func(ctx context.Context, args RecordNextQueries) (bool, error)                                            // engine.recordNextQueries
	RegisterDynamicLib           func(ctx context.Context, args RegisterDynamicLib) (internal.BoolStat, error)                              // engine.registerDynamicLib
	ReloadDynamicLib             func(ctx context.Context, args ReloadDynamicLib) (internal.BoolStat, error)                                // engine.reloadDynamicLib
	ReplaceConfigServer          func(ctx context.Context, args ReplaceConfigServer) (internal.True, error)                                 // engine.replaceConfigServer
	SendSignal                   func(ctx context.Context, args SendSignal) (internal.True, error)                                          // engine.sendSignal
	SetFsyncInterval             func(ctx context.Context, args SetFsyncInterval) (internal.BoolStat, error)                                // engine.setFsyncInterval
	SetMetafileMemory            func(ctx context.Context, args SetMetafileMemory) (internal.BoolStat, error)                               // engine.setMetafileMemory
	SetNoPersistentConfigArray   func(ctx context.Context, args SetNoPersistentConfigArray) (internal.True, error)                          // engine.setNoPersistentConfigArray
	SetNoPersistentConfigValue   func(ctx context.Context, args SetNoPersistentConfigValue) (internal.True, error)                          // engine.setNoPersistentConfigValue
	SetPersistentConfigArray     func(ctx context.Context, args SetPersistentConfigArray) (internal.True, error)                            // engine.setPersistentConfigArray
	SetPersistentConfigValue     func(ctx context.Context, args SetPersistentConfigValue) (internal.True, error)                            // engine.setPersistentConfigValue
	SetVerbosity                 func(ctx context.Context, args SetVerbosity) (internal.True, error)                                        // engine.setVerbosity
	SetVerbosityType             func(ctx context.Context, args SetVerbosityType) (internal.True, error)                                    // engine.setVerbosityType
	Sleep                        func(ctx context.Context, args Sleep) (bool, error)                                                        // engine.sleep
	Stat                         func(ctx context.Context, args Stat) (internal.Stat, error)                                                // engine.stat
	SwitchToMasterMode           func(ctx context.Context, args SwitchToMasterMode) (SwitchMasterReplicaModeResultUnion, error)             // engine.switchToMasterMode
	SwitchToMasterModeForcefully func(ctx context.Context, args SwitchToMasterModeForcefully) (SwitchMasterReplicaModeResultUnion, error)   // engine.switchToMasterModeForcefully
	SwitchToReplicaMode          func(ctx context.Context, args SwitchToReplicaMode) (SwitchMasterReplicaModeResultUnion, error)            // engine.switchToReplicaMode
	UnregisterDynamicLib         func(ctx context.Context, args UnregisterDynamicLib) (internal.BoolStat, error)                            // engine.unregisterDynamicLib
	Version                      func(ctx context.Context, args Version) (string, error)                                                    // engine.version
	WriteNop                     func(ctx context.Context, args WriteNop) (internal.True, error)                                            // engine.writeNop

	RawAsyncSleep                   func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.asyncSleep
	RawCount                        func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.count
	RawDumpForceQueries             func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.dumpForceQueries
	RawDumpLastQueries              func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.dumpLastQueries
	RawDumpNextQueries              func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.dumpNextQueries
	RawEnableMetafilesAnalyzer      func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.enableMetafilesAnalyzer
	RawFilteredStat                 func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.filteredStat
	RawGetBinlogPrefixes            func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.getBinlogPrefixes
	RawGetExpectedMetafilesStats    func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.getExpectedMetafilesStats
	RawGetReadWriteMode             func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.getReadWriteMode
	RawGetReindexStatus             func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.getReindexStatus
	RawInvokeHttpQuery              func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.invokeHttpQuery
	RawIsProduction                 func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.isProduction
	RawNop                          func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.nop
	RawPid                          func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.pid
	RawPushStat                     func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.pushStat
	RawReadNop                      func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.readNop
	RawRecordNextQueries            func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.recordNextQueries
	RawRegisterDynamicLib           func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.registerDynamicLib
	RawReloadDynamicLib             func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.reloadDynamicLib
	RawReplaceConfigServer          func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.replaceConfigServer
	RawSendSignal                   func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.sendSignal
	RawSetFsyncInterval             func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.setFsyncInterval
	RawSetMetafileMemory            func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.setMetafileMemory
	RawSetNoPersistentConfigArray   func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.setNoPersistentConfigArray
	RawSetNoPersistentConfigValue   func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.setNoPersistentConfigValue
	RawSetPersistentConfigArray     func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.setPersistentConfigArray
	RawSetPersistentConfigValue     func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.setPersistentConfigValue
	RawSetVerbosity                 func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.setVerbosity
	RawSetVerbosityType             func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.setVerbosityType
	RawSleep                        func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.sleep
	RawStat                         func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.stat
	RawSwitchToMasterMode           func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.switchToMasterMode
	RawSwitchToMasterModeForcefully func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.switchToMasterModeForcefully
	RawSwitchToReplicaMode          func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.switchToReplicaMode
	RawUnregisterDynamicLib         func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.unregisterDynamicLib
	RawVersion                      func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.version
	RawWriteNop                     func(ctx context.Context, hctx *rpc.HandlerContext) error // engine.writeNop
}

func (*Handler) Handle 

func (h *Handler) Handle(ctx context.Context, hctx *rpc.HandlerContext) (err error)

type HttpQuery 

type HttpQuery = internal.EngineHttpQuery

type HttpQueryResponse 

type HttpQueryResponse = internal.EngineHttpQueryResponse

type InvokeHttpQuery 

type InvokeHttpQuery = internal.EngineInvokeHttpQuery

type IsProduction 

type IsProduction = internal.EngineIsProduction

type MetafilesOneMemoryStat 

type MetafilesOneMemoryStat = internal.EngineMetafilesOneMemoryStat

type MetafilesStat 

type MetafilesStat = internal.EngineMetafilesStat

type Nop 

type Nop = internal.EngineNop

type Pid 

type Pid = internal.EnginePid

type PushStat 

type PushStat = internal.EnginePushStat

type QueryResult 

type QueryResult = internal.EngineQueryResult

type QueryResultAio 

type QueryResultAio = internal.EngineQueryResultAio

type QueryResultError 

type QueryResultError = internal.EngineQueryResultError

type QueryResultUnion 

type QueryResultUnion = internal.EngineQueryResultUnion

type ReadNop 

type ReadNop = internal.EngineReadNop

type ReadWriteMode 

type ReadWriteMode = internal.EngineReadWriteMode

type RecordNextQueries 

type RecordNextQueries = internal.EngineRecordNextQueries

type RegisterDynamicLib 

type RegisterDynamicLib = internal.EngineRegisterDynamicLib

type ReindexStatusDone 

type ReindexStatusDone = internal.EngineReindexStatusDone

type ReindexStatusDoneOld 

type ReindexStatusDoneOld = internal.EngineReindexStatusDoneOld

type ReindexStatusFailed 

type ReindexStatusFailed = internal.EngineReindexStatusFailed

type ReindexStatusNever 

type ReindexStatusNever = internal.EngineReindexStatusNever

type ReindexStatusRunning 

type ReindexStatusRunning = internal.EngineReindexStatusRunning

type ReindexStatusRunningOld 

type ReindexStatusRunningOld = internal.EngineReindexStatusRunningOld

type ReindexStatusSignaled 

type ReindexStatusSignaled = internal.EngineReindexStatusSignaled

type ReindexStatusUnion 

type ReindexStatusUnion = internal.EngineReindexStatusUnion

type ReloadDynamicLib 

type ReloadDynamicLib = internal.EngineReloadDynamicLib

type ReloadDynamicLibOptions 

type ReloadDynamicLibOptions = internal.EngineReloadDynamicLibOptions

type ReplaceConfigServer 

type ReplaceConfigServer = internal.EngineReplaceConfigServer

type SendSignal 

type SendSignal = internal.EngineSendSignal

type SetFsyncInterval 

type SetFsyncInterval = internal.EngineSetFsyncInterval

type SetMetafileMemory 

type SetMetafileMemory = internal.EngineSetMetafileMemory

type SetNoPersistentConfigArray 

type SetNoPersistentConfigArray = internal.EngineSetNoPersistentConfigArray

type SetNoPersistentConfigValue 

type SetNoPersistentConfigValue = internal.EngineSetNoPersistentConfigValue

type SetPersistentConfigArray 

type SetPersistentConfigArray = internal.EngineSetPersistentConfigArray

type SetPersistentConfigValue 

type SetPersistentConfigValue = internal.EngineSetPersistentConfigValue

type SetVerbosity 

type SetVerbosity = internal.EngineSetVerbosity

type SetVerbosityType 

type SetVerbosityType = internal.EngineSetVerbosityType

type Sleep 

type Sleep = internal.EngineSleep

type Stat 

type Stat = internal.EngineStat

type SwitchMasterReplicaModeResultUnion 

type SwitchMasterReplicaModeResultUnion = internal.EngineSwitchMasterReplicaModeResultUnion

type SwitchToMasterMode 

type SwitchToMasterMode = internal.EngineSwitchToMasterMode

type SwitchToMasterModeForcefully 

type SwitchToMasterModeForcefully = internal.EngineSwitchToMasterModeForcefully

type SwitchToReplicaMode 

type SwitchToReplicaMode = internal.EngineSwitchToReplicaMode

type SwitchedToMasterMode 

type SwitchedToMasterMode = internal.EngineSwitchedToMasterMode

type SwitchedToMasterModeForcefully 

type SwitchedToMasterModeForcefully = internal.EngineSwitchedToMasterModeForcefully

type SwitchedToReplicaMode 

type SwitchedToReplicaMode = internal.EngineSwitchedToReplicaMode

type UnregisterDynamicLib 

type UnregisterDynamicLib = internal.EngineUnregisterDynamicLib

type Version 

type Version = internal.EngineVersion

type WriteNop 

type WriteNop = internal.EngineWriteNop

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.