natskvlease

type BucketConfig struct {
	// Bucket is the name of the KeyValue bucket.
	Bucket string

	// TTL is the time-to-live for keys in the bucket.
	// If zero, DefaultBucketTTL is used.
	TTL time.Duration

	// Storage is the storage type (Memory or File).
	// Defaults to MemoryStorage.
	Storage jetstream.StorageType

	// Compression enables compression for the bucket.
	Compression bool
}

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

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

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

type LeaseCallbacks struct {
	// OnAcquired is called when the lease is successfully acquired.
	OnAcquired func()

	// OnLost is called when the lease is lost (not voluntarily released).
	OnLost func()

	// OnRenewed is called when the lease is successfully renewed.
	OnRenewed func()

	// OnReleased is called when the lease is voluntarily released.
	OnReleased func()
}

type LeaseConfig struct {
	// Key is the unique identifier for the lease in the KV store.
	Key string

	// TTL is the time-to-live for the lease.
	TTL time.Duration

	// RenewRatio is the ratio of TTL at which to renew (e.g., 0.5 means renew at 50% of TTL).
	RenewRatio float64

	// Value is the value to store with the lease (owner identifier).
	Value []byte

	// IsOwner checks if the given value belongs to this lease holder.
	IsOwner func(value []byte) bool

	// Callbacks for lease state changes.
	Callbacks LeaseCallbacks

	// Logger for lease operations.
	Logger *slog.Logger
}

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

type RetryConfig struct {
	MaxRetries     uint
	MaxElapsedTime time.Duration
}