inserter

package
v4.15.9+incompatible Latest Latest
Warning

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

Go to latest
Published: Jan 25, 2019 License: GPL-3.0 Imports: 9 Imported by: 2

Documentation

Index

Constants

View Source
const UpmuSpaceString = "c9bbebff-ff40-4dbe-987e-f9e96afb7a57"

UpmuSpaceString is UpmuSpace as a human-readable string

Variables

UpmuSpace is used to generate deterministic UUIDs...

Functions

func DescriptorFromSerial

func DescriptorFromSerial(serial string) string

func GetUUID

func GetUUID(serial string, streamname string) uuid.UUID

func PerformInsert

func PerformInsert(c chan InsertReq, wg *sync.WaitGroup)

func ProcessMessage

func ProcessMessage(ctx context.Context, sernum string, data []byte, bc *btrdb.BTrDB, serialToPath func(ctx context.Context, sernum string) string, ic chan InsertReq) bool

ProcessMessage processes a message from a uPMU, inserting it into BTrDB

Types

type InsertReq

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

Jump to

Keyboard shortcuts

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