v1

Documentation

Index

• func ResourceMatches(tp *deeptp.TracePointConfig, resource []*cp.KeyValue) bool
• type TPEncoder
  • func (t *TPEncoder) Flush(ctx context.Context, block types.TPBlock) error
  • func (t *TPEncoder) LoadBlock(ctx context.Context, tenantID string) (types.TPBlock, error)

Functions

func ResourceMatches

func ResourceMatches(tp *deeptp.TracePointConfig, resource []*cp.KeyValue) bool

Types

type TPEncoder

type TPEncoder struct {
	Reader deepdb.TracepointReader
	Writer deepdb.TracepointWriter
}

func (*TPEncoder) Flush

func (t *TPEncoder) Flush(ctx context.Context, block types.TPBlock) error

func (*TPEncoder) LoadBlock

func (t *TPEncoder) LoadBlock(ctx context.Context, tenantID string) (types.TPBlock, error)