metadata

Documentation

Overview

Package metadata helps enforce a consistent standard of meaning around the map metadata object.

Index

• type SourceSlice
  • func FromProto(s *spb.MapMetadata_SourceSlice) *SourceSlice
  • func New(logID int64, low, high water.Mark) *SourceSlice
  • func (s SourceSlice) HighMark() water.Mark
  • func (s SourceSlice) LowMark() water.Mark
  • func (s *SourceSlice) Proto() *spb.MapMetadata_SourceSlice

Types

type SourceSlice

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

SourceSlice is a helper for the MapMetadata_SourceSlice proto message.

func FromProto

func FromProto(s *spb.MapMetadata_SourceSlice) *SourceSlice

FromProto returns a wrapper for the given proto SourceSlice.

func New

func New(logID int64, low, high water.Mark) *SourceSlice

New creates a new source slice from watermarks for the given log.

func (SourceSlice) HighMark

func (s SourceSlice) HighMark() water.Mark

HighMark returns HighestExclusive as a watermark.

func (SourceSlice) LowMark

func (s SourceSlice) LowMark() water.Mark

LowMark returns LowestInclusive as a watermark.

func (*SourceSlice) Proto

func (s *SourceSlice) Proto() *spb.MapMetadata_SourceSlice

Proto returns the proto representation of the SourceSlice.