mapper

Documentation

Overview

Package mapper contains a transformation pipeline from log messages to map revisions.

Index

• func MapMapLeafFn(leaf *tpb.MapLeaf) (*entry.IndexedValue, error)
• func MapMetaFn(meta *spb.MapMetadata, emit func(*spb.MapMetadata_SourceSlice))
• func MapUpdateFn(msg *pb.EntryUpdate) (*entry.IndexedValue, error)

Functions

func MapMapLeafFn

func MapMapLeafFn(leaf *tpb.MapLeaf) (*entry.IndexedValue, error)

MapMapLeaf converts a map leaf into an entry.IndexedValue.

func MapMetaFn

func MapMetaFn(meta *spb.MapMetadata, emit func(*spb.MapMetadata_SourceSlice))

MapMetaFn emits the source slices referenced by meta.

func MapUpdateFn

func MapUpdateFn(msg *pb.EntryUpdate) (*entry.IndexedValue, error)

MapUpdateFn converts an update into an entry.IndexedValue.