Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

postq

package module

Go to main page

Versions in this module

v1

v1.0.0

Oct 2, 2023

v0

v0.1.6

Aug 5, 2024

Changes in this version

type AsyncEventConsumer

+ func (t *AsyncEventConsumer) RecordEvents(size int)

+ func (t AsyncEventConsumer) GetRecords() ([]Event, error)

type SyncEventConsumer

+ func (t *SyncEventConsumer) RecordEvents(size int)

+ func (t SyncEventConsumer) GetRecords() ([]Event, error)

v0.1.5

Mar 20, 2024

Changes in this version

type Event

+ Priority int

type Events

+ func (events Events) Recreate(ctx Context, tx *pgx.Conn) error

v0.1.4

Feb 8, 2024

v0.1.3

Jan 1, 2024

Changes in this version

type Context

+ Debugf func(message string, args ...interface{})

+ Tracef func(message string, args ...interface{})

type Event

+ func (t Event) TableName() string

v0.1.2

Oct 4, 2023

Changes in this version

type AsyncEventHandlerFunc

+ func AsyncHandler(fn func(ctx T, e Events) Events) AsyncEventHandlerFunc

type SyncEventHandlerFunc

+ func SyncHandlers(fn ...func(ctx T, e Event) error) []SyncEventHandlerFunc

v0.1.1

Oct 2, 2023

v0.1.0

Oct 2, 2023

Changes in this version

+ type AsyncEventConsumer struct

+ BatchSize int

+ Consumer AsyncEventHandlerFunc

+ ConsumerOption *ConsumerOption

+ EventFetcherOption *EventFetcherOption

+ WatchEvents []string

+ func (t *AsyncEventConsumer) Handle(ctx Context) (int, error)

+ func (t AsyncEventConsumer) EventConsumer() (*PGConsumer, error)

+ type AsyncEventHandlerFunc func(Context, Events) Events

+ type ConsumerFunc func(ctx Context) (count int, err error)

+ type ConsumerOption struct

+ ErrorHandler func(err error) bool

+ NumConsumers int

+ Timeout time.Duration

+ type Context interface

+ Pool func() *pgxpool.Pool

+ type Event struct

+ Attempts int

+ CreatedAt time.Time

+ Error *string

+ ID uuid.UUID

+ LastAttempt *time.Time

+ Name string

+ Properties map[string]string

+ func (t *Event) Scan(rows pgx.Row) error

+ func (t *Event) SetError(err string)

+ type EventFetcherOption struct

+ BaseDelay int

+ Exponent int

+ MaxAttempts int

+ type Events []Event

+ func (events Events) Update(ctx Context, tx *pgx.Conn) error

+ type PGConsumer struct

+ func NewPGConsumer(consumerFunc ConsumerFunc, opt *ConsumerOption) (*PGConsumer, error)

+ func (e *PGConsumer) Listen(ctx Context, pgNotify <-chan string)

+ func (t *PGConsumer) ConsumeUntilEmpty(ctx Context)

+ type SyncEventConsumer struct

+ ConsumerOption *ConsumerOption

+ Consumers []SyncEventHandlerFunc

+ EventFetchOption *EventFetcherOption

+ WatchEvents []string

+ func (t *SyncEventConsumer) Handle(ctx Context) (int, error)

+ func (t SyncEventConsumer) EventConsumer() (*PGConsumer, error)

+ type SyncEventHandlerFunc func(Context, Event) error