jetstream

package

v0.3.0 Latest Latest Go to latest Published: Sep 19, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

This section is empty.

View Source

var (
	LockValidity   = 60 * time.Second
	LockRetryDelay = 100 * time.Millisecond
)

func AcquireJetstreamConn(ctx context.Context, conf *v1alpha1.JetstreamClientSpec, lg *slog.Logger) (nats.JetStreamContext, error)

type Lock struct {
	*lock.LockOptions
	// contains filtered or unexported fields
}

func NewLock(js nats.JetStreamContext, prefix, key string, lg *slog.Logger, options *lock.LockOptions) *Lock

func (l *Lock) Key() string

func (l *Lock) Lock(ctx context.Context) (<-chan struct{}, error)

func (l *Lock) TryLock(ctx context.Context) (acquired bool, done <-chan struct{}, err error)

func (l *Lock) Unlock() error

type LockManager struct {
	// contains filtered or unexported fields
}

Requires jetstream 2.9+

func NewLockManager(
	ctx context.Context,
	js nats.JetStreamContext,
	prefix string,
	tracer trace.Tracer,
	lg *slog.Logger,
) *LockManager

func (l *LockManager) Health(ctx context.Context) (conditions []string, err error)

func (l *LockManager) NewLock(key string, opts ...lock.LockOption) lock.Lock