default_operations

package
v0.0.0-...-92dc8bc Latest Latest
Warning

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

 Go to latest Published: Jun 23, 2021 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BusyOK 

type BusyOK struct {
	Payload []*models.Execution
}
BusyOK describes a response with status code 200, with default header values.

Successful response

func NewBusyOK 

func NewBusyOK() *BusyOK

NewBusyOK creates a BusyOK with default headers values

func (*BusyOK) Error 

func (o *BusyOK) Error() string

func (*BusyOK) GetPayload 

func (o *BusyOK) GetPayload() []*models.Execution

type BusyParams 

type BusyParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

BusyParams contains all the parameters to send to the API endpoint 

for the busy operation.

Typically these are written to a http.Request.

func NewBusyParams 

func NewBusyParams() *BusyParams

NewBusyParams creates a new BusyParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewBusyParamsWithContext 

func NewBusyParamsWithContext(ctx context.Context) *BusyParams

NewBusyParamsWithContext creates a new BusyParams object with the ability to set a context for a request.

func NewBusyParamsWithHTTPClient 

func NewBusyParamsWithHTTPClient(client *http.Client) *BusyParams

NewBusyParamsWithHTTPClient creates a new BusyParams object with the ability to set a custom HTTPClient for a request.

func NewBusyParamsWithTimeout 

func NewBusyParamsWithTimeout(timeout time.Duration) *BusyParams

NewBusyParamsWithTimeout creates a new BusyParams object with the ability to set a timeout on a request.

func (*BusyParams) SetContext 

func (o *BusyParams) SetContext(ctx context.Context)

SetContext adds the context to the busy params

func (*BusyParams) SetDefaults 

func (o *BusyParams) SetDefaults()

SetDefaults hydrates default values in the busy params (not the query body).

All values with no default are reset to their zero value.

func (*BusyParams) SetHTTPClient 

func (o *BusyParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the busy params

func (*BusyParams) SetTimeout 

func (o *BusyParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the busy params

func (*BusyParams) WithContext 

func (o *BusyParams) WithContext(ctx context.Context) *BusyParams

WithContext adds the context to the busy params

func (*BusyParams) WithDefaults 

func (o *BusyParams) WithDefaults() *BusyParams

WithDefaults hydrates default values in the busy params (not the query body).

All values with no default are reset to their zero value.

func (*BusyParams) WithHTTPClient 

func (o *BusyParams) WithHTTPClient(client *http.Client) *BusyParams

WithHTTPClient adds the HTTPClient to the busy params

func (*BusyParams) WithTimeout 

func (o *BusyParams) WithTimeout(timeout time.Duration) *BusyParams

WithTimeout adds the timeout to the busy params

func (*BusyParams) WriteToRequest 

func (o *BusyParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type BusyReader 

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

BusyReader is a Reader for the Busy structure.

func (*BusyReader) ReadResponse 

func (o *BusyReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type Client 

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

Client for default operations API

func (*Client) Busy 

func (a *Client) Busy(params *BusyParams, opts ...ClientOption) (*BusyOK, error)

Busy Returns the running executions.

func (*Client) GetIsLeader 

func (a *Client) GetIsLeader(params *GetIsLeaderParams, opts ...ClientOption) (*GetIsLeaderOK, error)

GetIsLeader Check if node is a leader or follower.

func (*Client) GetLeader 

func (a *Client) GetLeader(params *GetLeaderParams, opts ...ClientOption) (*GetLeaderOK, error)

GetLeader List leader of cluster.

func (*Client) Leave 

func (a *Client) Leave(params *LeaveParams, opts ...ClientOption) (*LeaveOK, error)

Leave Force the node to leave the cluster.

func (*Client) SetTransport 

func (a *Client) SetTransport(transport runtime.ClientTransport)

SetTransport changes the transport on the client

func (*Client) Status 

func (a *Client) Status(params *StatusParams, opts ...ClientOption) (*StatusOK, error)

Status Gets `Status` object.

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	Busy(params *BusyParams, opts ...ClientOption) (*BusyOK, error)

	GetIsLeader(params *GetIsLeaderParams, opts ...ClientOption) (*GetIsLeaderOK, error)

	GetLeader(params *GetLeaderParams, opts ...ClientOption) (*GetLeaderOK, error)

	Leave(params *LeaveParams, opts ...ClientOption) (*LeaveOK, error)

	Status(params *StatusParams, opts ...ClientOption) (*StatusOK, error)

	SetTransport(transport runtime.ClientTransport)
}

ClientService is the interface for Client methods

func New 

func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService

New creates a new default operations API client.

type GetIsLeaderNotFound 

type GetIsLeaderNotFound struct {
}
GetIsLeaderNotFound describes a response with status code 404, with default header values.

Node is a follower

func NewGetIsLeaderNotFound 

func NewGetIsLeaderNotFound() *GetIsLeaderNotFound

NewGetIsLeaderNotFound creates a GetIsLeaderNotFound with default headers values

func (*GetIsLeaderNotFound) Error 

func (o *GetIsLeaderNotFound) Error() string

type GetIsLeaderOK 

type GetIsLeaderOK struct {
}
GetIsLeaderOK describes a response with status code 200, with default header values.

Node is a leader

func NewGetIsLeaderOK 

func NewGetIsLeaderOK() *GetIsLeaderOK

NewGetIsLeaderOK creates a GetIsLeaderOK with default headers values

func (*GetIsLeaderOK) Error 

func (o *GetIsLeaderOK) Error() string

type GetIsLeaderParams 

type GetIsLeaderParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetIsLeaderParams contains all the parameters to send to the API endpoint 

for the get is leader operation.

Typically these are written to a http.Request.

func NewGetIsLeaderParams 

func NewGetIsLeaderParams() *GetIsLeaderParams

NewGetIsLeaderParams creates a new GetIsLeaderParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewGetIsLeaderParamsWithContext 

func NewGetIsLeaderParamsWithContext(ctx context.Context) *GetIsLeaderParams

NewGetIsLeaderParamsWithContext creates a new GetIsLeaderParams object with the ability to set a context for a request.

func NewGetIsLeaderParamsWithHTTPClient 

func NewGetIsLeaderParamsWithHTTPClient(client *http.Client) *GetIsLeaderParams

NewGetIsLeaderParamsWithHTTPClient creates a new GetIsLeaderParams object with the ability to set a custom HTTPClient for a request.

func NewGetIsLeaderParamsWithTimeout 

func NewGetIsLeaderParamsWithTimeout(timeout time.Duration) *GetIsLeaderParams

NewGetIsLeaderParamsWithTimeout creates a new GetIsLeaderParams object with the ability to set a timeout on a request.

func (*GetIsLeaderParams) SetContext 

func (o *GetIsLeaderParams) SetContext(ctx context.Context)

SetContext adds the context to the get is leader params

func (*GetIsLeaderParams) SetDefaults 

func (o *GetIsLeaderParams) SetDefaults()

SetDefaults hydrates default values in the get is leader params (not the query body).

All values with no default are reset to their zero value.

func (*GetIsLeaderParams) SetHTTPClient 

func (o *GetIsLeaderParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get is leader params

func (*GetIsLeaderParams) SetTimeout 

func (o *GetIsLeaderParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get is leader params

func (*GetIsLeaderParams) WithContext 

func (o *GetIsLeaderParams) WithContext(ctx context.Context) *GetIsLeaderParams

WithContext adds the context to the get is leader params

func (*GetIsLeaderParams) WithDefaults 

func (o *GetIsLeaderParams) WithDefaults() *GetIsLeaderParams

WithDefaults hydrates default values in the get is leader params (not the query body).

All values with no default are reset to their zero value.

func (*GetIsLeaderParams) WithHTTPClient 

func (o *GetIsLeaderParams) WithHTTPClient(client *http.Client) *GetIsLeaderParams

WithHTTPClient adds the HTTPClient to the get is leader params

func (*GetIsLeaderParams) WithTimeout 

func (o *GetIsLeaderParams) WithTimeout(timeout time.Duration) *GetIsLeaderParams

WithTimeout adds the timeout to the get is leader params

func (*GetIsLeaderParams) WriteToRequest 

func (o *GetIsLeaderParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetIsLeaderReader 

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

GetIsLeaderReader is a Reader for the GetIsLeader structure.

func (*GetIsLeaderReader) ReadResponse 

func (o *GetIsLeaderReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type GetLeaderOK 

type GetLeaderOK struct {
	Payload *models.Member
}
GetLeaderOK describes a response with status code 200, with default header values.

Successful response

func NewGetLeaderOK 

func NewGetLeaderOK() *GetLeaderOK

NewGetLeaderOK creates a GetLeaderOK with default headers values

func (*GetLeaderOK) Error 

func (o *GetLeaderOK) Error() string

func (*GetLeaderOK) GetPayload 

func (o *GetLeaderOK) GetPayload() *models.Member

type GetLeaderParams 

type GetLeaderParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

GetLeaderParams contains all the parameters to send to the API endpoint 

for the get leader operation.

Typically these are written to a http.Request.

func NewGetLeaderParams 

func NewGetLeaderParams() *GetLeaderParams

NewGetLeaderParams creates a new GetLeaderParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewGetLeaderParamsWithContext 

func NewGetLeaderParamsWithContext(ctx context.Context) *GetLeaderParams

NewGetLeaderParamsWithContext creates a new GetLeaderParams object with the ability to set a context for a request.

func NewGetLeaderParamsWithHTTPClient 

func NewGetLeaderParamsWithHTTPClient(client *http.Client) *GetLeaderParams

NewGetLeaderParamsWithHTTPClient creates a new GetLeaderParams object with the ability to set a custom HTTPClient for a request.

func NewGetLeaderParamsWithTimeout 

func NewGetLeaderParamsWithTimeout(timeout time.Duration) *GetLeaderParams

NewGetLeaderParamsWithTimeout creates a new GetLeaderParams object with the ability to set a timeout on a request.

func (*GetLeaderParams) SetContext 

func (o *GetLeaderParams) SetContext(ctx context.Context)

SetContext adds the context to the get leader params

func (*GetLeaderParams) SetDefaults 

func (o *GetLeaderParams) SetDefaults()

SetDefaults hydrates default values in the get leader params (not the query body).

All values with no default are reset to their zero value.

func (*GetLeaderParams) SetHTTPClient 

func (o *GetLeaderParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the get leader params

func (*GetLeaderParams) SetTimeout 

func (o *GetLeaderParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the get leader params

func (*GetLeaderParams) WithContext 

func (o *GetLeaderParams) WithContext(ctx context.Context) *GetLeaderParams

WithContext adds the context to the get leader params

func (*GetLeaderParams) WithDefaults 

func (o *GetLeaderParams) WithDefaults() *GetLeaderParams

WithDefaults hydrates default values in the get leader params (not the query body).

All values with no default are reset to their zero value.

func (*GetLeaderParams) WithHTTPClient 

func (o *GetLeaderParams) WithHTTPClient(client *http.Client) *GetLeaderParams

WithHTTPClient adds the HTTPClient to the get leader params

func (*GetLeaderParams) WithTimeout 

func (o *GetLeaderParams) WithTimeout(timeout time.Duration) *GetLeaderParams

WithTimeout adds the timeout to the get leader params

func (*GetLeaderParams) WriteToRequest 

func (o *GetLeaderParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type GetLeaderReader 

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

GetLeaderReader is a Reader for the GetLeader structure.

func (*GetLeaderReader) ReadResponse 

func (o *GetLeaderReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type LeaveOK 

type LeaveOK struct {
	Payload []*models.Member
}
LeaveOK describes a response with status code 200, with default header values.

Successful response

func NewLeaveOK 

func NewLeaveOK() *LeaveOK

NewLeaveOK creates a LeaveOK with default headers values

func (*LeaveOK) Error 

func (o *LeaveOK) Error() string

func (*LeaveOK) GetPayload 

func (o *LeaveOK) GetPayload() []*models.Member

type LeaveParams 

type LeaveParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

LeaveParams contains all the parameters to send to the API endpoint 

for the leave operation.

Typically these are written to a http.Request.

func NewLeaveParams 

func NewLeaveParams() *LeaveParams

NewLeaveParams creates a new LeaveParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewLeaveParamsWithContext 

func NewLeaveParamsWithContext(ctx context.Context) *LeaveParams

NewLeaveParamsWithContext creates a new LeaveParams object with the ability to set a context for a request.

func NewLeaveParamsWithHTTPClient 

func NewLeaveParamsWithHTTPClient(client *http.Client) *LeaveParams

NewLeaveParamsWithHTTPClient creates a new LeaveParams object with the ability to set a custom HTTPClient for a request.

func NewLeaveParamsWithTimeout 

func NewLeaveParamsWithTimeout(timeout time.Duration) *LeaveParams

NewLeaveParamsWithTimeout creates a new LeaveParams object with the ability to set a timeout on a request.

func (*LeaveParams) SetContext 

func (o *LeaveParams) SetContext(ctx context.Context)

SetContext adds the context to the leave params

func (*LeaveParams) SetDefaults 

func (o *LeaveParams) SetDefaults()

SetDefaults hydrates default values in the leave params (not the query body).

All values with no default are reset to their zero value.

func (*LeaveParams) SetHTTPClient 

func (o *LeaveParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the leave params

func (*LeaveParams) SetTimeout 

func (o *LeaveParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the leave params

func (*LeaveParams) WithContext 

func (o *LeaveParams) WithContext(ctx context.Context) *LeaveParams

WithContext adds the context to the leave params

func (*LeaveParams) WithDefaults 

func (o *LeaveParams) WithDefaults() *LeaveParams

WithDefaults hydrates default values in the leave params (not the query body).

All values with no default are reset to their zero value.

func (*LeaveParams) WithHTTPClient 

func (o *LeaveParams) WithHTTPClient(client *http.Client) *LeaveParams

WithHTTPClient adds the HTTPClient to the leave params

func (*LeaveParams) WithTimeout 

func (o *LeaveParams) WithTimeout(timeout time.Duration) *LeaveParams

WithTimeout adds the timeout to the leave params

func (*LeaveParams) WriteToRequest 

func (o *LeaveParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type LeaveReader 

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

LeaveReader is a Reader for the Leave structure.

func (*LeaveReader) ReadResponse 

func (o *LeaveReader) ReadResponse(response runtime.ClientResponse, consumer runtime.Consumer) (interface{}, error)

ReadResponse reads a server response into the received o.

type StatusOK 

type StatusOK struct {
	Payload *models.Status
}
StatusOK describes a response with status code 200, with default header values.

Successful response

func NewStatusOK 

func NewStatusOK() *StatusOK

NewStatusOK creates a StatusOK with default headers values

func (*StatusOK) Error 

func (o *StatusOK) Error() string

func (*StatusOK) GetPayload 

func (o *StatusOK) GetPayload() *models.Status

type StatusParams 

type StatusParams struct {
	Context    context.Context
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

StatusParams contains all the parameters to send to the API endpoint 

for the status operation.

Typically these are written to a http.Request.

func NewStatusParams 

func NewStatusParams() *StatusParams

NewStatusParams creates a new StatusParams object, with the default timeout for this client.

Default values are not hydrated, since defaults are normally applied by the API server side.

To enforce default values in parameter, use SetDefaults or WithDefaults.

func NewStatusParamsWithContext 

func NewStatusParamsWithContext(ctx context.Context) *StatusParams

NewStatusParamsWithContext creates a new StatusParams object with the ability to set a context for a request.

func NewStatusParamsWithHTTPClient 

func NewStatusParamsWithHTTPClient(client *http.Client) *StatusParams

NewStatusParamsWithHTTPClient creates a new StatusParams object with the ability to set a custom HTTPClient for a request.

func NewStatusParamsWithTimeout 

func NewStatusParamsWithTimeout(timeout time.Duration) *StatusParams

NewStatusParamsWithTimeout creates a new StatusParams object with the ability to set a timeout on a request.

func (*StatusParams) SetContext 

func (o *StatusParams) SetContext(ctx context.Context)

SetContext adds the context to the status params

func (*StatusParams) SetDefaults 

func (o *StatusParams) SetDefaults()

SetDefaults hydrates default values in the status params (not the query body).

All values with no default are reset to their zero value.

func (*StatusParams) SetHTTPClient 

func (o *StatusParams) SetHTTPClient(client *http.Client)

SetHTTPClient adds the HTTPClient to the status params

func (*StatusParams) SetTimeout 

func (o *StatusParams) SetTimeout(timeout time.Duration)

SetTimeout adds the timeout to the status params

func (*StatusParams) WithContext 

func (o *StatusParams) WithContext(ctx context.Context) *StatusParams

WithContext adds the context to the status params

func (*StatusParams) WithDefaults 

func (o *StatusParams) WithDefaults() *StatusParams

WithDefaults hydrates default values in the status params (not the query body).

All values with no default are reset to their zero value.

func (*StatusParams) WithHTTPClient 

func (o *StatusParams) WithHTTPClient(client *http.Client) *StatusParams

WithHTTPClient adds the HTTPClient to the status params

func (*StatusParams) WithTimeout 

func (o *StatusParams) WithTimeout(timeout time.Duration) *StatusParams

WithTimeout adds the timeout to the status params

func (*StatusParams) WriteToRequest 

func (o *StatusParams) WriteToRequest(r runtime.ClientRequest, reg strfmt.Registry) error

WriteToRequest writes these params to a swagger request

type StatusReader 

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

StatusReader is a Reader for the Status structure.

func (*StatusReader) ReadResponse 

func (o *StatusReader) 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.