exporter

package
v0.0.0-...-7784702 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 6, 2022 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RunExporter

func RunExporter(runner ExporterRunner, runnerConfig *config.RunnerConfig) error

Types

type Exporter

type Exporter interface {
	Start()
}

type ExporterApp

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

func NewExporterApp

func NewExporterApp(config *cfg.Config) *ExporterApp

func (*ExporterApp) Start

func (app *ExporterApp) Start()

type ExporterAppRunner

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

func (ExporterAppRunner) Collect

func (r ExporterAppRunner) Collect(runnerConfig *cfg.RunnerConfig, kubeConfig *rest.Config) (*model.TopologyModel, error)

func (ExporterAppRunner) Connect

func (r ExporterAppRunner) Connect() (*rest.Config, error)

func (ExporterAppRunner) Report

func (r ExporterAppRunner) Report(runnerConfig *cfg.RunnerConfig, output *strings.Builder)

func (ExporterAppRunner) Transform

func (r ExporterAppRunner) Transform(topology *model.TopologyModel) *strings.Builder

type ExporterRunner

type ExporterRunner interface {
	Connect() (*rest.Config, error)
	Collect(runnerConfig *config.RunnerConfig, config *rest.Config) (*model.TopologyModel, error)
	Transform(topology *model.TopologyModel) *strings.Builder
	Report(runnerConfig *config.RunnerConfig, output *strings.Builder)
}

type ExporterService

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

func NewExporterService

func NewExporterService(config *config.Config) *ExporterService

func (*ExporterService) NewRunner

func (*ExporterService) Start

func (s *ExporterService) Start()

type ExporterServiceRunner

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

func (ExporterServiceRunner) Collect

func (r ExporterServiceRunner) Collect(runnerConfig *cfg.RunnerConfig, kubeConfig *rest.Config) (*model.TopologyModel, error)

func (ExporterServiceRunner) Connect

func (r ExporterServiceRunner) Connect() (*rest.Config, error)

func (ExporterServiceRunner) Report

func (r ExporterServiceRunner) Report(runnerConfig *cfg.RunnerConfig, output *strings.Builder)

func (ExporterServiceRunner) Transform

func (r ExporterServiceRunner) Transform(topology *model.TopologyModel) *strings.Builder

type FileReporter

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

func NewFileReporter

func NewFileReporter(config *config.Config, runnerConfig *config.RunnerConfig) FileReporter

func (*FileReporter) Report

func (r *FileReporter) Report(data *strings.Builder)

type HttpReporter

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

func NewHttpReporter

func NewHttpReporter(config *config.Config, runnerConfig *config.RunnerConfig, rw http.ResponseWriter) HttpReporter

func (*HttpReporter) Report

func (r *HttpReporter) Report(data *strings.Builder)

type ModelBuilder

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

func NewModelBuilder

func NewModelBuilder(config *config.Config, runnerConfig *config.RunnerConfig) *ModelBuilder

func (*ModelBuilder) BuildForKubeConfig

func (builder *ModelBuilder) BuildForKubeConfig(config *rest.Config) (*model.TopologyModel, error)

type Reporter

type Reporter interface {
	Report(w *io.Writer)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL