worker

Documentation

Index

• type Stats
  • func RunExport(ctx context.Context, workers []Worker, resources []*types.GroupResource) (*Stats, error)
  • func (s *Stats) Add(o *Stats)
  • func (s *Stats) HasErrors() bool
  • func (s *Stats) Namespaces() int
• type Worker
  • func New(id int, config *types.Config, ac *client.ApiClient, prog progress.Progress) Worker

Types

type Stats

type Stats struct {
	Errors int

	Kinds     int
	Pages     int
	Resources int
	// contains filtered or unexported fields
}

Stats worker stats

func RunExport

func RunExport(ctx context.Context, workers []Worker, resources []*types.GroupResource) (*Stats, error)

RunExport run the export wit the given workers

func (*Stats) Add

func (s *Stats) Add(o *Stats)

Add stats

func (*Stats) HasErrors

func (s *Stats) HasErrors() bool

HasErrors true if errors >0

func (*Stats) Namespaces

func (s *Stats) Namespaces() int

Namespaces get the number of namespaces

type Worker

type Worker interface {
	GenerateWork(ctx context.Context, s *sync.WaitGroup, out chan *types.GroupResource) func(resource *types.GroupResource)
	Stop() Stats
}

Worker interface

func New

func New(id int, config *types.Config, ac *client.ApiClient, prog progress.Progress) Worker

New create a new worker