Documentation
¶
Index ¶
- Variables
- func Resource(resource string) schema.GroupResource
- type CodeGetter
- type CodeInterface
- type ConnectionGetter
- type ConnectionInterface
- type CoreV1Client
- func (c *CoreV1Client) Code() CodeInterface
- func (c *CoreV1Client) Connection() ConnectionInterface
- func (c *CoreV1Client) Job() JobInterface
- func (c *CoreV1Client) RESTClient() rest.Interface
- func (c *CoreV1Client) Stage() StageInterface
- func (c *CoreV1Client) Variable() VariableInterface
- func (c *CoreV1Client) Worker() WorkerInterface
- func (c *CoreV1Client) Workflow() WorkflowInterface
- type CoreV1Interface
- type JobExpansion
- type JobGetter
- type JobInterface
- type StageExpansion
- type StageGetter
- type StageInterface
- type VariableGetter
- type VariableInterface
- type WorkerExpansion
- type WorkerGetter
- type WorkerInterface
- type WorkflowExpansion
- type WorkflowGetter
- type WorkflowInterface
Constants ¶
This section is empty.
Variables ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme )
var Scheme = runtime.NewScheme()
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 NewForConfigAndClient ¶
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 CoreV1Interface ¶
type CoreV1Interface interface { RESTClient() rest.Interface WorkflowGetter JobGetter WorkerGetter StageGetter CodeGetter VariableGetter ConnectionGetter }
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 }