rendezvous

Documentation

Index

• Constants
• Variables
• func GenerateRendezvousPointForPeriod(topic, seed []byte, date time.Time) []byte
• func NextTimePeriod(date time.Time, interval time.Duration) time.Time
• func RoundTimePeriod(date time.Time, interval time.Duration) time.Time
• type Point
  • func (p *Point) Deadline() time.Time
  • func (p *Point) IsExpired() bool
  • func (p *Point) NextPoint() *Point
  • func (p *Point) RawRotationTopic() []byte
  • func (p *Point) RawTopic() []byte
  • func (p *Point) RotationTopic() string
  • func (p *Point) Seed() []byte
  • func (p *Point) TTL() time.Duration
  • func (p *Point) Topic() string
• type RotationInterval
  • func NewRotationInterval(interval time.Duration) *RotationInterval
  • func NewStaticRotationInterval() *RotationInterval
  • func (r *RotationInterval) NewRendezvousPointForPeriod(at time.Time, topic string, seed []byte) (point *Point)
  • func (r *RotationInterval) NextTimePeriod(at time.Time) time.Time
  • func (r *RotationInterval) PointForRawRotation(rotation []byte) (*Point, error)
  • func (r *RotationInterval) PointForRotation(rotation string) (*Point, error)
  • func (r *RotationInterval) PointForTopic(topic string) (*Point, error)
  • func (r *RotationInterval) RegisterRotation(at time.Time, topic string, seed []byte)
  • func (r *RotationInterval) RoundTimePeriod(at time.Time) time.Time

Constants

const DefaultRotationInterval = time.Hour * 24

Variables

var (
	RotationGracePeriod  = time.Minute * 10
	MinimumDelayRotation = time.Minute
)

Functions

func GenerateRendezvousPointForPeriod

func GenerateRendezvousPointForPeriod(topic, seed []byte, date time.Time) []byte

func NextTimePeriod

func NextTimePeriod(date time.Time, interval time.Duration) time.Time

func RoundTimePeriod

func RoundTimePeriod(date time.Time, interval time.Duration) time.Time

Types

type Point

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

func (*Point) Deadline

func (p *Point) Deadline() time.Time

func (*Point) IsExpired

func (p *Point) IsExpired() bool

func (*Point) NextPoint

func (p *Point) NextPoint() *Point

func (*Point) RawRotationTopic

func (p *Point) RawRotationTopic() []byte

func (*Point) RawTopic

func (p *Point) RawTopic() []byte

func (*Point) RotationTopic

func (p *Point) RotationTopic() string

func (*Point) Seed

func (p *Point) Seed() []byte

func (*Point) TTL

func (p *Point) TTL() time.Duration

func (*Point) Topic

func (p *Point) Topic() string

type RotationInterval

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

func NewRotationInterval

func NewRotationInterval(interval time.Duration) *RotationInterval

func NewStaticRotationInterval

func NewStaticRotationInterval() *RotationInterval

func (*RotationInterval) NewRendezvousPointForPeriod

func (r *RotationInterval) NewRendezvousPointForPeriod(at time.Time, topic string, seed []byte) (point *Point)

func (*RotationInterval) NextTimePeriod

func (r *RotationInterval) NextTimePeriod(at time.Time) time.Time

func (*RotationInterval) PointForRawRotation

func (r *RotationInterval) PointForRawRotation(rotation []byte) (*Point, error)

func (*RotationInterval) PointForRotation

func (r *RotationInterval) PointForRotation(rotation string) (*Point, error)

func (*RotationInterval) PointForTopic

func (r *RotationInterval) PointForTopic(topic string) (*Point, error)

func (*RotationInterval) RegisterRotation

func (r *RotationInterval) RegisterRotation(at time.Time, topic string, seed []byte)

func (*RotationInterval) RoundTimePeriod

func (r *RotationInterval) RoundTimePeriod(at time.Time) time.Time