server

package

Go to main page

Versions in this module

v0

v0.8.0

Jun 4, 2024

v0.7.5

May 20, 2024

Changes in this version

type ConvertedQuery

+ StatementTag string

v0.7.4

May 14, 2024

v0.7.1

May 13, 2024

v0.7.0

May 13, 2024

Changes in this version

+ const OverrideDataDirKey

+ var ConfigHelp = `Place holder. This will be replaced with details on config.yaml options`

+ func Ptr[T any](v T) *T

+ type DoltgesMetricsConfig struct

+ Host *string

+ Labels map[string]string

+ Port *int

+ type DoltgresBehaviorConfig struct

+ DisableClientMultiStatements *bool

+ DoltTransactionCommit *bool

+ ReadOnly *bool

+ type DoltgresConfig struct

+ BehaviorConfig *DoltgresBehaviorConfig

+ BranchControlFile *string

+ CfgDirStr *string

+ DataDirStr *string

+ EncodeLoggedQuery *bool

+ GoldenMysqlConn *string

+ Jwks []engine.JwksConfig

+ ListenerConfig *DoltgresListenerConfig

+ LogLevelStr *string

+ MaxLenInLogs *int

+ MetricsConfig *DoltgesMetricsConfig

+ PerformanceConfig *DoltgresPerformanceConfig

+ PostgresReplicationConfig *PostgresReplicationConfig

+ PrivilegeFile *string

+ RemotesapiConfig *DoltgresRemotesapiConfig

+ SystemVariables *engine.SystemVariables

+ UserConfig *DoltgresUserConfig

+ Vars []DoltgresUserSessionVars

+ func ConfigFromYamlData(configFileData []byte, overrides map[string]string) (*DoltgresConfig, error)

+ func ReadConfigFromYamlFile(fs filesys.Filesys, configFilePath string, overrides map[string]string) (*DoltgresConfig, error)

+ func (cfg *DoltgresConfig) AllowCleartextPasswords() bool

+ func (cfg *DoltgresConfig) AutoCommit() bool

+ func (cfg *DoltgresConfig) BranchControlFilePath() string

+ func (cfg *DoltgresConfig) CfgDir() string

+ func (cfg *DoltgresConfig) ClusterConfig() cluster.Config

+ func (cfg *DoltgresConfig) DataDir() string

+ func (cfg *DoltgresConfig) DisableClientMultiStatements() bool

+ func (cfg *DoltgresConfig) DoltTransactionCommit() bool

+ func (cfg *DoltgresConfig) EventSchedulerStatus() string

+ func (cfg *DoltgresConfig) Host() string

+ func (cfg *DoltgresConfig) JwksConfig() []engine.JwksConfig

+ func (cfg *DoltgresConfig) LogLevel() sqlserver.LogLevel

+ func (cfg *DoltgresConfig) MaxConnections() uint64

+ func (cfg *DoltgresConfig) MaxLoggedQueryLen() int

+ func (cfg *DoltgresConfig) MetricsHost() string

+ func (cfg *DoltgresConfig) MetricsLabels() map[string]string

+ func (cfg *DoltgresConfig) MetricsPort() int

+ func (cfg *DoltgresConfig) Password() string

+ func (cfg *DoltgresConfig) PersistenceBehavior() string

+ func (cfg *DoltgresConfig) Port() int

+ func (cfg *DoltgresConfig) PrivilegeFilePath() string

+ func (cfg *DoltgresConfig) QueryParallelism() int

+ func (cfg *DoltgresConfig) ReadOnly() bool

+ func (cfg *DoltgresConfig) ReadTimeout() uint64

+ func (cfg *DoltgresConfig) RemotesapiPort() *int

+ func (cfg *DoltgresConfig) RemotesapiReadOnly() *bool

+ func (cfg *DoltgresConfig) RequireSecureTransport() bool

+ func (cfg *DoltgresConfig) ShouldEncodeLoggedQuery() bool

+ func (cfg *DoltgresConfig) Socket() string

+ func (cfg *DoltgresConfig) SystemVars() engine.SystemVariables

+ func (cfg *DoltgresConfig) TLSCert() string

+ func (cfg *DoltgresConfig) TLSKey() string

+ func (cfg *DoltgresConfig) ToSqlServerConfig() sqlserver.ServerConfig

+ func (cfg *DoltgresConfig) User() string

+ func (cfg *DoltgresConfig) UserVars() []sqlserver.UserSessionVars

+ func (cfg *DoltgresConfig) ValueSet(value string) bool

+ func (cfg *DoltgresConfig) WriteTimeout() uint64

+ type DoltgresListenerConfig struct

+ AllowCleartextPasswords *bool

+ HostStr *string

+ PortNumber *int

+ ReadTimeoutMillis *uint64

+ RequireSecureTransport *bool

+ Socket *string

+ TLSCert *string

+ TLSKey *string

+ WriteTimeoutMillis *uint64

+ type DoltgresPerformanceConfig struct

+ QueryParallelism *int

+ type DoltgresRemotesapiConfig struct

+ Port *int

+ ReadOnly *bool

+ type DoltgresUserConfig struct

+ Name *string

+ Password *string

+ type DoltgresUserSessionVars struct

+ Name string

+ Vars map[string]string

v0.6.0

Apr 16, 2024

v0.5.0

Mar 28, 2024

Changes in this version

+ func NewListenerWithOpts(listenerCfg mysql.ListenerConfig, opts ...ListenerOpt) (server.ProtocolListener, error)

+ type DoltgresConfigReader struct

+ func (d DoltgresConfigReader) ReadConfigArgs(args *argparser.ArgParseResults) (sqlserver.ServerConfig, error)

+ func (d DoltgresConfigReader) ReadConfigFile(fs filesys.Filesys, file string) (sqlserver.ServerConfig, error)

+ type DoltgresServerConfig struct

+ PostgresReplicationConfig *PostgresReplicationConfig

+ type ListenerOpt func(*Listener)

+ func WithCertificate(cert tls.Certificate) ListenerOpt

+ type PostgresReplicationConfig struct

+ PostgresDatabase string

+ PostgresPassword string

+ PostgresPort int

+ PostgresServerAddress string

+ PostgresUser string

+ SlotName string

v0.4.0

Feb 14, 2024

Changes in this version

+ type ConnectionHandler struct

+ func NewConnectionHandler(conn net.Conn, handler mysql.Handler) *ConnectionHandler

+ func (h *ConnectionHandler) Conn() net.Conn

+ func (h *ConnectionHandler) HandleConnection()

+ type PortalData struct

+ BoundPlan sql.Node

+ Fields []*querypb.Field

+ IsEmptyQuery bool

+ Query ConvertedQuery

+ type PreparedStatementData struct

+ BindVarTypes []int32

+ Query ConvertedQuery

+ ReturnFields []*querypb.Field

v0.3.1

Dec 28, 2023

Changes in this version

+ const DefUserEmail

+ const DefUserName

+ const DoltgresDir

v0.3.0

Dec 20, 2023

Changes in this version

+ const DOLTGRES_DATA_DIR

+ const DOLTGRES_DATA_DIR_DEFAULT

v0.2.0

Dec 11, 2023

Changes in this version

+ func HandleImplicitCommitStatement(statement string) (reverseStatement string, handled bool)

+ type ConvertedQuery struct

+ AST vitess.Statement

+ String string

v0.1.0

Nov 1, 2023

Changes in this version

+ const Version

+ func ImplicitlyCommits(statement string) bool

+ func NewLimitedListener(listenerCfg mysql.ListenerConfig) (server.ProtocolListener, error)

+ func NewListener(listenerCfg mysql.ListenerConfig) (server.ProtocolListener, error)

+ func RunInMemory(args []string) (*int, *sync.WaitGroup)

+ func RunOnDisk(args []string) (*int, *sync.WaitGroup)

+ type LimitedListener struct

+ func (l *LimitedListener) Accept()

+ func (l *LimitedListener) Addr() net.Addr

+ func (l *LimitedListener) Close()

+ type Listener struct

+ func (l *Listener) Accept()

+ func (l *Listener) Addr() net.Addr

+ func (l *Listener) Close()

+ func (l *Listener) HandleConnection(conn net.Conn)

+ type ParsedQuery struct

+ Parsed vitess.Statement

+ Query string

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