agentpush

package
v0.0.0-...-5004fd2 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2024 License: MIT Imports: 41 Imported by: 0

Documentation

Overview

Package agentpush provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen/v2 version v2.0.0 DO NOT EDIT.

Package agentpush provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen/v2 version v2.0.0 DO NOT EDIT.

Package agentpush provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen/v2 version v2.0.0 DO NOT EDIT.

Index

Constants

View Source 
const (
	BearerAuthScopes = "BearerAuth.Scopes"
)

Variables

This section is empty.

Functions

func NewAgentDockerContainerInspectRequest 

func NewAgentDockerContainerInspectRequest(server string, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerInspectParams) (*http.Request, error)

NewAgentDockerContainerInspectRequest generates requests for AgentDockerContainerInspect

func NewAgentDockerContainerRemoveRequest 

func NewAgentDockerContainerRemoveRequest(server string, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerRemoveParams) (*http.Request, error)

NewAgentDockerContainerRemoveRequest generates requests for AgentDockerContainerRemove

func NewAgentDockerContainerStopRequest 

func NewAgentDockerContainerStopRequest(server string, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerStopParams) (*http.Request, error)

NewAgentDockerContainerStopRequest generates requests for AgentDockerContainerStop

func NewAgentLaunchAgentRequest 

func NewAgentLaunchAgentRequest(server string, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *AgentLaunchAgentParams, body AgentLaunchAgentJSONRequestBody) (*http.Request, error)

NewAgentLaunchAgentRequest calls the generic AgentLaunchAgent builder with application/json body

func NewAgentLaunchAgentRequestWithBody 

func NewAgentLaunchAgentRequestWithBody(server string, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *AgentLaunchAgentParams, contentType string, body io.Reader) (*http.Request, error)

NewAgentLaunchAgentRequestWithBody generates requests for AgentLaunchAgent with any type of body

func NewPushAgentConfigRadiusRequest 

func NewPushAgentConfigRadiusRequest(server string, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *PushAgentConfigRadiusParams) (*http.Request, error)

NewPushAgentConfigRadiusRequest generates requests for PushAgentConfigRadius

func NewServer 

func NewServer(buildID string, mode agentcommon.AgentSlot, envSvc common.EnvService, dockerClient dockerclient.APIClient) (*agentServer, error)

func RegisterHandlers 

func RegisterHandlers(router EchoRouter, si ServerInterface)

RegisterHandlers adds each server route to the EchoRouter.

func RegisterHandlersWithBaseURL 

func RegisterHandlersWithBaseURL(router EchoRouter, si ServerInterface, baseURL string)

Registers handlers, and prepends BaseURL to the paths, so that the paths can be served under a prefix.

Types

type AgentDockerContainerInspectParams 

type AgentDockerContainerInspectParams struct {
	XCryptocatProxyAuthorization *DelegatedAuthorizationHeaderParameter `json:"X-Cryptocat-Proxy-Authorization,omitempty"`
}

AgentDockerContainerInspectParams defines parameters for AgentDockerContainerInspect.

type AgentDockerContainerInspectResponse 

type AgentDockerContainerInspectResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *DockerContainerJSON
}

func ParseAgentDockerContainerInspectResponse 

func ParseAgentDockerContainerInspectResponse(rsp *http.Response) (*AgentDockerContainerInspectResponse, error)

ParseAgentDockerContainerInspectResponse parses an HTTP response from a AgentDockerContainerInspectWithResponse call

func (*AgentDockerContainerInspectResponse) GetBody 

func (r *AgentDockerContainerInspectResponse) GetBody() []byte

func (AgentDockerContainerInspectResponse) Status 

func (r AgentDockerContainerInspectResponse) Status() string

Status returns HTTPResponse.Status

func (AgentDockerContainerInspectResponse) StatusCode 

func (r AgentDockerContainerInspectResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type AgentDockerContainerRemoveParams 

type AgentDockerContainerRemoveParams struct {
	XCryptocatProxyAuthorization *DelegatedAuthorizationHeaderParameter `json:"X-Cryptocat-Proxy-Authorization,omitempty"`
}

AgentDockerContainerRemoveParams defines parameters for AgentDockerContainerRemove.

type AgentDockerContainerRemoveResponse 

type AgentDockerContainerRemoveResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseAgentDockerContainerRemoveResponse 

func ParseAgentDockerContainerRemoveResponse(rsp *http.Response) (*AgentDockerContainerRemoveResponse, error)

ParseAgentDockerContainerRemoveResponse parses an HTTP response from a AgentDockerContainerRemoveWithResponse call

func (*AgentDockerContainerRemoveResponse) GetBody 

func (r *AgentDockerContainerRemoveResponse) GetBody() []byte

func (AgentDockerContainerRemoveResponse) Status 

func (r AgentDockerContainerRemoveResponse) Status() string

Status returns HTTPResponse.Status

func (AgentDockerContainerRemoveResponse) StatusCode 

func (r AgentDockerContainerRemoveResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type AgentDockerContainerStopParams 

type AgentDockerContainerStopParams struct {
	XCryptocatProxyAuthorization *DelegatedAuthorizationHeaderParameter `json:"X-Cryptocat-Proxy-Authorization,omitempty"`
}

AgentDockerContainerStopParams defines parameters for AgentDockerContainerStop.

type AgentDockerContainerStopResponse 

type AgentDockerContainerStopResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseAgentDockerContainerStopResponse 

func ParseAgentDockerContainerStopResponse(rsp *http.Response) (*AgentDockerContainerStopResponse, error)

ParseAgentDockerContainerStopResponse parses an HTTP response from a AgentDockerContainerStopWithResponse call

func (*AgentDockerContainerStopResponse) GetBody 

func (r *AgentDockerContainerStopResponse) GetBody() []byte

func (AgentDockerContainerStopResponse) Status 

func (r AgentDockerContainerStopResponse) Status() string

Status returns HTTPResponse.Status

func (AgentDockerContainerStopResponse) StatusCode 

func (r AgentDockerContainerStopResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type AgentLaunchAgentJSONRequestBody 

type AgentLaunchAgentJSONRequestBody = LaunchAgentRequest

AgentLaunchAgentJSONRequestBody defines body for AgentLaunchAgent for application/json ContentType.

type AgentLaunchAgentParams 

type AgentLaunchAgentParams struct {
	XCryptocatProxyAuthorization *DelegatedAuthorizationHeaderParameter `json:"X-Cryptocat-Proxy-Authorization,omitempty"`
}

AgentLaunchAgentParams defines parameters for AgentLaunchAgent.

type AgentLaunchAgentResponse 

type AgentLaunchAgentResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *DockerContianerCreateResponse
}

func ParseAgentLaunchAgentResponse 

func ParseAgentLaunchAgentResponse(rsp *http.Response) (*AgentLaunchAgentResponse, error)

ParseAgentLaunchAgentResponse parses an HTTP response from a AgentLaunchAgentWithResponse call

func (*AgentLaunchAgentResponse) GetBody 

func (r *AgentLaunchAgentResponse) GetBody() []byte

func (AgentLaunchAgentResponse) Status 

func (r AgentLaunchAgentResponse) Status() string

Status returns HTTPResponse.Status

func (AgentLaunchAgentResponse) StatusCode 

func (r AgentLaunchAgentResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type Client 

type Client struct {
	// The endpoint of the server conforming to this interface, with scheme,
	// https://api.deepmap.com for example. This can contain a path relative
	// to the server, such as https://api.deepmap.com/dev-test, and all the
	// paths in the swagger spec will be appended to the server.
	Server string

	// Doer for performing requests, typically a *http.Client with any
	// customized settings, such as certificate chains.
	Client HttpRequestDoer

	// A list of callbacks for modifying requests which are generated before sending over
	// the network.
	RequestEditors []RequestEditorFn
}

Client which conforms to the OpenAPI3 specification for this service.

func NewClient 

func NewClient(server string, opts ...ClientOption) (*Client, error)

Creates a new Client, with reasonable defaults

func (*Client) AgentDockerContainerInspect 

func (c *Client) AgentDockerContainerInspect(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerInspectParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) AgentDockerContainerRemove 

func (c *Client) AgentDockerContainerRemove(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerRemoveParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) AgentDockerContainerStop 

func (c *Client) AgentDockerContainerStop(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerStopParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) AgentLaunchAgent 

func (c *Client) AgentLaunchAgent(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *AgentLaunchAgentParams, body AgentLaunchAgentJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) AgentLaunchAgentWithBody 

func (c *Client) AgentLaunchAgentWithBody(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *AgentLaunchAgentParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PushAgentConfigRadius 

func (c *Client) PushAgentConfigRadius(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *PushAgentConfigRadiusParams, reqEditors ...RequestEditorFn) (*http.Response, error)

type ClientInterface 

type ClientInterface interface {
	// PushAgentConfigRadius request
	PushAgentConfigRadius(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *PushAgentConfigRadiusParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// AgentDockerContainerRemove request
	AgentDockerContainerRemove(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerRemoveParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// AgentDockerContainerInspect request
	AgentDockerContainerInspect(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerInspectParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// AgentDockerContainerStop request
	AgentDockerContainerStop(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerStopParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// AgentLaunchAgentWithBody request with any body
	AgentLaunchAgentWithBody(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *AgentLaunchAgentParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	AgentLaunchAgent(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *AgentLaunchAgentParams, body AgentLaunchAgentJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
}

The interface specification for the client above.

type ClientOption 

type ClientOption func(*Client) error

ClientOption allows setting custom parameters during construction

func WithBaseURL 

func WithBaseURL(baseURL string) ClientOption

WithBaseURL overrides the baseURL.

func WithHTTPClient 

func WithHTTPClient(doer HttpRequestDoer) ClientOption

WithHTTPClient allows overriding the default Doer, which is automatically created using http.Client. This is useful for tests.

func WithRequestEditorFn 

func WithRequestEditorFn(fn RequestEditorFn) ClientOption

WithRequestEditorFn allows setting up a callback function, which will be called right before sending the request. This can be used to mutate the request.

type ClientWithResponses 

type ClientWithResponses struct {
	ClientInterface
}

ClientWithResponses builds on ClientInterface to offer response payloads

func NewClientWithResponses 

func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)

NewClientWithResponses creates a new ClientWithResponses, which wraps Client with return type handling

func (*ClientWithResponses) AgentDockerContainerInspectWithResponse 

func (c *ClientWithResponses) AgentDockerContainerInspectWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerInspectParams, reqEditors ...RequestEditorFn) (*AgentDockerContainerInspectResponse, error)

AgentDockerContainerInspectWithResponse request returning *AgentDockerContainerInspectResponse

func (*ClientWithResponses) AgentDockerContainerRemoveWithResponse 

func (c *ClientWithResponses) AgentDockerContainerRemoveWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerRemoveParams, reqEditors ...RequestEditorFn) (*AgentDockerContainerRemoveResponse, error)

AgentDockerContainerRemoveWithResponse request returning *AgentDockerContainerRemoveResponse

func (*ClientWithResponses) AgentDockerContainerStopWithResponse 

func (c *ClientWithResponses) AgentDockerContainerStopWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerStopParams, reqEditors ...RequestEditorFn) (*AgentDockerContainerStopResponse, error)

AgentDockerContainerStopWithResponse request returning *AgentDockerContainerStopResponse

func (*ClientWithResponses) AgentLaunchAgentWithBodyWithResponse 

func (c *ClientWithResponses) AgentLaunchAgentWithBodyWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *AgentLaunchAgentParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AgentLaunchAgentResponse, error)

AgentLaunchAgentWithBodyWithResponse request with arbitrary body returning *AgentLaunchAgentResponse

func (*ClientWithResponses) AgentLaunchAgentWithResponse 

func (c *ClientWithResponses) AgentLaunchAgentWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *AgentLaunchAgentParams, body AgentLaunchAgentJSONRequestBody, reqEditors ...RequestEditorFn) (*AgentLaunchAgentResponse, error)

func (*ClientWithResponses) PushAgentConfigRadiusWithResponse 

func (c *ClientWithResponses) PushAgentConfigRadiusWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *PushAgentConfigRadiusParams, reqEditors ...RequestEditorFn) (*PushAgentConfigRadiusResponse, error)

PushAgentConfigRadiusWithResponse request returning *PushAgentConfigRadiusResponse

type ClientWithResponsesInterface 

type ClientWithResponsesInterface interface {
	// PushAgentConfigRadiusWithResponse request
	PushAgentConfigRadiusWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *PushAgentConfigRadiusParams, reqEditors ...RequestEditorFn) (*PushAgentConfigRadiusResponse, error)

	// AgentDockerContainerRemoveWithResponse request
	AgentDockerContainerRemoveWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerRemoveParams, reqEditors ...RequestEditorFn) (*AgentDockerContainerRemoveResponse, error)

	// AgentDockerContainerInspectWithResponse request
	AgentDockerContainerInspectWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerInspectParams, reqEditors ...RequestEditorFn) (*AgentDockerContainerInspectResponse, error)

	// AgentDockerContainerStopWithResponse request
	AgentDockerContainerStopWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params *AgentDockerContainerStopParams, reqEditors ...RequestEditorFn) (*AgentDockerContainerStopResponse, error)

	// AgentLaunchAgentWithBodyWithResponse request with any body
	AgentLaunchAgentWithBodyWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *AgentLaunchAgentParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AgentLaunchAgentResponse, error)

	AgentLaunchAgentWithResponse(ctx context.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params *AgentLaunchAgentParams, body AgentLaunchAgentJSONRequestBody, reqEditors ...RequestEditorFn) (*AgentLaunchAgentResponse, error)
}

ClientWithResponsesInterface is the interface specification for the client with responses above.

func NewClientWithCreds 

func NewClientWithCreds(server string, caCertBytes []byte, accessToken string) (ClientWithResponsesInterface, error)

type DelegatedAuthorizationHeaderParameter 

type DelegatedAuthorizationHeaderParameter = string

DelegatedAuthorizationHeaderParameter defines model for DelegatedAuthorizationHeaderParameter.

type DockerContainerJSON 

type DockerContainerJSON = types.ContainerJSON

DockerContainerJSON defines model for DockerContainerJSON.

type DockerContianerCreateResponse 

type DockerContianerCreateResponse = container.CreateResponse

DockerContianerCreateResponse defines model for DockerContianerCreateResponse.

type EchoRouter 

type EchoRouter interface {
	CONNECT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	DELETE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	GET(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	HEAD(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	OPTIONS(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PATCH(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	POST(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PUT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	TRACE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
}

This is a simple interface which specifies echo.Route addition functions which are present on both echo.Echo and echo.Group, since we want to allow using either of them for path registration

type HttpRequestDoer 

type HttpRequestDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

Doer performs HTTP requests.

The standard http.Client implements this interface.

type LaunchAgentRequest 

type LaunchAgentRequest struct {
	ContainerName                 string                     `json:"containerName"`
	Env                           []string                   `json:"env,omitempty"`
	ExposedPortSpecs              []string                   `json:"exposedPortSpecs"`
	HostBinds                     []string                   `json:"hostBinds"`
	ImageTag                      string                     `json:"imageTag"`
	ListenerAddress               string                     `json:"listenerAddress"`
	Mode                          externalRef1.AgentMode     `json:"mode"`
	MsEntraIdClientCertSecretName string                     `json:"msEntraIdClientCertSecretName,omitempty"`
	NetworkName                   string                     `json:"networkName,omitempty"`
	PushEndpoint                  string                     `json:"pushEndpoint"`
	Secrets                       []externalRef1.SecretMount `json:"secrets"`
}

LaunchAgentRequest defines model for LaunchAgentRequest.

type ProxiedResponse 

type ProxiedResponse interface {
	StatusCode() int
	GetBody() []byte
}

type ProxyClientPool 

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

func NewProxyClientPool 

func NewProxyClientPool(maxSize int) *ProxyClientPool

func (*ProxyClientPool) AddClient 

func (p *ProxyClientPool) AddClient(client ClientWithResponsesInterface, tokenString string) error

func (*ProxyClientPool) GetCachedClient 

func (p *ProxyClientPool) GetCachedClient(tokenString string) (ClientWithResponsesInterface, bool, error)

func (*ProxyClientPool) GetCutOff 

func (p *ProxyClientPool) GetCutOff() time.Time

func (*ProxyClientPool) Len 

func (p *ProxyClientPool) Len() int

Len implements heap.Interface.

func (*ProxyClientPool) Less 

func (p *ProxyClientPool) Less(i int, j int) bool

Less implements heap.Interface.

func (*ProxyClientPool) Pop 

func (p *ProxyClientPool) Pop() any

Pop implements heap.Interface.

func (*ProxyClientPool) Push 

func (p *ProxyClientPool) Push(x any)

Push implements heap.Interface.

func (*ProxyClientPool) Swap 

func (p *ProxyClientPool) Swap(i int, j int)

Swap implements heap.Interface.

type PushAgentConfigRadiusParams 

type PushAgentConfigRadiusParams struct {
	XCryptocatProxyAuthorization *DelegatedAuthorizationHeaderParameter `json:"X-Cryptocat-Proxy-Authorization,omitempty"`
}

PushAgentConfigRadiusParams defines parameters for PushAgentConfigRadius.

type PushAgentConfigRadiusResponse 

type PushAgentConfigRadiusResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParsePushAgentConfigRadiusResponse 

func ParsePushAgentConfigRadiusResponse(rsp *http.Response) (*PushAgentConfigRadiusResponse, error)

ParsePushAgentConfigRadiusResponse parses an HTTP response from a PushAgentConfigRadiusWithResponse call

func (*PushAgentConfigRadiusResponse) GetBody 

func (r *PushAgentConfigRadiusResponse) GetBody() []byte

func (PushAgentConfigRadiusResponse) Status 

func (r PushAgentConfigRadiusResponse) Status() string

Status returns HTTPResponse.Status

func (PushAgentConfigRadiusResponse) StatusCode 

func (r PushAgentConfigRadiusResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RequestEditorFn 

type RequestEditorFn func(ctx context.Context, req *http.Request) error

RequestEditorFn is the function signature for the RequestEditor callback function

type ServerInterface 

type ServerInterface interface {

	// (POST /v1/{namespaceKind}/{namespaceId}/agent/instance/{resourceId}/config/radius)
	PushAgentConfigRadius(ctx echo.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params PushAgentConfigRadiusParams) error

	// (DELETE /v1/{namespaceKind}/{namespaceId}/agent/instance/{resourceId}/docker/containers/{containerId})
	AgentDockerContainerRemove(ctx echo.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params AgentDockerContainerRemoveParams) error

	// (GET /v1/{namespaceKind}/{namespaceId}/agent/instance/{resourceId}/docker/containers/{containerId})
	AgentDockerContainerInspect(ctx echo.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params AgentDockerContainerInspectParams) error

	// (POST /v1/{namespaceKind}/{namespaceId}/agent/instance/{resourceId}/docker/containers/{containerId}/stop)
	AgentDockerContainerStop(ctx echo.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, containerId string, params AgentDockerContainerStopParams) error

	// (POST /v1/{namespaceKind}/{namespaceId}/agent/instance/{resourceId}/launch-agent)
	AgentLaunchAgent(ctx echo.Context, namespaceKind externalRef0.NamespaceKindParameter, namespaceId externalRef0.NamespaceIdParameter, resourceId externalRef0.ResourceIdParameter, params AgentLaunchAgentParams) error
}

ServerInterface represents all server handlers.

func NewProxiedServer 

func NewProxiedServer(apiServer api.APIServer) ServerInterface

type ServerInterfaceWrapper 

type ServerInterfaceWrapper struct {
	Handler ServerInterface
}

ServerInterfaceWrapper converts echo contexts to parameters.

func (*ServerInterfaceWrapper) AgentDockerContainerInspect 

func (w *ServerInterfaceWrapper) AgentDockerContainerInspect(ctx echo.Context) error

AgentDockerContainerInspect converts echo context to params.

func (*ServerInterfaceWrapper) AgentDockerContainerRemove 

func (w *ServerInterfaceWrapper) AgentDockerContainerRemove(ctx echo.Context) error

AgentDockerContainerRemove converts echo context to params.

func (*ServerInterfaceWrapper) AgentDockerContainerStop 

func (w *ServerInterfaceWrapper) AgentDockerContainerStop(ctx echo.Context) error

AgentDockerContainerStop converts echo context to params.

func (*ServerInterfaceWrapper) AgentLaunchAgent 

func (w *ServerInterfaceWrapper) AgentLaunchAgent(ctx echo.Context) error

AgentLaunchAgent converts echo context to params.

func (*ServerInterfaceWrapper) PushAgentConfigRadius 

func (w *ServerInterfaceWrapper) PushAgentConfigRadius(ctx echo.Context) error

PushAgentConfigRadius converts echo context to params.

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.