connectivity

package
v1.9.4 Latest Latest
Warning

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

Go to latest
Published: Feb 3, 2021 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) (*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) (*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 ClientService

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

	PutStatusProbe(params *PutStatusProbeParams) (*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 handles this case with default header values.

Success

func NewGetStatusOK

func NewGetStatusOK() *GetStatusOK

NewGetStatusOK creates a GetStatusOK with default headers values

func (*GetStatusOK) Error

func (o *GetStatusOK) Error() string

func (*GetStatusOK) GetPayload

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

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 values initialized.

func NewGetStatusParamsWithContext

func NewGetStatusParamsWithContext(ctx context.Context) *GetStatusParams

NewGetStatusParamsWithContext creates a new GetStatusParams object with the default values initialized, and 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 default values initialized, and 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 default values initialized, and 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) 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) 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 handles this case 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) Error

func (o *PutStatusProbeFailed) Error() string

func (*PutStatusProbeFailed) GetPayload

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

type PutStatusProbeOK

type PutStatusProbeOK struct {
	Payload *models.HealthStatusResponse
}

PutStatusProbeOK handles this case with default header values.

Success

func NewPutStatusProbeOK

func NewPutStatusProbeOK() *PutStatusProbeOK

NewPutStatusProbeOK creates a PutStatusProbeOK with default headers values

func (*PutStatusProbeOK) Error

func (o *PutStatusProbeOK) Error() string

func (*PutStatusProbeOK) GetPayload

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

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 values initialized.

func NewPutStatusProbeParamsWithContext

func NewPutStatusProbeParamsWithContext(ctx context.Context) *PutStatusProbeParams

NewPutStatusProbeParamsWithContext creates a new PutStatusProbeParams object with the default values initialized, and 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 default values initialized, and 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 default values initialized, and 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) 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

WithContext adds the context to the put status probe params

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL