timemap

Documentation

Index

• Constants
• type Entry
• type TimeMap
  • func New(id, capacity, hashSlots int, timeInterval uint32, timeSlots int) *TimeMap
  • func (m *TimeMap) AddOrMerge(entry Entry) error
  • func (m *TimeMap) AdvanceTime(timestamp uint32)
  • func (m *TimeMap) ClearOutput()
  • func (m *TimeMap) GetOutput() []Entry

Constants

const (
	INIT_OUTPUT_LEN = 1024
)

Types

type Entry

type Entry interface {
	Timestamp() uint32
	SetTimestamp(timestamp uint32)
	// Hash和Eq与timestamp没关系
	// 换句话说，调用了SetTimestamp或Merge之后，Hash不应该改变
	Hash() uint64
	Eq(other Entry) bool
	Merge(other Entry)
	Clone() Entry
	Release()
	fmt.Stringer
}

type TimeMap

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

func New

func New(id, capacity, hashSlots int, timeInterval uint32, timeSlots int) *TimeMap

func (*TimeMap) AddOrMerge

func (m *TimeMap) AddOrMerge(entry Entry) error

AddOrMerge does not consume entry

func (*TimeMap) AdvanceTime

func (m *TimeMap) AdvanceTime(timestamp uint32)

func (*TimeMap) ClearOutput

func (m *TimeMap) ClearOutput()

func (*TimeMap) GetOutput

func (m *TimeMap) GetOutput() []Entry