Documentation
¶
Index ¶
- Constants
- func Delete(ctx context.Context, opts DeleteOptions, keys ...string) error
- func DeleteAll(ctx context.Context, opts DeleteOptions, key string) error
- func EtcdClient(kubernetesMode bool, schedulerNamespace string) (*clientv3.Client, context.CancelFunc, error)
- func Export(ctx context.Context, opts ExportImportOptions) error
- func Import(ctx context.Context, opts ExportImportOptions) error
- type DeleteOptions
- type ExportFile
- type ExportImportOptions
- type Filter
- type GetOptions
- type JobCount
- type ListOptions
- type ListOutput
- type ListOutputWide
Constants ¶
View Source
const ( FilterAll = "all" FilterApp = "app" FilterActor = "actor" FilterWorkflow = "workflow" FilterActivity = "activity" )
Variables ¶
This section is empty.
Functions ¶
func EtcdClient ¶
Types ¶
type DeleteOptions ¶
type ExportImportOptions ¶
type GetOptions ¶
type ListOptions ¶
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)
Click to show internal directories.
Click to hide internal directories.