scheduler

package
v1.16.3 Latest Latest
Warning

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

Go to latest
Published: Oct 31, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	FilterAll      = "all"
	FilterApp      = "app"
	FilterActor    = "actor"
	FilterWorkflow = "workflow"
	FilterActivity = "activity"
)

Variables

This section is empty.

Functions

func Delete

func Delete(ctx context.Context, opts DeleteOptions, keys ...string) error

func DeleteAll

func DeleteAll(ctx context.Context, opts DeleteOptions, key string) error

func EtcdClient

func EtcdClient(kubernetesMode bool, schedulerNamespace string) (*clientv3.Client, context.CancelFunc, error)

func Export

func Export(ctx context.Context, opts ExportImportOptions) error

func Import

func Import(ctx context.Context, opts ExportImportOptions) error

Types

type DeleteOptions

type DeleteOptions struct {
	SchedulerNamespace string
	DaprNamespace      string
	KubernetesMode     bool
}

type ExportFile

type ExportFile struct {
	Jobs     map[string][]byte
	Counters map[string][]byte
}

type ExportImportOptions

type ExportImportOptions struct {
	SchedulerNamespace string
	KubernetesMode     bool
	TargetFile         string
}

type Filter

type Filter struct {
	Type      string
	Namespace *string
}

type GetOptions

type GetOptions struct {
	SchedulerNamespace string
	DaprNamespace      string
	KubernetesMode     bool
}

type JobCount

type JobCount struct {
	Key     string
	Job     *stored.Job
	Counter *stored.Counter
}

func ListJobs

func ListJobs(ctx context.Context, opts ListOptions) ([]*JobCount, error)

type ListOptions

type ListOptions struct {
	SchedulerNamespace string
	KubernetesMode     bool
	Filter             Filter
}

type ListOutput

type ListOutput struct {
	Name        string `csv:"NAME" json:"name"  yaml:"name"`
	Begin       string `csv:"BEGIN" json:"begin"  yaml:"begin,omitempty"`
	Count       uint32 `csv:"COUNT" json:"count"  yaml:"count,omitempty"`
	LastTrigger string `csv:"LAST TRIGGER" json:"lastTrigger" yaml:"lastTrigger"`
}

func Get

func Get(ctx context.Context, opts GetOptions, keys ...string) ([]*ListOutput, error)

func List

func List(ctx context.Context, opts ListOptions) ([]*ListOutput, error)

type ListOutputWide

type ListOutputWide struct {
	Namespace   string     `csv:"NAMESPACE" json:"namespace" yaml:"namespace"`
	Name        string     `csv:"NAME" json:"name"  yaml:"name"`
	Begin       time.Time  `csv:"BEGIN" json:"begin"  yaml:"begin,omitempty"`
	Expiration  *time.Time `csv:"EXPIRATION" json:"expiration"  yaml:"expiration,omitempty"`
	Schedule    *string    `csv:"SCHEDULE" json:"schedule"  yaml:"schedule,omitempty"`
	DueTime     *string    `csv:"DUE TIME" json:"dueTime"  yaml:"dueTime,omitempty"`
	TTL         *string    `csv:"TTL" json:"ttl"  yaml:"ttl,omitempty"`
	Repeats     *uint32    `csv:"REPEATS" json:"repeats"  yaml:"repeats,omitempty"`
	Count       uint32     `csv:"COUNT" json:"count"  yaml:"count,omitempty"`
	LastTrigger *time.Time `csv:"LAST TRIGGER" json:"lastTrigger,omitempty"  yaml:"lastTrigger,omitempty"`
}

func GetWide

func GetWide(ctx context.Context, opts GetOptions, keys ...string) ([]*ListOutputWide, error)

func ListWide

func ListWide(ctx context.Context, opts ListOptions) ([]*ListOutputWide, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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