psqlfront

Oct 4, 2022

Changes in this version

type Config

+ InitialFetch bool

Oct 4, 2022

Changes in this version

type Column

+ IsUnicodeName bool

Sep 29, 2022

Changes in this version

type Config

+ CacheControllTimeout *time.Duration

Sep 28, 2022

Changes in this version

type CacheWriter

+ DeleteRows func(ctx context.Context) error

+ ReplaceCacheTable func(ctx context.Context, t *Table) error

+ TargetTable func() *Table

type Origin

+ RefreshCache func(context.Context, CacheWriter) error

Aug 26, 2022

Changes in this version

+ type CacheMigrator interface

+ Migrate func(context.Context, *Table) error

type Migrator

+ func (m *Migrator) ExecuteMigrationForTargetTables(tables []*Table, preHook ...string) error

type Origin

+ MigrateTable func(context.Context, CacheMigrator, *Table) error

Aug 4, 2022

Changes in this version

+ var Version = "current"

+ func PtrValue(t T) *T

type Config

+ IdleTimeout *time.Duration

+ Stats *StatsConfig

type ProxyConn

+ func (conn *ProxyConn) ExtendDeadline() (time.Time, error)

+ func (conn *ProxyConn) SetIdleTimeout(idleTimeout time.Duration)

+ type ProxyConnOnQueryReceivedHandlerFunc func(ctx context.Context, query string, isPreparedStmt bool, notifier Notifier) error

type Server

+ func (server *Server) GetStats() *ServerStats

+ type ServerStats struct

+ CacheHits int64

+ CacheMisses int64

+ CurrConnections int64

+ Hostname string

+ MemoryAlloc uint64

+ Pid int

+ Queries int64

+ Time int64

+ TotalConnections int64

+ Uptime int64

+ Version string

+ func (stats *ServerStats) InsertInto(ctx context.Context, tx pgx.Tx) error

+ func (stats *ServerStats) Loatate(ctx context.Context, tx pgx.Tx) error

+ func (stats *ServerStats) String() string

+ type StatsConfig struct

+ Enabled *bool

+ MonitoringInterval time.Duration

+ StoreDatabase bool

Aug 2, 2022

Changes in this version

+ func GetRemoteAddr(ctx context.Context) string

+ func RegisterOriginType(typeName string, originConfigConstructor func() OriginConfig)

+ func UnregisterOriginType(typeName string)

+ func WithProxyConnOnQueryReceived(...) func(opts *ProxyConnOptions)

+ func WithProxyConnTLS(tlsConfig *tls.Config) func(opts *ProxyConnOptions)

+ type CacheDatabaseConfig struct

+ Database string

+ Host string

+ Password string

+ Port int

+ SSLMode string

+ Username string

+ func (cfg *CacheDatabaseConfig) DSN() string

+ type CacheInfo struct

+ CachedAt time.Time

+ ExpiredAt time.Time

+ OriginID string

+ SchemaName string

+ TableName string

+ type CacheWriter interface

+ AppendRows func(context.Context, [][]interface{}) error

+ type CertificateConfig struct

+ Cert string

+ Key string

+ type Column struct

+ Contraint string

+ DataType string

+ Length *int

+ Name string

+ type CommonOriginConfig struct

+ ID string

+ OriginConfig OriginConfig

+ TTL *time.Duration

+ Type string

+ func (cfg *CommonOriginConfig) NewOrigin() (Origin, error)

+ func (cfg *CommonOriginConfig) Ristrict() error

+ func (cfg *CommonOriginConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type Config struct

+ CacheDatabase *CacheDatabaseConfig

+ Certificates []*CertificateConfig

+ DefaultTTL time.Duration

+ Origins []*CommonOriginConfig

+ RequiredVersion string

+ func DefaultConfig() *Config

+ func (cfg *Config) Load(path string) error

+ func (cfg *Config) Restrict() error

+ func (cfg *Config) ValidateVersion(version string) error

+ type Migrator struct

+ func NewMigrator(cfg *CacheDatabaseConfig) *Migrator

+ func (m *Migrator) ExecuteMigration(tables []*Table) error

+ func (m *Migrator) GenerateCreateSchemaStmt(tables []*Table) string

+ func (m *Migrator) GenerateDesiredDDLs(tables []*Table) (string, error)

+ type Notifier interface

+ Notify func(ctx context.Context, resp *pgproto3.NoticeResponse) error

+ type Origin interface

+ GetRows func(context.Context, CacheWriter, *Table) error

+ GetTables func(ctx context.Context) ([]*Table, error)

+ ID func() string

+ type OriginConfig interface

+ NewOrigin func(id string) (Origin, error)

+ Restrict func() error

+ Type func() string

+ func GetOriginConfig(typeName string) (OriginConfig, bool)

+ type OriginNotFoundError struct

+ func WrapOriginNotFoundError(err error) *OriginNotFoundError

+ func (onfe *OriginNotFoundError) Error() string

+ func (onfe *OriginNotFoundError) Unwrap() error

+ type ProxyConn struct

+ func NewProxyConn(client net.Conn, upstream net.Conn, optFns ...func(opts *ProxyConnOptions)) (*ProxyConn, error)

+ func (conn *ProxyConn) Run(ctx context.Context) error

+ type ProxyConnOptions struct

+ type ProxyConnection struct

+ func (conn *ProxyConnection) Close(ctx context.Context) error

+ func (conn *ProxyConnection) ID() string

+ type Server struct

+ func New(ctx context.Context, cfg *Config) (*Server, error)

+ func (server *Server) RunWithContext(ctx context.Context, address string) error

+ func (server *Server) RunWithContextAndListener(ctx context.Context, listener net.Listener) error

+ type Table struct

+ Columns []*Column

+ Constraints []string

+ RelName string

+ SchemaName string

+ func AnalyzeQuery(query string) ([]*Table, error)

+ func (t *Table) GenerateDDL() (string, error)

+ func (t *Table) GoString() string

+ func (t *Table) String() string