workload

package
v0.0.0-...-7bbfb33 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 24, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildConfigRequest

func BuildConfigRequest(request *lbot.ConfigRequest) *proto.ConfigRequest

func CheckPromptErr

func CheckPromptErr(err error)

func GenerateConfigWorkload

func GenerateConfigWorkload() (err error)

func GetBooleanInput

func GetBooleanInput(label string) bool

func GetDurationInput

func GetDurationInput(label string, defaultValue string) *time.Duration

func GetNumberInput

func GetNumberInput(label string, defaultValue string) int

func GetSelectInput

func GetSelectInput(label string, options []string, ops ...choose.Option) string

func GetSelectWithDescriptionInput

func GetSelectWithDescriptionInput(label string, options []choose.Choice, ops ...choose.Option) string

func GetStringInput

func GetStringInput(label string, defaultValue string) string

func GetWorkloadConfig

func GetWorkloadConfig(conn grpc.ClientConnInterface) (err error)

func SetWorkloadConfig

func SetWorkloadConfig(conn grpc.ClientConnInterface, parsedConfig *lbot.ConfigRequest) (err error)

checks if process is running in local system here should be cli config request - not lbot one

func StartWorkload

func StartWorkload(conn grpc.ClientConnInterface, request *proto.StartRequest) (err error)

tutaj nie powinno wchodzić proto

func StartWorkloadWithProgress

func StartWorkloadWithProgress(conn grpc.ClientConnInterface, request *proto.StartWithProgressRequest) (err error)

func StopWorkload

func StopWorkload(conn grpc.ClientConnInterface, request *proto.StopRequest) (err error)

func WatchWorkload

func WatchWorkload(conn grpc.ClientConnInterface, request *proto.WatchRequest) (err error)

func WorkloadProgress

func WorkloadProgress(conn grpc.ClientConnInterface, request *proto.ProgressRequest) (err error)

Types

type ProgressBar

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

func NewProgressBar

func NewProgressBar() *ProgressBar

todo: no need to send request ops and request duration in every request pull job data in init

func (*ProgressBar) Finish

func (b *ProgressBar) Finish()

func (*ProgressBar) Init

func (b *ProgressBar) Init(resp *proto.ProgressResponse)

func (*ProgressBar) IsInitialized

func (b *ProgressBar) IsInitialized(resp *proto.ProgressResponse) bool

func (*ProgressBar) Start

func (b *ProgressBar) Start(resp *proto.ProgressResponse)

func (*ProgressBar) Update

func (b *ProgressBar) Update(resp *proto.ProgressResponse)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL