hub

Documentation

Index

• type AROHCPPreparerOptions
  • func NewAROHCPPreparerOptions() *AROHCPPreparerOptions
  • func (o *AROHCPPreparerOptions) AddFlags(fs *pflag.FlagSet)
  • func (o *AROHCPPreparerOptions) CreateWorks(ctx context.Context, phase string) error
  • func (o *AROHCPPreparerOptions) PrepareClusters(ctx context.Context) error
  • func (o *AROHCPPreparerOptions) Run(ctx context.Context) error

Types

type AROHCPPreparerOptions

type AROHCPPreparerOptions struct {
	MaestroServiceAddress string
	GRPCServiceAddress    string

	ClusterBeginIndex int
	ClusterCounts     int

	OnlyClusters bool

	WorkCounts int
}

func NewAROHCPPreparerOptions

func NewAROHCPPreparerOptions() *AROHCPPreparerOptions

func (*AROHCPPreparerOptions) AddFlags

func (o *AROHCPPreparerOptions) AddFlags(fs *pflag.FlagSet)

func (*AROHCPPreparerOptions) CreateWorks

func (o *AROHCPPreparerOptions) CreateWorks(ctx context.Context, phase string) error

func (*AROHCPPreparerOptions) PrepareClusters

func (o *AROHCPPreparerOptions) PrepareClusters(ctx context.Context) error

func (*AROHCPPreparerOptions) Run

func (o *AROHCPPreparerOptions) Run(ctx context.Context) error