lease

Documentation

Index

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

Variables

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

lease errors

Types

type Factory

type Factory interface {
	// Next generate next lease chan.
	Next(ctx context.Context) (ch chan Lease, ok bool)
}

Factory can be used to generate leases.

func NewSimpleFactory

func NewSimpleFactory(interval, ttl, delay time.Duration, numberOfRequest uint32) (Factory, error)

NewSimpleFactory creates a simple lease factory.

type Lease

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

Lease represents lease structure.