events

package

v0.9.0 Latest Latest Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	MaxRestartRetries         = 5
	InitialRestartBackoffTime = 150 * time.Millisecond
)

View Source

const DefaultDefaultAsyncPubAckInflight = 256

Default `defaultAsyncPubAckInflight` is `4000` (`nats.go`)

View Source

const DescriptionPrefix = "FiveNet: "

View Source

var Module = fx.Module("events",
	fx.Provide(
		New,
	),
	fx.Decorate(wrapLogger),
)

func GetJetstreamMsgContext(msg jetstream.Msg) (spanContext trace.SpanContext, err error)

func GetNatsMsgContext(msg *nats.Msg) (spanContext trace.SpanContext, err error)

type ConsumeErrRestartFn func(ctx context.Context, c context.Context) error

type JSWrapper struct {
	jetstream.JetStream
	// contains filtered or unexported fields
}

Ensures certain NATS config options are applied

func NewJSWrapper(js jetstream.JetStream, cfg config.NATS, shutdowner fx.Shutdowner) *JSWrapper

func (j *JSWrapper) ConsumeErrHandler(logger *zap.Logger) jetstream.PullConsumeOpt

func (j *JSWrapper) ConsumeErrHandlerWithRestart(c context.Context, logger *zap.Logger, restartFn ConsumeErrRestartFn) jetstream.PullConsumeOpt

func (j *JSWrapper) CreateOrUpdateKeyValue(ctx context.Context, cfg jetstream.KeyValueConfig) (jetstream.KeyValue, error)

func (j *JSWrapper) CreateOrUpdateStream(ctx context.Context, cfg jetstream.StreamConfig) (jetstream.Stream, error)

func (j *JSWrapper) Publish(ctx context.Context, subject string, payload []byte, opts ...jetstream.PublishOpt) (*jetstream.PubAck, error)

func (j *JSWrapper) PublishAsync(ctx context.Context, subject string, payload []byte, opts ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

func (j *JSWrapper) PublishMsg(ctx context.Context, msg *nats.Msg, opts ...jetstream.PublishOpt) (*jetstream.PubAck, error)

func (j *JSWrapper) PublishMsgAsync(ctx context.Context, msg *nats.Msg, opts ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

type Params struct {
	fx.In

	LC         fx.Lifecycle
	Shutdowner fx.Shutdowner

	Logger *zap.Logger
	Config *config.Config
}

type Result struct {
	fx.Out

	JS *JSWrapper
}

func New(p Params) (res Result, err error)

type Subject string

type Topic string

type Type string