psql

Documentation

Index

• Variables
• func ShortenId(uuid string) (string, error)
• type Publisher
  • func New(postgresHost string, postgresPort int, postgresUser string, postgresPw string, ...) (*Publisher, error)
  • func (publisher *Publisher) Publish(envelope model.Envelope, service model.Service) (err error, notifyUsers bool)

Variables

var ConnectionTimeout = 10 * time.Second

var SlowProducerTimeout time.Duration = 2 * time.Second

Functions

func ShortenId

func ShortenId(uuid string) (string, error)

Types

type Publisher

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

func New

func New(postgresHost string, postgresPort int, postgresUser string, postgresPw string, postgresDb string, debugLog bool, wg *sync.WaitGroup, basectx context.Context) (*Publisher, error)

func (*Publisher) Publish

func (publisher *Publisher) Publish(envelope model.Envelope, service model.Service) (err error, notifyUsers bool)