span

Documentation

Index

• Constants
• func SpanIngestRunFromContext(runCtx context.Context, spanName string) (ddtrace.Span, context.Context)

Constants

const (
	IngestData = "kubehound.ingestData"
	BuildGraph = "kubehound.buildGraph"
	Launch     = "kubehound.launch"
)

Top level spans

const (
	JanusGraphFlush      = "kubehound.janusgraph.flush"
	JanusGraphBatchWrite = "kubehound.janusgraph.batchwrite"
)

JanusGraph provider spans

const (
	MongoDBFlush      = "kubehound.mongo.flush"
	MongoDBBatchWrite = "kubehound.mongo.batchwrite"
)

MongoDB provider spans

const (
	CollectorStream = "kubehound.collector.stream"
	CollectorDump   = "kubehound.collector.dump"

	IngestorLaunch      = "kubehound.ingestor.launch"
	IngestorStartJob    = "kubehound.ingestor.startjob"
	IngestorBlobPull    = "kubehound.ingestor.blob.pull"
	IngestorBlobPut     = "kubehound.ingestor.blob.put"
	IngestorBlobExtract = "kubehound.ingestor.blob.extract"
	IngestorBlobClose   = "kubehound.ingestor.blob.close"

	DumperLaunch = "kubehound.dumper.launch"

	DumperNodes               = "kubehound.dumper.nodes"
	DumperPods                = "kubehound.dumper.pods"
	DumperEndpoints           = "kubehound.dumper.endpoints"
	DumperRoles               = "kubehound.dumper.roles"
	DumperClusterRoles        = "kubehound.dumper.clusterroles"
	DumperRoleBindings        = "kubehound.dumper.rolebindings"
	DumperClusterRoleBindings = "kubehound.dumper.clusterrolebindings"

	DumperReadFile    = "kubehound.dumper.readFile"
	DumperS3Push      = "kubehound.dumper.s3_push"
	DumperS3Download  = "kubehound.dumper.s3_download"
	DumperWriterWrite = "kubehound.dumper.write"
	DumperWriterFlush = "kubehound.dumper.flush"
	DumperWriterClose = "kubehound.dumper.close"
)

Collector/dumper component spans

const (
	ContextLogFieldClusterName contextKey = iota
	ContextLogFieldRunID
)

const (
	BuildEdge = "kubehound.graph.builder.edge"
)

Graph builder spans

Functions

func SpanIngestRunFromContext

func SpanIngestRunFromContext(runCtx context.Context, spanName string) (ddtrace.Span, context.Context)