pub

Documentation

Index

• type JetStreamOpts
• type Pub
  • func NewConsolePub(logg *slog.Logger) Pub
  • func NewJetStreamPub(o JetStreamOpts) (Pub, error)

Types

type JetStreamOpts

type JetStreamOpts struct {
	Logg            *slog.Logger
	Endpoint        string
	DedupDuration   time.Duration
	PersistDuration time.Duration
}

type Pub

type Pub interface {
	Send(context.Context, event.Event) error
	Close()
}

func NewConsolePub

func NewConsolePub(logg *slog.Logger) Pub

func NewJetStreamPub

func NewJetStreamPub(o JetStreamOpts) (Pub, error)