tasks

Documentation

Index

• type DailyQuotaCollector
  • func NewDailyQuotaCollector(opts ...DailyQuotaCollectorOption) *DailyQuotaCollector
  • func (d *DailyQuotaCollector) Task() (bool, error)
• type DailyQuotaCollectorOption
  • func DailyQuotaCollectorWithBundle(bndl *bundle.Bundle) DailyQuotaCollectorOption
  • func DailyQuotaCollectorWithCMPAPI(cmp interface{ ... }) DailyQuotaCollectorOption
  • func DailyQuotaCollectorWithDBClient(db *dbclient.DBClient) DailyQuotaCollectorOption
• type ExitError
  • func (e ExitError) Error() string
• type Task
• type Ticker
  • func New(interval time.Duration, task func() (bool, error)) *Ticker
  • func (d *Ticker) Close()
  • func (d *Ticker) Run() error

Types

type DailyQuotaCollector

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

func NewDailyQuotaCollector

func NewDailyQuotaCollector(opts ...DailyQuotaCollectorOption) *DailyQuotaCollector

func (*DailyQuotaCollector) Task

func (d *DailyQuotaCollector) Task() (bool, error)

type DailyQuotaCollectorOption

type DailyQuotaCollectorOption func(collector *DailyQuotaCollector)

func DailyQuotaCollectorWithBundle

func DailyQuotaCollectorWithBundle(bndl *bundle.Bundle) DailyQuotaCollectorOption

func DailyQuotaCollectorWithCMPAPI

func DailyQuotaCollectorWithCMPAPI(cmp interface {
	ListSteveResource(ctx context.Context, req *apistructs.SteveRequest) ([]types.APIObject, error)
	GetNamespacesResources(ctx context.Context, nReq *pb.GetNamespacesResourcesRequest) (*pb.GetNamespacesResourcesResponse, error)
	GetClustersResources(ctx context.Context, cReq *pb.GetClustersResourcesRequest) (*pb.GetClusterResourcesResponse, error)
	GetAllClusters() []string
}) DailyQuotaCollectorOption

func DailyQuotaCollectorWithDBClient

func DailyQuotaCollectorWithDBClient(db *dbclient.DBClient) DailyQuotaCollectorOption

type ExitError

type ExitError struct {
	Message string
}

func (ExitError) Error

func (e ExitError) Error() string

type Task

type Task func() error

type Ticker

type Ticker struct {
	Name     string
	Interval time.Duration
	Task     func() (stop bool, err error)
	// contains filtered or unexported fields
}

func New

func New(interval time.Duration, task func() (bool, error)) *Ticker

func (*Ticker) Close

func (d *Ticker) Close()

func (*Ticker) Run

func (d *Ticker) Run() error