clusters

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

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

func (*ClustersItems0) Validate 

func (o *ClustersItems0) Validate(formats strfmt.Registry) error

Validate validates this clusters items0

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

func (*FindClustersOKBodyBody) Validate 

func (o *FindClustersOKBodyBody) Validate(formats strfmt.Registry) error

Validate validates this find clusters o k body body

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.