lease

Documentation

Index

• Variables
• type Lease
• type Leases
  • func NewSimpleLease(interval, ttl, delay time.Duration, numberOfRequest uint32) (Leases, error)

Variables

var (
	ErrLeaseNotRcv         = errors.New("rsocket: lease was not received yet")
	ErrLeaseExpired        = errors.New("rsocket: lease expired")
	ErrLeaseNoMoreRequests = errors.New("rsocket: no more lease")
)

Types

type Lease

type Lease struct {
	TimeToLive       time.Duration
	NumberOfRequests uint32
	Metadata         []byte
}

type Leases

type Leases interface {
	Next(ctx context.Context) (ch chan Lease, ok bool)
}

func NewSimpleLease

func NewSimpleLease(interval, ttl, delay time.Duration, numberOfRequest uint32) (Leases, error)