insightsuploader

Documentation

Index

• type Authorizer
• type Controller
  • func New(summarizer Summarizer, client *insightsclient.Client, ...) *Controller
  • func (c *Controller) ArchiveUploaded() <-chan struct{}
  • func (c *Controller) Run(ctx context.Context, initialDelay time.Duration)
  • func (c *Controller) Upload(ctx context.Context, s *insightsclient.Source) (string, int, error)
• type StatusReporter
• type Summarizer

Types

type Authorizer

type Authorizer interface {
	IsAuthorizationError(error) bool
}

type Controller

type Controller struct {
	controllerstatus.StatusController
	// contains filtered or unexported fields
}

func New

func New(summarizer Summarizer,
	client *insightsclient.Client,
	configurator configobserver.Interface,
	apiConfigurator configobserver.InsightsDataGatherObserver,
	statusReporter StatusReporter,
	initialDelay time.Duration) *Controller

func (*Controller) ArchiveUploaded

func (c *Controller) ArchiveUploaded() <-chan struct{}

ArchiveUploaded returns a channel that indicates when an archive is uploaded

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, initialDelay time.Duration)

func (*Controller) Upload

func (c *Controller) Upload(ctx context.Context, s *insightsclient.Source) (string, int, error)

Upload is an alternative simple upload method used only in TechPreview clusters. Returns Insights request ID and error=nil in case of successful data upload.

type StatusReporter

type StatusReporter interface {
	LastReportedTime() time.Time
	SetLastReportedTime(time.Time)
}

type Summarizer

type Summarizer interface {
	Summary(ctx context.Context, since time.Time) (*insightsclient.Source, bool, error)
}