pubsub

README

go-pubsub

Pubsub implementation for Go based on Postgres

Documentation

Index

• Constants
• func Publish[T any](ctx context.Context, logger *slog.Logger, querier postgres.Querier, ...) (int64, error)
• func Subscribe[T any](ctx context.Context, logger *slog.Logger, dbPool *pgxpool.Pool, topic string, ...) (string, func())
• type Handler
  • func HandlerWithCond[T any](handler Handler[T]) (Handler[T], *sync.Cond, func() T)
• type SubscriptionError
  • func NewSubscriptionError(err error, fatal bool) SubscriptionError
  • func (e SubscriptionError) Error() string
  • func (e SubscriptionError) Unwrap() error
• type SubscriptionErrors
  • func (es SubscriptionErrors) Errors() []string

Constants

const Fatal = true

const NonFatal = false

Functions

func Publish

func Publish[T any](
	ctx context.Context,
	logger *slog.Logger,
	querier postgres.Querier,
	topic string,
	message T,
) (int64, error)

func Subscribe

func Subscribe[T any](
	ctx context.Context,
	logger *slog.Logger,
	dbPool *pgxpool.Pool,
	topic string,
	msgHandler Handler[T],
	subHandler Handler[bool],
	errHandler Handler[SubscriptionError],
) (string, func())

Types

type Handler

type Handler[T any] func(v T)

func HandlerWithCond

func HandlerWithCond[T any](handler Handler[T]) (Handler[T], *sync.Cond, func() T)

type SubscriptionError

type SubscriptionError struct {
	Err   error
	Fatal bool
}

func NewSubscriptionError

func NewSubscriptionError(err error, fatal bool) SubscriptionError

func (SubscriptionError) Error

func (e SubscriptionError) Error() string

func (SubscriptionError) Unwrap

func (e SubscriptionError) Unwrap() error

type SubscriptionErrors

type SubscriptionErrors []SubscriptionError

func (SubscriptionErrors) Errors

func (es SubscriptionErrors) Errors() []string