server

package

Go to main page

Versions in this module

v0

v0.17.1

Feb 17, 2025

v0.17.0

Feb 11, 2025

v0.16.0

Dec 30, 2024

Changes in this version

+ type BindVariables struct

v0.15.0

Dec 5, 2024

v0.14.1

Nov 13, 2024

v0.14.0

Nov 8, 2024

v0.13.0

Oct 17, 2024

Changes in this version

+ const PrintErrorStackTracesEnvKey

+ var EnableAuthentication = false

type SASLInitial

+ func (si SASLInitial) MessageBare() []byte

type SASLResponse

+ func (sr SASLResponse) MessageWithoutProof() []byte

v0.12.0

Sep 30, 2024

Changes in this version

+ const SASLMechanism_SCRAM_SHA_256

+ const SASLMechanism_SCRAM_SHA_256_PLUS

+ var HandlePanics = true

+ var OidToDoltgresType = map[uint32]pgtypes.DoltgresType

+ func VitessTypeToObjectID(typ query.Type) (uint32, error)

+ type DoltgresHandler struct

+ func (h *DoltgresHandler) ComBind(ctx context.Context, c *mysql.Conn, query string, ...) (mysql.BoundQuery, []pgproto3.FieldDescription, error)

+ func (h *DoltgresHandler) ComExecuteBound(ctx context.Context, conn *mysql.Conn, query string, ...) error

+ func (h *DoltgresHandler) ComPrepareParsed(ctx context.Context, c *mysql.Conn, query string, parsed sqlparser.Statement) (mysql.ParsedQuery, []pgproto3.FieldDescription, error)

+ func (h *DoltgresHandler) ComQuery(ctx context.Context, c *mysql.Conn, query string, parsed sqlparser.Statement, ...) error

+ func (h *DoltgresHandler) ComResetConnection(c *mysql.Conn) error

+ func (h *DoltgresHandler) ConnectionClosed(c *mysql.Conn)

+ func (h *DoltgresHandler) NewConnection(c *mysql.Conn)

+ func (h *DoltgresHandler) NewContext(ctx context.Context, c *mysql.Conn, query string) (*sql.Context, error)

+ type ErrorResponseSeverity string

+ const ErrorResponseSeverity_Debug

+ const ErrorResponseSeverity_Error

+ const ErrorResponseSeverity_Fatal

+ const ErrorResponseSeverity_Info

+ const ErrorResponseSeverity_Log

+ const ErrorResponseSeverity_Notice

+ const ErrorResponseSeverity_Panic

+ const ErrorResponseSeverity_Warning

+ type Handler interface

+ ComBind func(ctx context.Context, c *mysql.Conn, query string, ...) (mysql.BoundQuery, []pgproto3.FieldDescription, error)

+ ComExecuteBound func(ctx context.Context, conn *mysql.Conn, query string, ...) error

+ ComPrepareParsed func(ctx context.Context, c *mysql.Conn, query string, parsed sqlparser.Statement) (mysql.ParsedQuery, []pgproto3.FieldDescription, error)

+ ComQuery func(ctx context.Context, c *mysql.Conn, query string, parsed sqlparser.Statement, ...) error

+ ComResetConnection func(c *mysql.Conn) error

+ ConnectionClosed func(c *mysql.Conn)

+ NewConnection func(c *mysql.Conn)

+ NewContext func(ctx context.Context, c *mysql.Conn, query string) (*sql.Context, error)

+ type QueryExecutor func(ctx *sql.Context, query string, parsed sqlparser.Statement, analyzed sql.Node) (sql.Schema, sql.RowIter, *sql.QueryFlags, error)

+ type ReadyForQueryTransactionIndicator byte

+ const ReadyForQueryTransactionIndicator_FailedTransactionBlock

+ const ReadyForQueryTransactionIndicator_Idle

+ const ReadyForQueryTransactionIndicator_TransactionBlock

+ type Result struct

+ Fields []pgproto3.FieldDescription

+ Rows []Row

+ RowsAffected uint64

+ type Row struct

+ type SASLBindingFlag string

+ const SASLBindingFlag_AssumedNoServerSupport

+ const SASLBindingFlag_NoClientSupport

+ const SASLBindingFlag_Used

+ type SASLContinue struct

+ Iterations uint32

+ Nonce string

+ Salt string

+ func (sc SASLContinue) Encode() *pgproto3.AuthenticationSASLContinue

+ type SASLInitial struct

+ Authzid string

+ BindName string

+ Binding string

+ Flag SASLBindingFlag

+ Nonce string

+ RawData []byte

+ Username string

+ func (si SASLInitial) Base64Header() string

+ type SASLResponse struct

+ ClientProof string

+ GS2Header string

+ Nonce string

+ RawData []byte

v0.11.1

Aug 21, 2024

v0.11.0

Aug 12, 2024

v0.10.0

Jul 2, 2024

v0.9.0

Jun 11, 2024

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