connectivity

package
v1.16.0-rc.2 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2024 License: Apache-2.0 Imports: 10 Imported by: 6

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 connectivity API

func (*Client) GetStatus 

func (a *Client) GetStatus(params *GetStatusParams, opts ...ClientOption) (*GetStatusOK, error)
GetStatus gets connectivity status of the cilium cluster

Returns the connectivity status to all other cilium-health instances

using interval-based probing.

func (*Client) PutStatusProbe 

func (a *Client) PutStatusProbe(params *PutStatusProbeParams, opts ...ClientOption) (*PutStatusProbeOK, error)
PutStatusProbe runs synchronous connectivity probe to determine status of the cilium cluster

Runs a synchronous probe to all other cilium-health instances and

returns the connectivity status.

func (*Client) SetTransport 

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

SetTransport changes the transport on the client

type ClientOption 

type ClientOption func(*runtime.ClientOperation)

ClientOption is the option for Client methods

type ClientService 

type ClientService interface {
	GetStatus(params *GetStatusParams, opts ...ClientOption) (*GetStatusOK, error)

	PutStatusProbe(params *PutStatusProbeParams, opts ...ClientOption) (*PutStatusProbeOK, 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 connectivity API client.

type GetStatusOK 

type GetStatusOK struct {
	Payload *models.HealthStatusResponse
}

GetStatusOK describes a response with status code 200, with default header values.

Success

func NewGetStatusOK 

func NewGetStatusOK() *GetStatusOK

NewGetStatusOK creates a GetStatusOK with default headers values

func (*GetStatusOK) Code added in v1.16.0 

func (o *GetStatusOK) Code() int

Code gets the status code for the get status o k response

func (*GetStatusOK) Error 

func (o *GetStatusOK) Error() string

func (*GetStatusOK) GetPayload 

func (o *GetStatusOK) GetPayload() *models.HealthStatusResponse

func (*GetStatusOK) IsClientError 

func (o *GetStatusOK) IsClientError() bool

IsClientError returns true when this get status o k response has a 4xx status code

func (*GetStatusOK) IsCode 

func (o *GetStatusOK) IsCode(code int) bool

IsCode returns true when this get status o k response a status code equal to that given

func (*GetStatusOK) IsRedirect 

func (o *GetStatusOK) IsRedirect() bool

IsRedirect returns true when this get status o k response has a 3xx status code

func (*GetStatusOK) IsServerError 

func (o *GetStatusOK) IsServerError() bool

IsServerError returns true when this get status o k response has a 5xx status code

func (*GetStatusOK) IsSuccess 

func (o *GetStatusOK) IsSuccess() bool

IsSuccess returns true when this get status o k response has a 2xx status code

func (*GetStatusOK) String 

func (o *GetStatusOK) String() string

type GetStatusParams 

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

GetStatusParams contains all the parameters to send to the API endpoint 

for the get status operation.

Typically these are written to a http.Request.

func NewGetStatusParams 

func NewGetStatusParams() *GetStatusParams

NewGetStatusParams creates a new GetStatusParams 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 NewGetStatusParamsWithContext 

func NewGetStatusParamsWithContext(ctx context.Context) *GetStatusParams

NewGetStatusParamsWithContext creates a new GetStatusParams object with the ability to set a context for a request.

func NewGetStatusParamsWithHTTPClient 

func NewGetStatusParamsWithHTTPClient(client *http.Client) *GetStatusParams

NewGetStatusParamsWithHTTPClient creates a new GetStatusParams object with the ability to set a custom HTTPClient for a request.

func NewGetStatusParamsWithTimeout 

func NewGetStatusParamsWithTimeout(timeout time.Duration) *GetStatusParams

NewGetStatusParamsWithTimeout creates a new GetStatusParams object with the ability to set a timeout on a request.

func (*GetStatusParams) SetContext 

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

SetContext adds the context to the get status params

func (*GetStatusParams) SetDefaults 

func (o *GetStatusParams) SetDefaults()

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

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

func (*GetStatusParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the get status params

func (*GetStatusParams) SetTimeout 

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

SetTimeout adds the timeout to the get status params

func (*GetStatusParams) WithContext 

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

WithContext adds the context to the get status params

func (*GetStatusParams) WithDefaults 

func (o *GetStatusParams) WithDefaults() *GetStatusParams

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

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

func (*GetStatusParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the get status params

func (*GetStatusParams) WithTimeout 

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

WithTimeout adds the timeout to the get status params

func (*GetStatusParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type GetStatusReader 

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

GetStatusReader is a Reader for the GetStatus structure.

func (*GetStatusReader) ReadResponse 

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

ReadResponse reads a server response into the received o.

type PutStatusProbeFailed 

type PutStatusProbeFailed struct {
	Payload models.Error
}

PutStatusProbeFailed describes a response with status code 500, with default header values.

Internal error occurred while conducting connectivity probe

func NewPutStatusProbeFailed 

func NewPutStatusProbeFailed() *PutStatusProbeFailed

NewPutStatusProbeFailed creates a PutStatusProbeFailed with default headers values

func (*PutStatusProbeFailed) Code added in v1.16.0 

func (o *PutStatusProbeFailed) Code() int

Code gets the status code for the put status probe failed response

func (*PutStatusProbeFailed) Error 

func (o *PutStatusProbeFailed) Error() string

func (*PutStatusProbeFailed) GetPayload 

func (o *PutStatusProbeFailed) GetPayload() models.Error

func (*PutStatusProbeFailed) IsClientError 

func (o *PutStatusProbeFailed) IsClientError() bool

IsClientError returns true when this put status probe failed response has a 4xx status code

func (*PutStatusProbeFailed) IsCode 

func (o *PutStatusProbeFailed) IsCode(code int) bool

IsCode returns true when this put status probe failed response a status code equal to that given

func (*PutStatusProbeFailed) IsRedirect 

func (o *PutStatusProbeFailed) IsRedirect() bool

IsRedirect returns true when this put status probe failed response has a 3xx status code

func (*PutStatusProbeFailed) IsServerError 

func (o *PutStatusProbeFailed) IsServerError() bool

IsServerError returns true when this put status probe failed response has a 5xx status code

func (*PutStatusProbeFailed) IsSuccess 

func (o *PutStatusProbeFailed) IsSuccess() bool

IsSuccess returns true when this put status probe failed response has a 2xx status code

func (*PutStatusProbeFailed) String 

func (o *PutStatusProbeFailed) String() string

type PutStatusProbeForbidden 

type PutStatusProbeForbidden struct {
}

PutStatusProbeForbidden describes a response with status code 403, with default header values.

Forbidden

func NewPutStatusProbeForbidden 

func NewPutStatusProbeForbidden() *PutStatusProbeForbidden

NewPutStatusProbeForbidden creates a PutStatusProbeForbidden with default headers values

func (*PutStatusProbeForbidden) Code added in v1.16.0 

func (o *PutStatusProbeForbidden) Code() int

Code gets the status code for the put status probe forbidden response

func (*PutStatusProbeForbidden) Error 

func (o *PutStatusProbeForbidden) Error() string

func (*PutStatusProbeForbidden) IsClientError 

func (o *PutStatusProbeForbidden) IsClientError() bool

IsClientError returns true when this put status probe forbidden response has a 4xx status code

func (*PutStatusProbeForbidden) IsCode 

func (o *PutStatusProbeForbidden) IsCode(code int) bool

IsCode returns true when this put status probe forbidden response a status code equal to that given

func (*PutStatusProbeForbidden) IsRedirect 

func (o *PutStatusProbeForbidden) IsRedirect() bool

IsRedirect returns true when this put status probe forbidden response has a 3xx status code

func (*PutStatusProbeForbidden) IsServerError 

func (o *PutStatusProbeForbidden) IsServerError() bool

IsServerError returns true when this put status probe forbidden response has a 5xx status code

func (*PutStatusProbeForbidden) IsSuccess 

func (o *PutStatusProbeForbidden) IsSuccess() bool

IsSuccess returns true when this put status probe forbidden response has a 2xx status code

func (*PutStatusProbeForbidden) String 

func (o *PutStatusProbeForbidden) String() string

type PutStatusProbeOK 

type PutStatusProbeOK struct {
	Payload *models.HealthStatusResponse
}

PutStatusProbeOK describes a response with status code 200, with default header values.

Success

func NewPutStatusProbeOK 

func NewPutStatusProbeOK() *PutStatusProbeOK

NewPutStatusProbeOK creates a PutStatusProbeOK with default headers values

func (*PutStatusProbeOK) Code added in v1.16.0 

func (o *PutStatusProbeOK) Code() int

Code gets the status code for the put status probe o k response

func (*PutStatusProbeOK) Error 

func (o *PutStatusProbeOK) Error() string

func (*PutStatusProbeOK) GetPayload 

func (o *PutStatusProbeOK) GetPayload() *models.HealthStatusResponse

func (*PutStatusProbeOK) IsClientError 

func (o *PutStatusProbeOK) IsClientError() bool

IsClientError returns true when this put status probe o k response has a 4xx status code

func (*PutStatusProbeOK) IsCode 

func (o *PutStatusProbeOK) IsCode(code int) bool

IsCode returns true when this put status probe o k response a status code equal to that given

func (*PutStatusProbeOK) IsRedirect 

func (o *PutStatusProbeOK) IsRedirect() bool

IsRedirect returns true when this put status probe o k response has a 3xx status code

func (*PutStatusProbeOK) IsServerError 

func (o *PutStatusProbeOK) IsServerError() bool

IsServerError returns true when this put status probe o k response has a 5xx status code

func (*PutStatusProbeOK) IsSuccess 

func (o *PutStatusProbeOK) IsSuccess() bool

IsSuccess returns true when this put status probe o k response has a 2xx status code

func (*PutStatusProbeOK) String 

func (o *PutStatusProbeOK) String() string

type PutStatusProbeParams 

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

PutStatusProbeParams contains all the parameters to send to the API endpoint 

for the put status probe operation.

Typically these are written to a http.Request.

func NewPutStatusProbeParams 

func NewPutStatusProbeParams() *PutStatusProbeParams

NewPutStatusProbeParams creates a new PutStatusProbeParams 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 NewPutStatusProbeParamsWithContext 

func NewPutStatusProbeParamsWithContext(ctx context.Context) *PutStatusProbeParams

NewPutStatusProbeParamsWithContext creates a new PutStatusProbeParams object with the ability to set a context for a request.

func NewPutStatusProbeParamsWithHTTPClient 

func NewPutStatusProbeParamsWithHTTPClient(client *http.Client) *PutStatusProbeParams

NewPutStatusProbeParamsWithHTTPClient creates a new PutStatusProbeParams object with the ability to set a custom HTTPClient for a request.

func NewPutStatusProbeParamsWithTimeout 

func NewPutStatusProbeParamsWithTimeout(timeout time.Duration) *PutStatusProbeParams

NewPutStatusProbeParamsWithTimeout creates a new PutStatusProbeParams object with the ability to set a timeout on a request.

func (*PutStatusProbeParams) SetContext 

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

SetContext adds the context to the put status probe params

func (*PutStatusProbeParams) SetDefaults 

func (o *PutStatusProbeParams) SetDefaults()

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

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

func (*PutStatusProbeParams) SetHTTPClient 

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

SetHTTPClient adds the HTTPClient to the put status probe params

func (*PutStatusProbeParams) SetTimeout 

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

SetTimeout adds the timeout to the put status probe params

func (*PutStatusProbeParams) WithContext 

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

WithContext adds the context to the put status probe params

func (*PutStatusProbeParams) WithDefaults 

func (o *PutStatusProbeParams) WithDefaults() *PutStatusProbeParams

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

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

func (*PutStatusProbeParams) WithHTTPClient 

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

WithHTTPClient adds the HTTPClient to the put status probe params

func (*PutStatusProbeParams) WithTimeout 

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

WithTimeout adds the timeout to the put status probe params

func (*PutStatusProbeParams) WriteToRequest 

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

WriteToRequest writes these params to a swagger request

type PutStatusProbeReader 

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

PutStatusProbeReader is a Reader for the PutStatusProbe structure.

func (*PutStatusProbeReader) ReadResponse 

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