logs

Documentation

Index

• type BufferedDirectLogsExporter
  • func NewBufferedDirectLogsExporter(log *logrus.Logger, consumer consumer.Logs, bufferSize int) *BufferedDirectLogsExporter
  • func (s *BufferedDirectLogsExporter) Export(ctx context.Context, flows <-chan protoreflect.Message) error
• type BufferedLogExporter
  • func NewBufferedLogExporter(otlpConn *grpc.ClientConn, bufferSize int, headers map[string]string, ...) *BufferedLogExporter
  • func (s *BufferedLogExporter) Export(ctx context.Context, flows <-chan protoreflect.Message) error
• type FlowConverter
  • func NewFlowConverter(log *logrus.Logger, options *common.EncodingOptions, ...) *FlowConverter
  • func (c *FlowConverter) Convert(hubbleResp *observer.GetFlowsResponse) (protoreflect.Message, error)

Types

type BufferedDirectLogsExporter

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

func NewBufferedDirectLogsExporter

func NewBufferedDirectLogsExporter(log *logrus.Logger, consumer consumer.Logs, bufferSize int) *BufferedDirectLogsExporter

func (*BufferedDirectLogsExporter) Export

func (s *BufferedDirectLogsExporter) Export(ctx context.Context, flows <-chan protoreflect.Message) error

type BufferedLogExporter

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

func NewBufferedLogExporter

func NewBufferedLogExporter(otlpConn *grpc.ClientConn, bufferSize int, headers map[string]string, callOptions ...grpc.CallOption) *BufferedLogExporter

func (*BufferedLogExporter) Export

func (s *BufferedLogExporter) Export(ctx context.Context, flows <-chan protoreflect.Message) error

type FlowConverter

type FlowConverter struct {
	*common.FlowEncoder
	// contains filtered or unexported fields
}

func NewFlowConverter

func NewFlowConverter(
	log *logrus.Logger,
	options *common.EncodingOptions,
	includeFlowTypes *common.IncludeFlowTypes,
	fallbackServiceNamePrefix string,
) *FlowConverter

func (*FlowConverter) Convert

func (c *FlowConverter) Convert(hubbleResp *observer.GetFlowsResponse) (protoreflect.Message, error)