exporter

Documentation

Index

• func NewExportedBytesTotalWriter(w io.Writer) io.Writer
• func RegisterMetrics(group metrics.Group)
• type ExportEncoder
• type Exporter
  • func NewExporter(ctx context.Context, request *tetragon.GetEventsRequest, server *server.Server, ...) *Exporter
  • func (e *Exporter) Context() context.Context
  • func (e *Exporter) RecvMsg(_ interface{}) error
  • func (e *Exporter) Send(event *tetragon.GetEventsResponse) error
  • func (e *Exporter) SendHeader(metadata.MD) error
  • func (e *Exporter) SendMsg(_ interface{}) error
  • func (e *Exporter) SetHeader(metadata.MD) error
  • func (e *Exporter) SetTrailer(metadata.MD)
  • func (e *Exporter) Start() error

Functions

func NewExportedBytesTotalWriter

func NewExportedBytesTotalWriter(w io.Writer) io.Writer

func RegisterMetrics

func RegisterMetrics(group metrics.Group)

Types

type ExportEncoder

type ExportEncoder interface {
	Encode(v interface{}) error
}

type Exporter

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

func NewExporter

func NewExporter(
	ctx context.Context,
	request *tetragon.GetEventsRequest,
	server *server.Server,
	encoder ExportEncoder,
	closer io.Closer,
	rateLimiter *ratelimit.RateLimiter,
) *Exporter

func (*Exporter) Context

func (e *Exporter) Context() context.Context

func (*Exporter) RecvMsg

func (e *Exporter) RecvMsg(_ interface{}) error

func (*Exporter) Send

func (e *Exporter) Send(event *tetragon.GetEventsResponse) error

func (*Exporter) SendHeader

func (e *Exporter) SendHeader(metadata.MD) error

func (*Exporter) SendMsg

func (e *Exporter) SendMsg(_ interface{}) error

func (*Exporter) SetHeader

func (e *Exporter) SetHeader(metadata.MD) error

func (*Exporter) SetTrailer

func (e *Exporter) SetTrailer(metadata.MD)

func (*Exporter) Start

func (e *Exporter) Start() error