water

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 3, 2020 License: Apache-2.0 Imports: 0 Imported by: 0

Documentation

Overview

Package water provides the watermark type.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Mark

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

Mark is wrapper for uint64 representing a watermark, or a logical timestamp. Some implementations use an actual timestamp in micro- or nanoseconds, some use more generic sequence numbers.

func NewMark

func NewMark(value uint64) Mark

NewMark returns a watermark from the given integer value.

func (Mark) Add

func (m Mark) Add(value uint64) Mark

Add increments the watermark by the passed in value.

func (Mark) Compare

func (m Mark) Compare(other Mark) int

Compare returns the result of comparing this Mark with with the other.

func (Mark) Value

func (m Mark) Value() uint64

Value returns the uint64 representation of the watermark.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL