partition

Documentation

Overview

Package partition is a tuple containing (start, end) time and an optional slot. Window contains a partition because Window contains the keys too. A partition is used to map a message to a pbq instance.

Index

• type ID
  • func (p ID) String() string

Types

type ID

type ID struct {
	Start time.Time
	End   time.Time
	// Slot is a hash-range for keys (multiple keys can go to the same slot)
	Slot string
}

ID uniquely identifies a partition.

func (ID) String

func (p ID) String() string