reporter

type Config struct {
	OutputDirectory      string
	MetricsPerFile       *int
	MaxRoutines          *int
	Retry                *int
	CaFile               string
	TokenFile            string
	DataServiceTokenFile string
	DataServiceCertFile  string
	DeployedNamespace    string
	Local                bool
	Upload               bool
	IsDisconnected       bool
	PrometheusService    string
	PrometheusNamespace  string
	PrometheusPort       string
	uploaders.UploaderTargets
	ReporterSchema string
	CipherSuites   []uint16
	MinVersion     uint16

	K8sRestConfig *rest.Config
}

type MarketplaceReporter struct {
	PrometheusAPI
	MktConfig *marketplacev1alpha1.MarketplaceConfig

	*Config
	// contains filtered or unexported fields
}

type MeterDefKey struct {
	Name, Namespace string
}

type MeterDefinitionReferences = []marketplacev1beta1.MeterDefinitionReference

type Name types.NamespacedName

type Namespace string

type PrometheusService *corev1.Service

type ReconcileTask struct {
	K8SClient client.Client
	Config    *Config
	K8SScheme *runtime.Scheme
	Namespace

	NewTask   func(ctx context.Context, reportName ReportName, taskConfig *Config) (TaskRun, error)
	NewUpload func(ctx context.Context, config *Config, namespace Namespace) (UploadRun, error)
	// contains filtered or unexported fields
}

type ReportName types.NamespacedName

type ReportOutputDir string

type ReportSkipReason string

type Task struct {
	ReportName ReportName
	K8SClient  rhmclient.SimpleClient
	Config     *Config
	uploaders.Uploader
}

type TaskRun interface {
	Run(ctx context.Context) error
}

type UploadRun interface {
	RunGeneric(ctx context.Context) error
	RunReport(ctx context.Context, report *marketplacev1alpha1.MeterReport) error
}

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