pg

Documentation

Index

• Constants
• type AvcDurationExceededError
  • func (der AvcDurationExceededError) Error() string
  • func (der AvcDurationExceededError) String() string
• type Conn
  • func NewConn(connParams Dsn, logger *zap.SugaredLogger) (c *Conn)
  • func (c *Conn) AvCheckDuration(ctx context.Context, max float64) error
  • func (c *Conn) AvUpdateDuration(ctx context.Context) error
  • func (c *Conn) AvcCreateTable(ctx context.Context) error
  • func (c *Conn) Connect(ctx context.Context) (err error)
  • func (c *Conn) DSN() (dsn string)
  • func (c *Conn) GetRows(ctx context.Context, query string, args ...interface{}) ([]map[string]interface{}, error)
  • func (c *Conn) Host() string
  • func (c *Conn) IsPrimary(ctx context.Context) (bool, error)
  • func (c *Conn) IsStandby(ctx context.Context) (bool, error)
  • func (c *Conn) Port() string
• type Dsn

Constants

const (
	AvcSchema = "public"
	AvcTable  = "pgr66_avc"
	AvcColumn = "pgr66_avc"
)

Types

type AvcDurationExceededError

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

func (AvcDurationExceededError) Error

func (der AvcDurationExceededError) Error() string

func (AvcDurationExceededError) String

func (der AvcDurationExceededError) String() string

type Conn

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

func NewConn

func NewConn(connParams Dsn, logger *zap.SugaredLogger) (c *Conn)

func (*Conn) AvCheckDuration

func (c *Conn) AvCheckDuration(ctx context.Context, max float64) error

func (*Conn) AvUpdateDuration

func (c *Conn) AvUpdateDuration(ctx context.Context) error

func (*Conn) AvcCreateTable

func (c *Conn) AvcCreateTable(ctx context.Context) error

func (*Conn) Connect

func (c *Conn) Connect(ctx context.Context) (err error)

func (*Conn) DSN

func (c *Conn) DSN() (dsn string)

func (*Conn) GetRows

func (c *Conn) GetRows(ctx context.Context, query string, args ...interface{}) ([]map[string]interface{}, error)

func (*Conn) Host

func (c *Conn) Host() string

func (*Conn) IsPrimary

func (c *Conn) IsPrimary(ctx context.Context) (bool, error)

func (*Conn) IsStandby

func (c *Conn) IsStandby(ctx context.Context) (bool, error)

func (*Conn) Port

func (c *Conn) Port() string

type Dsn

type Dsn map[string]string