crash.software
Projects
Pull Requests
Issues
Builds
dolt
Code
Files
Commits
Branches
Tags
Pull Requests
Code Comments
Code Compare
Issues
List
Boards
Milestones
Builds
Statistics
Contributions
Source Lines
Child Projects
Projects
STRLCPY
dolt
Files
🤬
Sign In
88ec14b1
ROOT
/
go
/
libraries
/
doltcore
/
sqle
/
cluster
/
controller.go
Search
History
732 lines
|
ISO-8859-1
|
21 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
Role
RolePrimary
:
Role
RoleStandby
:
Role
RoleDetectedBrokenConfig
:
Role
PersistentConfigPrefix
Controller
cfg
:
Config
persistentCfg
:
config.ReadWriteConfig
role
:
Role
epoch
:
int
systemVars
:
sqlvars
mu
:
sync.Mutex
commithooks
:
[]*commithook
sinterceptor
:
serverinterceptor
cinterceptor
:
clientinterceptor
lgr
:
*logrus.Logger
provider
:
dbProvider
iterSessions
:
IterSessions
killQuery
:
func(uint32)
killConnection
:
func(uint32) error
jwks
:
*jwtauth.MultiJWKS
tlsCfg
:
*tls.Config
grpcCreds
:
credentials.PerRPCCredentials
pub
:
ed25519.PublicKey
priv
:
ed25519.PrivateKey
sqlvars
AddSystemVariables
(sysVars []sql.SystemVariable)
dbProvider
SetIsStandby
(bool)
procedurestore
Register
(sql.ExternalStoredProcedureDetails)
DoltClusterRoleVariable
DoltClusterRoleEpochVariable
NewController
(lgr *logrus.Logger, cfg Config, pCfg config.ReadWriteConfig)
:
(*Controller, error)
IterSessions
applyBootstrapClusterConfig
(lgr *logrus.Logger, cfg Config, pCfg config.ReadWriteConfig)
:
(Role, int, error)
waitForHooksToReplicateTimeout
*Controller
Run
()
GracefulStop
()
:
error
ManageSystemVariables
(variables sqlvars)
ApplyStandbyReplicationConfig
(ctx context.Context, bt *sql.BackgroundThreads, mrEnv *env.MultiRepoEnv, dbs ...sqle.SqlDatabase)
:
error
ManageDatabaseProvider
(p dbProvider)
ManageQueryConnections
(iterSessions IterSessions, killQuery func(uint32), killConnection func(uint32) error)
applyCommitHooks
(ctx context.Context, name string, bt *sql.BackgroundThreads, denv *env.DoltEnv)
:
([]*commithook, error)
gRPCDialProvider
(denv *env.DoltEnv)
:
dbfactory.GRPCDialProvider
RegisterStoredProcedures
(store procedurestore)
ClusterDatabase
()
:
sql.Database
RemoteSrvPort
()
:
int
ServerOptions
()
:
[]grpc.ServerOption
refreshSystemVars
()
persistVariables
()
:
error
setRoleAndEpoch
(role string, epoch int, graceful bool, saveConnID int)
:
(bool, error)
roleAndEpoch
()
:
(Role, int)
registerCommitHook
(hook *commithook)
GetClusterStatus
()
:
[]clusterdb.ReplicaStatus
recordSuccessfulRemoteSrvCommit
(name string)
RemoteSrvServerArgs
(ctx *sql.Context, args remotesrv.ServerArgs)
:
remotesrv.ServerArgs
gracefulTransitionToStandby
(saveConnID int)
:
error
immediateTransitionToStandby
()
:
error
transitionToPrimary
(saveConnID int)
:
error
killRunningQueries
(saveConnID int)
setProviderIsStandby
(standby bool)
waitForHooksToReplicate
()
:
error
outboundTlsConfig
()
:
(*tls.Config, error)
standbyRemotesJWKS
()
:
*jwtauth.MultiJWKS
All occurrences
Please wait...
Page is in error, reload to recover