exporter

Documentation

Index

• type EndpointConfig
  • func CreateEndpointConfigs(cfg []config.Endpoint) []EndpointConfig
• type Exporter
  • func New(endpoints []EndpointConfig) (*Exporter, error)
  • func (e *Exporter) ExportCommits(ctx context.Context, data []*typespb.Commit) error
  • func (e *Exporter) ExportJobs(ctx context.Context, data []*typespb.Job) error
  • func (e *Exporter) ExportMergeRequestNoteEvents(ctx context.Context, data []*typespb.MergeRequestNoteEvent) error
  • func (e *Exporter) ExportMergeRequests(ctx context.Context, data []*typespb.MergeRequest) error
  • func (e *Exporter) ExportMetrics(ctx context.Context, data []*typespb.Metric) error
  • func (e *Exporter) ExportPipelines(ctx context.Context, data []*typespb.Pipeline) error
  • func (e *Exporter) ExportProjects(ctx context.Context, data []*typespb.Project) error
  • func (e *Exporter) ExportSections(ctx context.Context, data []*typespb.Section) error
  • func (e *Exporter) ExportTestCases(ctx context.Context, data []*typespb.TestCase) error
  • func (e *Exporter) ExportTestReports(ctx context.Context, data []*typespb.TestReport) error
  • func (e *Exporter) ExportTestSuites(ctx context.Context, data []*typespb.TestSuite) error
  • func (e *Exporter) ExportTraces(ctx context.Context, data []*typespb.Trace) error
  • func (e *Exporter) MetricsCollectorFor(endpoint string) prometheus.Collector

Types

type EndpointConfig

type EndpointConfig struct {
	Address string
	Options []grpc.DialOption
}

func CreateEndpointConfigs

func CreateEndpointConfigs(cfg []config.Endpoint) []EndpointConfig

type Exporter

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

func New

func New(endpoints []EndpointConfig) (*Exporter, error)

func (*Exporter) ExportCommits

func (e *Exporter) ExportCommits(ctx context.Context, data []*typespb.Commit) error

func (*Exporter) ExportJobs

func (e *Exporter) ExportJobs(ctx context.Context, data []*typespb.Job) error

func (*Exporter) ExportMergeRequestNoteEvents

func (e *Exporter) ExportMergeRequestNoteEvents(ctx context.Context, data []*typespb.MergeRequestNoteEvent) error

func (*Exporter) ExportMergeRequests

func (e *Exporter) ExportMergeRequests(ctx context.Context, data []*typespb.MergeRequest) error

func (*Exporter) ExportMetrics

func (e *Exporter) ExportMetrics(ctx context.Context, data []*typespb.Metric) error

func (*Exporter) ExportPipelines

func (e *Exporter) ExportPipelines(ctx context.Context, data []*typespb.Pipeline) error

func (*Exporter) ExportProjects

func (e *Exporter) ExportProjects(ctx context.Context, data []*typespb.Project) error

func (*Exporter) ExportSections

func (e *Exporter) ExportSections(ctx context.Context, data []*typespb.Section) error

func (*Exporter) ExportTestCases

func (e *Exporter) ExportTestCases(ctx context.Context, data []*typespb.TestCase) error

func (*Exporter) ExportTestReports

func (e *Exporter) ExportTestReports(ctx context.Context, data []*typespb.TestReport) error

func (*Exporter) ExportTestSuites

func (e *Exporter) ExportTestSuites(ctx context.Context, data []*typespb.TestSuite) error

func (*Exporter) ExportTraces

func (e *Exporter) ExportTraces(ctx context.Context, data []*typespb.Trace) error

func (*Exporter) MetricsCollectorFor

func (e *Exporter) MetricsCollectorFor(endpoint string) prometheus.Collector