inserter

Documentation

Index

• Constants
• Variables
• func DescriptorFromSerial(serial string) string
• func GetUUID(serial string, streamname string) uuid.UUID
• func PerformInsert(c chan InsertReq, wg *sync.WaitGroup)
• func ProcessMessage(ctx context.Context, sernum string, data []byte, bc *btrdb.BTrDB, ...) bool
• type InsertReq

Constants

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

UpmuSpaceString is UpmuSpace as a human-readable string

Variables

var UpmuSpace = uuid.Parse(UpmuSpaceString)

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
}