postgres

Documentation

Index

• func NewTransport(cfg Config) (queue.Transport, error)
• type Config
• type Transport
  • func (s *Transport) Close() error
  • func (s *Transport) Open(name string) (queue.Queue, error)

Functions

func NewTransport

func NewTransport(cfg Config) (queue.Transport, error)

Types

type Config

type Config struct {
	ConnStr       string
	Logger        *zap.Logger
	EnableLogging bool
	MaxConns      int32
}

type Transport

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

Transport ...

func (*Transport) Close

func (s *Transport) Close() error

Close ...

func (*Transport) Open

func (s *Transport) Open(name string) (queue.Queue, error)