backend

Documentation

Index

• type ConnInfo
• type ConnInfoStore
• type InMemoryConnInfoStore
  • func NewInMemoryConnInfoStore() *InMemoryConnInfoStore
  • func (s *InMemoryConnInfoStore) Delete(i *ConnInfo) error
  • func (s *InMemoryConnInfoStore) Find(clientAddress net.Addr, backendProcessID, backendSecretKey uint32) (*ConnInfo, error)
  • func (s *InMemoryConnInfoStore) Save(i *ConnInfo) error
• type PGResolver
• type PGStartupMessageRewriter
• type StaticPGResolver
  • func NewStaticPGResolver(addr string) *StaticPGResolver
  • func (r *StaticPGResolver) GetPGConn(ctx context.Context, clientAddr net.Addr, parameters map[string]string) (net.Conn, error)

Types

type ConnInfo

type ConnInfo struct {
	ClientAddress     net.Addr
	ServerAddress     net.Addr
	BackendProcessID  uint32
	BackendSecretKey  uint32
	StartupParameters map[string]string
}

type ConnInfoStore

type ConnInfoStore interface {
	Find(clientAddress net.Addr, backendProcessID, backendSecretKey uint32) (*ConnInfo, error)
	Save(*ConnInfo) error
	Delete(*ConnInfo) error
}

type InMemoryConnInfoStore

type InMemoryConnInfoStore struct {
	// contains filtered or unexported fields
}

func NewInMemoryConnInfoStore

func NewInMemoryConnInfoStore() *InMemoryConnInfoStore

func (*InMemoryConnInfoStore) Delete

func (s *InMemoryConnInfoStore) Delete(i *ConnInfo) error

func (*InMemoryConnInfoStore) Find

func (s *InMemoryConnInfoStore) Find(clientAddress net.Addr, backendProcessID, backendSecretKey uint32) (*ConnInfo, error)

func (*InMemoryConnInfoStore) Save

func (s *InMemoryConnInfoStore) Save(i *ConnInfo) error

type PGResolver

type PGResolver interface {
	GetPGConn(ctx context.Context, clientAddr net.Addr, parameters map[string]string) (net.Conn, error)
}

type PGStartupMessageRewriter

type PGStartupMessageRewriter interface {
	RewriteParameters(original map[string]string) map[string]string
}

type StaticPGResolver

type StaticPGResolver struct {
	Address string
}

func NewStaticPGResolver

func NewStaticPGResolver(addr string) *StaticPGResolver

func (*StaticPGResolver) GetPGConn

func (r *StaticPGResolver) GetPGConn(ctx context.Context, clientAddr net.Addr, parameters map[string]string) (net.Conn, error)