pub

Documentation

Index

• Variables
• type JetStreamOpts
• type Pub
  • func NewJetStreamPub(o JetStreamOpts) (Pub, error)

Variables

var ErrCircuitOpen = errors.New("circuit breaker is open")

Types

type JetStreamOpts

type JetStreamOpts struct {
	Endpoints               []string
	PersistDuration         time.Duration
	DedupWindow             time.Duration
	StreamReplicas          int
	MaxRetries              int
	CircuitBreakerThreshold int
	CircuitBreakerTimeout   time.Duration
	Logg                    *slog.Logger
}

type Pub

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

func NewJetStreamPub

func NewJetStreamPub(o JetStreamOpts) (Pub, error)