v1

package
v0.0.0-...-a134451 Latest Latest
Warning

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

Go to latest
Published: Feb 28, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source
var Scheme = runtime.NewScheme()
View Source
var SchemeGroupVersion = schema.GroupVersion{Group: constant.GroupName, Version: "v1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type CodeGetter

type CodeGetter interface {
	Code() CodeInterface
}

type CodeInterface

type CodeInterface interface {
	Create(ctx context.Context, code *meta.Code, opts meta.CreateOptions) (*meta.Code, error)
	Update(ctx context.Context, code *meta.Code, opts meta.UpdateOptions) (*meta.Code, error)
	Delete(ctx context.Context, name string, opts meta.DeleteOptions) error
	DeleteCollection(ctx context.Context, opts meta.DeleteOptions, listOpts meta.ListOptions) error
	Get(ctx context.Context, name string, opts meta.GetOptions) (*meta.Code, error)
	List(ctx context.Context, opts meta.ListOptions) (*meta.CodeList, error)
	Watch(ctx context.Context, opts meta.ListOptions) (watch.Interface, error)
	Patch(ctx context.Context, name string, pt string, data []byte, opts meta.PatchOptions, subresources ...string) (result *meta.Code, err error)
}

type ConnectionGetter

type ConnectionGetter interface {
	Connection() ConnectionInterface
}

type ConnectionInterface

type ConnectionInterface interface {
	Create(ctx context.Context, connection *meta.Connection, opts meta.CreateOptions) (*meta.Connection, error)
	Update(ctx context.Context, connection *meta.Connection, opts meta.UpdateOptions) (*meta.Connection, error)
	Delete(ctx context.Context, name string, opts meta.DeleteOptions) error
	DeleteCollection(ctx context.Context, opts meta.DeleteOptions, listOpts meta.ListOptions) error
	Get(ctx context.Context, name string, opts meta.GetOptions) (*meta.Connection, error)
	List(ctx context.Context, opts meta.ListOptions) (*meta.ConnectionList, error)
	Watch(ctx context.Context, opts meta.ListOptions) (watch.Interface, error)
	Patch(ctx context.Context, name string, pt string, data []byte, opts meta.PatchOptions, subresources ...string) (result *meta.Connection, err error)
}

type CoreV1Client

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

func New

func New(c rest.Interface) *CoreV1Client

func NewForConfig

func NewForConfig(c *rest.Config, h *http.Client) (*CoreV1Client, error)

func NewForConfigAndClient

func NewForConfigAndClient(c *rest.Config, h *http.Client) (*CoreV1Client, error)

NewForConfigAndClient creates a new CoreV1Client for the given config and http client. Note the http client provided takes precedence over the configured transport values.

func (*CoreV1Client) Code

func (c *CoreV1Client) Code() CodeInterface

func (*CoreV1Client) Connection

func (c *CoreV1Client) Connection() ConnectionInterface

func (*CoreV1Client) Job

func (c *CoreV1Client) Job() JobInterface

func (*CoreV1Client) RESTClient

func (c *CoreV1Client) RESTClient() rest.Interface

RESTClient returns a RESTClient that is used to communicate with API server by this client implementation.

func (*CoreV1Client) Stage

func (c *CoreV1Client) Stage() StageInterface

func (*CoreV1Client) Variable

func (c *CoreV1Client) Variable() VariableInterface

func (*CoreV1Client) Worker

func (c *CoreV1Client) Worker() WorkerInterface

func (*CoreV1Client) Workflow

func (c *CoreV1Client) Workflow() WorkflowInterface

type JobExpansion

type JobExpansion interface {
	Bind(ctx context.Context, binding *meta.Binding, opts meta.CreateOptions) error
}

The JobExpansion interface allows manually adding extra methods to the JobInterface.

type JobGetter

type JobGetter interface {
	Job() JobInterface
}

type JobInterface

type JobInterface interface {
	Create(ctx context.Context, job *meta.Job, opts meta.CreateOptions) (*meta.Job, error)
	Update(ctx context.Context, job *meta.Job, opts meta.UpdateOptions) (*meta.Job, error)
	UpdateStatus(ctx context.Context, job *meta.Job, opts meta.UpdateOptions) (*meta.Job, error)
	Delete(ctx context.Context, name string, opts meta.DeleteOptions) error
	DeleteCollection(ctx context.Context, opts meta.DeleteOptions, listOpts meta.ListOptions) error
	Get(ctx context.Context, name string, opts meta.GetOptions) (*meta.Job, error)
	List(ctx context.Context, opts meta.ListOptions) (*meta.JobList, error)
	Watch(ctx context.Context, opts meta.ListOptions) (watch.Interface, error)
	Patch(ctx context.Context, name string, pt string, data []byte, opts meta.PatchOptions, subresources ...string) (result *meta.Job, err error)

	JobExpansion
}

type StageExpansion

type StageExpansion interface {
	Bind(ctx context.Context, binding *meta.Binding, opts meta.CreateOptions) error
	UpdateStatus(ctx context.Context, stage *meta.Stage, opts meta.UpdateOptions) (*meta.Stage, error)
	UpdateListStatus(ctx context.Context, list *meta.StageList, opts meta.UpdateOptions) (*meta.Status, error)
}

The StageExpansion interface allows manually adding extra methods to the StageInterface.

type StageGetter

type StageGetter interface {
	Stage() StageInterface
}

type StageInterface

type StageInterface interface {
	Create(ctx context.Context, stage *meta.Stage, opts meta.CreateOptions) (*meta.Stage, error)
	Update(ctx context.Context, stage *meta.Stage, opts meta.UpdateOptions) (*meta.Stage, error)
	Delete(ctx context.Context, name string, opts meta.DeleteOptions) error
	DeleteCollection(ctx context.Context, opts meta.DeleteOptions, listOpts meta.ListOptions) error
	Get(ctx context.Context, name string, opts meta.GetOptions) (*meta.Stage, error)
	List(ctx context.Context, opts meta.ListOptions) (*meta.StageList, error)
	Watch(ctx context.Context, opts meta.ListOptions) (watch.Interface, error)
	Patch(ctx context.Context, name string, pt string, data []byte, opts meta.PatchOptions, subresources ...string) (result *meta.Stage, err error)

	StageExpansion
}

type VariableGetter

type VariableGetter interface {
	Variable() VariableInterface
}

type VariableInterface

type VariableInterface interface {
	Create(ctx context.Context, variable *meta.Variable, opts meta.CreateOptions) (*meta.Variable, error)
	Update(ctx context.Context, variable *meta.Variable, opts meta.UpdateOptions) (*meta.Variable, error)
	Delete(ctx context.Context, name string, opts meta.DeleteOptions) error
	DeleteCollection(ctx context.Context, opts meta.DeleteOptions, listOpts meta.ListOptions) error
	Get(ctx context.Context, name string, opts meta.GetOptions) (*meta.Variable, error)
	List(ctx context.Context, opts meta.ListOptions) (*meta.VariableList, error)
	Watch(ctx context.Context, opts meta.ListOptions) (watch.Interface, error)
	Patch(ctx context.Context, name string, pt string, data []byte, opts meta.PatchOptions, subresources ...string) (result *meta.Variable, err error)
}

type WorkerExpansion

type WorkerExpansion interface {
	Bind(ctx context.Context, binding *meta.Binding, opts meta.CreateOptions) error
	Heartbeat(ctx context.Context, worker *meta.Worker, opts meta.UpdateOptions) (*meta.Status, error)
	Register(ctx context.Context, worker *meta.Worker, opts meta.CreateOptions) (*meta.Worker, error)
}

The WorkerExpansion interface allows manually adding extra methods to the WorkerInterface.

type WorkerGetter

type WorkerGetter interface {
	Worker() WorkerInterface
}

type WorkerInterface

type WorkerInterface interface {
	Create(ctx context.Context, worker *meta.Worker, opts meta.CreateOptions) (*meta.Worker, error)
	Update(ctx context.Context, worker *meta.Worker, opts meta.UpdateOptions) (*meta.Worker, error)
	UpdateStatus(ctx context.Context, worker *meta.Worker, opts meta.UpdateOptions) (*meta.Worker, error)
	Delete(ctx context.Context, name string, opts meta.DeleteOptions) error
	DeleteCollection(ctx context.Context, opts meta.DeleteOptions, listOpts meta.ListOptions) error
	Get(ctx context.Context, name string, opts meta.GetOptions) (*meta.Worker, error)
	List(ctx context.Context, opts meta.ListOptions) (*meta.WorkerList, error)
	Watch(ctx context.Context, opts meta.ListOptions) (watch.Interface, error)
	Patch(ctx context.Context, name string, pt string, data []byte, opts meta.PatchOptions, subresources ...string) (result *meta.Worker, err error)

	WorkerExpansion
}

type WorkflowExpansion

type WorkflowExpansion interface {
	Bind(ctx context.Context, binding *meta.Binding, opts meta.CreateOptions) error
	GetDag(ctx context.Context, name string, opts meta.GetOptions) (*meta.Dag, error)
}

The WorkflowExpansion interface allows manually adding extra methods to the WorkflowInterface.

type WorkflowGetter

type WorkflowGetter interface {
	Workflow() WorkflowInterface
}

type WorkflowInterface

type WorkflowInterface interface {
	Create(ctx context.Context, workflow *meta.Workflow, opts meta.CreateOptions) (*meta.Workflow, error)
	Update(ctx context.Context, workflow *meta.Workflow, opts meta.UpdateOptions) (*meta.Workflow, error)
	UpdateStatus(ctx context.Context, workflow *meta.Workflow, opts meta.UpdateOptions) (*meta.Workflow, error)
	Delete(ctx context.Context, name string, opts meta.DeleteOptions) error
	DeleteCollection(ctx context.Context, opts meta.DeleteOptions, listOpts meta.ListOptions) error
	Get(ctx context.Context, name string, opts meta.GetOptions) (*meta.Workflow, error)
	List(ctx context.Context, opts meta.ListOptions) (*meta.WorkflowList, error)
	Watch(ctx context.Context, opts meta.ListOptions) (watch.Interface, error)
	Patch(ctx context.Context, name string, pt string, data []byte, opts meta.PatchOptions, subresources ...string) (result *meta.Workflow, err error)

	WorkflowExpansion
}

Jump to

Keyboard shortcuts

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