Documentation
¶
Index ¶
- type Client
- func (a *Client) CreateCluster(params *CreateClusterParams) (*CreateClusterCreated, error)
- func (a *Client) DeleteSingleCluster(params *DeleteSingleClusterParams) (*DeleteSingleClusterNoContent, error)
- func (a *Client) FindClusters(params *FindClustersParams) (*FindClustersOK, error)
- func (a *Client) FindSingleCluster(params *FindSingleClusterParams) (*FindSingleClusterOK, error)
- func (a *Client) SetTransport(transport runtime.ClientTransport)
- func (a *Client) UpdateSingleCluster(params *UpdateSingleClusterParams) (*UpdateSingleClusterAccepted, error)
- type ClustersItems0
- type CreateClusterCreated
- type CreateClusterDefault
- type CreateClusterParams
- type CreateClusterReader
- type DeleteSingleClusterDefault
- type DeleteSingleClusterNoContent
- type DeleteSingleClusterParams
- type DeleteSingleClusterReader
- type FindClustersDefault
- type FindClustersOK
- type FindClustersOKBodyBody
- type FindClustersParams
- type FindClustersReader
- type FindSingleClusterDefault
- type FindSingleClusterOK
- type FindSingleClusterParams
- type FindSingleClusterReader
- type UpdateSingleClusterAccepted
- type UpdateSingleClusterDefault
- type UpdateSingleClusterParams
- type UpdateSingleClusterReader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client for clusters API
func New ¶
func New(transport runtime.ClientTransport, formats strfmt.Registry) *Client
New creates a new clusters API client.
func (*Client) CreateCluster ¶
func (a *Client) CreateCluster(params *CreateClusterParams) (*CreateClusterCreated, error)
CreateCluster Create a new cluster
func (*Client) DeleteSingleCluster ¶
func (a *Client) DeleteSingleCluster(params *DeleteSingleClusterParams) (*DeleteSingleClusterNoContent, error)
DeleteSingleCluster Delete the specified cluster
func (*Client) FindClusters ¶
func (a *Client) FindClusters(params *FindClustersParams) (*FindClustersOK, error)
FindClusters Returns all clusters that the user is able to access
func (*Client) FindSingleCluster ¶
func (a *Client) FindSingleCluster(params *FindSingleClusterParams) (*FindSingleClusterOK, error)
FindSingleCluster Return detailed information about a single cluster
func (*Client) SetTransport ¶
func (a *Client) SetTransport(transport runtime.ClientTransport)
SetTransport changes the transport on the client
func (*Client) UpdateSingleCluster ¶
func (a *Client) UpdateSingleCluster(params *UpdateSingleClusterParams) (*UpdateSingleClusterAccepted, error)
UpdateSingleCluster Update the specified cluster
type ClustersItems0 ¶
type ClustersItems0 struct {
/* URL for the cluster information page in oshinko-rest
Required: true
*/
Href *string `json:"href"`
/* URL to the spark master
Required: true
*/
MasterURL *string `json:"masterUrl"`
/* URL to the spark master web UI
Required: true
*/
MasterWebURL *string `json:"masterWebUrl"`
/* Name of the cluster
Required: true
*/
Name *string `json:"name"`
/* Current state of the cluster
Required: true
*/
Status *string `json:"status"`
/* Number of worker nodes in the cluster
Required: true
*/
WorkerCount *int64 `json:"workerCount"`
}
ClustersItems0 clusters items0
swagger:model ClustersItems0
type CreateClusterCreated ¶
type CreateClusterCreated struct {
/*URL of the cluster detail page within the oshinko rest server
*/
Location string
Payload *models.SingleCluster
}
CreateClusterCreated handles this case with default header values.
Cluster create response
func NewCreateClusterCreated ¶
func NewCreateClusterCreated() *CreateClusterCreated
NewCreateClusterCreated creates a CreateClusterCreated with default headers values
func (*CreateClusterCreated) Error ¶
func (o *CreateClusterCreated) Error() string
type CreateClusterDefault ¶
type CreateClusterDefault struct {
Payload *models.ErrorResponse
// contains filtered or unexported fields
}
CreateClusterDefault handles this case with default header values.
Unexpected error
func NewCreateClusterDefault ¶
func NewCreateClusterDefault(code int) *CreateClusterDefault
NewCreateClusterDefault creates a CreateClusterDefault with default headers values
func (*CreateClusterDefault) Code ¶
func (o *CreateClusterDefault) Code() int
Code gets the status code for the create cluster default response
func (*CreateClusterDefault) Error ¶
func (o *CreateClusterDefault) Error() string
type CreateClusterParams ¶
type CreateClusterParams struct {
/*Cluster
Cluster to create
*/
Cluster *models.NewCluster
// contains filtered or unexported fields
}
CreateClusterParams contains all the parameters to send to the API endpoint for the create cluster operation typically these are written to a http.Request
func NewCreateClusterParams ¶
func NewCreateClusterParams() *CreateClusterParams
NewCreateClusterParams creates a new CreateClusterParams object with the default values initialized.
func NewCreateClusterParamsWithTimeout ¶
func NewCreateClusterParamsWithTimeout(timeout time.Duration) *CreateClusterParams
NewCreateClusterParamsWithTimeout creates a new CreateClusterParams object with the default values initialized, and the ability to set a timeout on a request
func (*CreateClusterParams) WithCluster ¶
func (o *CreateClusterParams) WithCluster(cluster *models.NewCluster) *CreateClusterParams
WithCluster adds the cluster to the create cluster params
func (*CreateClusterParams) WriteToRequest ¶
func (o *CreateClusterParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type CreateClusterReader ¶
type CreateClusterReader struct {
// contains filtered or unexported fields
}
CreateClusterReader is a Reader for the CreateCluster structure.
func (*CreateClusterReader) ReadResponse ¶
func (o *CreateClusterReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type DeleteSingleClusterDefault ¶
type DeleteSingleClusterDefault struct {
Payload *models.ErrorResponse
// contains filtered or unexported fields
}
DeleteSingleClusterDefault handles this case with default header values.
Unexpected error
func NewDeleteSingleClusterDefault ¶
func NewDeleteSingleClusterDefault(code int) *DeleteSingleClusterDefault
NewDeleteSingleClusterDefault creates a DeleteSingleClusterDefault with default headers values
func (*DeleteSingleClusterDefault) Code ¶
func (o *DeleteSingleClusterDefault) Code() int
Code gets the status code for the delete single cluster default response
func (*DeleteSingleClusterDefault) Error ¶
func (o *DeleteSingleClusterDefault) Error() string
type DeleteSingleClusterNoContent ¶
type DeleteSingleClusterNoContent struct {
}
DeleteSingleClusterNoContent handles this case with default header values.
Cluster deletion response
func NewDeleteSingleClusterNoContent ¶
func NewDeleteSingleClusterNoContent() *DeleteSingleClusterNoContent
NewDeleteSingleClusterNoContent creates a DeleteSingleClusterNoContent with default headers values
func (*DeleteSingleClusterNoContent) Error ¶
func (o *DeleteSingleClusterNoContent) Error() string
type DeleteSingleClusterParams ¶
type DeleteSingleClusterParams struct {
/*Name
Name of the cluster
*/
Name string
// contains filtered or unexported fields
}
DeleteSingleClusterParams contains all the parameters to send to the API endpoint for the delete single cluster operation typically these are written to a http.Request
func NewDeleteSingleClusterParams ¶
func NewDeleteSingleClusterParams() *DeleteSingleClusterParams
NewDeleteSingleClusterParams creates a new DeleteSingleClusterParams object with the default values initialized.
func NewDeleteSingleClusterParamsWithTimeout ¶
func NewDeleteSingleClusterParamsWithTimeout(timeout time.Duration) *DeleteSingleClusterParams
NewDeleteSingleClusterParamsWithTimeout creates a new DeleteSingleClusterParams object with the default values initialized, and the ability to set a timeout on a request
func (*DeleteSingleClusterParams) WithName ¶
func (o *DeleteSingleClusterParams) WithName(name string) *DeleteSingleClusterParams
WithName adds the name to the delete single cluster params
func (*DeleteSingleClusterParams) WriteToRequest ¶
func (o *DeleteSingleClusterParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type DeleteSingleClusterReader ¶
type DeleteSingleClusterReader struct {
// contains filtered or unexported fields
}
DeleteSingleClusterReader is a Reader for the DeleteSingleCluster structure.
func (*DeleteSingleClusterReader) ReadResponse ¶
func (o *DeleteSingleClusterReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type FindClustersDefault ¶
type FindClustersDefault struct {
Payload *models.ErrorResponse
// contains filtered or unexported fields
}
FindClustersDefault handles this case with default header values.
Unexpected error
func NewFindClustersDefault ¶
func NewFindClustersDefault(code int) *FindClustersDefault
NewFindClustersDefault creates a FindClustersDefault with default headers values
func (*FindClustersDefault) Code ¶
func (o *FindClustersDefault) Code() int
Code gets the status code for the find clusters default response
func (*FindClustersDefault) Error ¶
func (o *FindClustersDefault) Error() string
type FindClustersOK ¶
type FindClustersOK struct {
Payload FindClustersOKBodyBody
}
FindClustersOK handles this case with default header values.
Clusters response
func NewFindClustersOK ¶
func NewFindClustersOK() *FindClustersOK
NewFindClustersOK creates a FindClustersOK with default headers values
func (*FindClustersOK) Error ¶
func (o *FindClustersOK) Error() string
type FindClustersOKBodyBody ¶
type FindClustersOKBodyBody struct {
/* clusters
Required: true
*/
Clusters []*ClustersItems0 `json:"clusters"`
}
FindClustersOKBodyBody find clusters o k body body
swagger:model FindClustersOKBodyBody
type FindClustersParams ¶
type FindClustersParams struct {
// contains filtered or unexported fields
}
FindClustersParams contains all the parameters to send to the API endpoint for the find clusters operation typically these are written to a http.Request
func NewFindClustersParams ¶
func NewFindClustersParams() *FindClustersParams
NewFindClustersParams creates a new FindClustersParams object with the default values initialized.
func NewFindClustersParamsWithTimeout ¶
func NewFindClustersParamsWithTimeout(timeout time.Duration) *FindClustersParams
NewFindClustersParamsWithTimeout creates a new FindClustersParams object with the default values initialized, and the ability to set a timeout on a request
func (*FindClustersParams) WriteToRequest ¶
func (o *FindClustersParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type FindClustersReader ¶
type FindClustersReader struct {
// contains filtered or unexported fields
}
FindClustersReader is a Reader for the FindClusters structure.
func (*FindClustersReader) ReadResponse ¶
func (o *FindClustersReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type FindSingleClusterDefault ¶
type FindSingleClusterDefault struct {
Payload *models.ErrorResponse
// contains filtered or unexported fields
}
FindSingleClusterDefault handles this case with default header values.
Unexpected error
func NewFindSingleClusterDefault ¶
func NewFindSingleClusterDefault(code int) *FindSingleClusterDefault
NewFindSingleClusterDefault creates a FindSingleClusterDefault with default headers values
func (*FindSingleClusterDefault) Code ¶
func (o *FindSingleClusterDefault) Code() int
Code gets the status code for the find single cluster default response
func (*FindSingleClusterDefault) Error ¶
func (o *FindSingleClusterDefault) Error() string
type FindSingleClusterOK ¶
type FindSingleClusterOK struct {
Payload *models.SingleCluster
}
FindSingleClusterOK handles this case with default header values.
Cluster detail response
func NewFindSingleClusterOK ¶
func NewFindSingleClusterOK() *FindSingleClusterOK
NewFindSingleClusterOK creates a FindSingleClusterOK with default headers values
func (*FindSingleClusterOK) Error ¶
func (o *FindSingleClusterOK) Error() string
type FindSingleClusterParams ¶
type FindSingleClusterParams struct {
/*Name
Name of the cluster
*/
Name string
// contains filtered or unexported fields
}
FindSingleClusterParams contains all the parameters to send to the API endpoint for the find single cluster operation typically these are written to a http.Request
func NewFindSingleClusterParams ¶
func NewFindSingleClusterParams() *FindSingleClusterParams
NewFindSingleClusterParams creates a new FindSingleClusterParams object with the default values initialized.
func NewFindSingleClusterParamsWithTimeout ¶
func NewFindSingleClusterParamsWithTimeout(timeout time.Duration) *FindSingleClusterParams
NewFindSingleClusterParamsWithTimeout creates a new FindSingleClusterParams object with the default values initialized, and the ability to set a timeout on a request
func (*FindSingleClusterParams) WithName ¶
func (o *FindSingleClusterParams) WithName(name string) *FindSingleClusterParams
WithName adds the name to the find single cluster params
func (*FindSingleClusterParams) WriteToRequest ¶
func (o *FindSingleClusterParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type FindSingleClusterReader ¶
type FindSingleClusterReader struct {
// contains filtered or unexported fields
}
FindSingleClusterReader is a Reader for the FindSingleCluster structure.
func (*FindSingleClusterReader) ReadResponse ¶
func (o *FindSingleClusterReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
type UpdateSingleClusterAccepted ¶
type UpdateSingleClusterAccepted struct {
Payload *models.SingleCluster
}
UpdateSingleClusterAccepted handles this case with default header values.
Cluster update response
func NewUpdateSingleClusterAccepted ¶
func NewUpdateSingleClusterAccepted() *UpdateSingleClusterAccepted
NewUpdateSingleClusterAccepted creates a UpdateSingleClusterAccepted with default headers values
func (*UpdateSingleClusterAccepted) Error ¶
func (o *UpdateSingleClusterAccepted) Error() string
type UpdateSingleClusterDefault ¶
type UpdateSingleClusterDefault struct {
Payload *models.ErrorResponse
// contains filtered or unexported fields
}
UpdateSingleClusterDefault handles this case with default header values.
Unexpected error
func NewUpdateSingleClusterDefault ¶
func NewUpdateSingleClusterDefault(code int) *UpdateSingleClusterDefault
NewUpdateSingleClusterDefault creates a UpdateSingleClusterDefault with default headers values
func (*UpdateSingleClusterDefault) Code ¶
func (o *UpdateSingleClusterDefault) Code() int
Code gets the status code for the update single cluster default response
func (*UpdateSingleClusterDefault) Error ¶
func (o *UpdateSingleClusterDefault) Error() string
type UpdateSingleClusterParams ¶
type UpdateSingleClusterParams struct {
/*Cluster
Requested cluster update
*/
Cluster *models.NewCluster
/*Name
Name of the cluster
*/
Name string
// contains filtered or unexported fields
}
UpdateSingleClusterParams contains all the parameters to send to the API endpoint for the update single cluster operation typically these are written to a http.Request
func NewUpdateSingleClusterParams ¶
func NewUpdateSingleClusterParams() *UpdateSingleClusterParams
NewUpdateSingleClusterParams creates a new UpdateSingleClusterParams object with the default values initialized.
func NewUpdateSingleClusterParamsWithTimeout ¶
func NewUpdateSingleClusterParamsWithTimeout(timeout time.Duration) *UpdateSingleClusterParams
NewUpdateSingleClusterParamsWithTimeout creates a new UpdateSingleClusterParams object with the default values initialized, and the ability to set a timeout on a request
func (*UpdateSingleClusterParams) WithCluster ¶
func (o *UpdateSingleClusterParams) WithCluster(cluster *models.NewCluster) *UpdateSingleClusterParams
WithCluster adds the cluster to the update single cluster params
func (*UpdateSingleClusterParams) WithName ¶
func (o *UpdateSingleClusterParams) WithName(name string) *UpdateSingleClusterParams
WithName adds the name to the update single cluster params
func (*UpdateSingleClusterParams) WriteToRequest ¶
func (o *UpdateSingleClusterParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error
WriteToRequest writes these params to a swagger request
type UpdateSingleClusterReader ¶
type UpdateSingleClusterReader struct {
// contains filtered or unexported fields
}
UpdateSingleClusterReader is a Reader for the UpdateSingleCluster structure.
func (*UpdateSingleClusterReader) ReadResponse ¶
func (o *UpdateSingleClusterReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)
ReadResponse reads a server response into the received o.
Source Files
¶
- clusters_client.go
- create_cluster_parameters.go
- create_cluster_responses.go
- delete_single_cluster_parameters.go
- delete_single_cluster_responses.go
- find_clusters_parameters.go
- find_clusters_responses.go
- find_single_cluster_parameters.go
- find_single_cluster_responses.go
- update_single_cluster_parameters.go
- update_single_cluster_responses.go