appManagerApiClient

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2019 License: Apache-2.0 Imports: 20 Imported by: 0

README

Go API client for ververicaplatformapi

HTTP REST API to connect to the AppManager

Overview

This API client was generated by the swagger-codegen project. By using the swagger-spec from a remote server, you can easily generate an API client.

  • API version: 1.0
  • Package version: 1.0.0
  • Build package: io.swagger.codegen.languages.GoClientCodegen

Installation

Put the package under your project folder and add the following in import:

import "./ververicaplatformapi"

Documentation for API Endpoints

All URIs are relative to http://localhost/api

Class Method HTTP request Description
ApiTokensApi CreateToken Post /v1/api-tokens Create a new api token
ApiTokensApi DeleteToken Delete /v1/api-tokens/{name} Delete an api token by name
ApiTokensApi GetToken Get /v1/api-tokens/{name} Get an api token by name
ApiTokensApi GetTokens Get /v1/api-tokens List all api tokens
ClusterRoleBindingsApi CreateClusterRoleBinding Post /v1/cluster-role-bindings Create a cluster role binding
ClusterRoleBindingsApi DeleteClusterRoleBinding Delete /v1/cluster-role-bindings/{name} Delete a cluster role binding
ClusterRoleBindingsApi GetClusterRoleBinding Get /v1/cluster-role-bindings/{name} Get a cluster role binding by name
ClusterRoleBindingsApi GetClusterRoleBindings Get /v1/cluster-role-bindings List all cluster role bindings
ClusterRoleBindingsApi UpdateClusterRoleBinding Patch /v1/cluster-role-bindings/{name} Update a cluster role binding
ClusterRolesApi CreateClusterRole Post /v1/cluster-roles Create a cluster role
ClusterRolesApi DeleteClusterRole Delete /v1/cluster-roles/{name} Delete a cluster role
ClusterRolesApi GetClusterRole Get /v1/cluster-roles/{name} Get a cluster role by name
ClusterRolesApi GetClusterRoles Get /v1/cluster-roles List all cluster roles
ClusterRolesApi UpdateClusterRole Patch /v1/cluster-roles/{name} Update a cluster role
DeploymentTargetsApi CreateDeploymentTarget Post /v1/namespaces/{namespace}/deployment-targets Create a deployment target
DeploymentTargetsApi DeleteDeploymentTarget Delete /v1/namespaces/{namespace}/deployment-targets/{name} Delete a deployment target
DeploymentTargetsApi GetDeploymentTarget Get /v1/namespaces/{namespace}/deployment-targets/{name} Get a deployment target by name
DeploymentTargetsApi GetDeploymentTargets Get /v1/namespaces/{namespace}/deployment-targets List all deployment targets
DeploymentsApi CreateDeployment Post /v1/namespaces/{namespace}/deployments Create a deployment
DeploymentsApi DeleteDeployment Delete /v1/namespaces/{namespace}/deployments/{deploymentId} Delete deployment
DeploymentsApi GetDeployment Get /v1/namespaces/{namespace}/deployments/{deploymentId} Get a deployment by id
DeploymentsApi GetDeployments Get /v1/namespaces/{namespace}/deployments List all deployments
DeploymentsApi UpdateDeployment Patch /v1/namespaces/{namespace}/deployments/{deploymentId} Update a deployment
EventsApi GetEvents Get /v1/namespaces/{namespace}/events Filter all events for a deployment or job
JobsApi GetJob Get /v1/namespaces/{namespace}/jobs/{jobId} Get a job by id
JobsApi GetJobs Get /v1/namespaces/{namespace}/jobs List all jobs. Can be filtered by DeploymentId
NamespacesApi DeleteNamespace Delete /v1/namespaces/{name} Delete a namespace by name
NamespacesApi GetNamespace Get /v1/namespaces/{name} Get a namespace by name
NamespacesApi ListNamespaces Get /v1/namespaces List namespaces
NamespacesApi PostNamespace Post /v1/namespaces Create a namespace
RoleBindingsApi CreateRoleBinding Post /v1/namespaces/{namespace}/role-bindings Create a role binding
RoleBindingsApi DeleteRoleBinding Delete /v1/namespaces/{namespace}/role-bindings/{name} Delete a role binding
RoleBindingsApi GetRoleBinding Get /v1/namespaces/{namespace}/role-bindings/{name} Get a role binding by name
RoleBindingsApi GetRoleBindings Get /v1/namespaces/{namespace}/role-bindings List all role bindings
RoleBindingsApi UpdateRoleBinding Patch /v1/namespaces/{namespace}/role-bindings/{name} Update a role binding
RolesApi CreateRole Post /v1/namespaces/{namespace}/roles Create a role
RolesApi DeleteRole Delete /v1/namespaces/{namespace}/roles/{name} Delete a role
RolesApi GetRole Get /v1/namespaces/{namespace}/roles/{name} Get a role by name
RolesApi GetRoles Get /v1/namespaces/{namespace}/roles List all roles
RolesApi UpdateRole Patch /v1/namespaces/{namespace}/roles/{name} Update a role
SavepointsApi CreateSavepoint Post /v1/namespaces/{namespace}/savepoints Create a new savepoint
SavepointsApi GetSavepoint Get /v1/namespaces/{namespace}/savepoints/{savepointId} Get a savepoint by id
SavepointsApi GetSavepoints Get /v1/namespaces/{namespace}/savepoints List all savepoints. Can be filtered by DeploymentId
SecretValuesApi CreateSecretValue Post /v1/namespaces/{namespace}/secret-values Create a secret value
SecretValuesApi DeleteSecretValue Delete /v1/namespaces/{namespace}/secret-values/{name} Delete a secret value
SecretValuesApi GetSecretValue Get /v1/namespaces/{namespace}/secret-values/{name} Get a secret value by name
SecretValuesApi GetSecretValues Get /v1/namespaces/{namespace}/secret-values List all secrets values
SecretValuesApi UpdateSecretValue Patch /v1/namespaces/{namespace}/secret-values/{name} Update a secret value
StatusApi GetStatus Get /v1/status Check that the server is running
StatusApi GetSystemInfo Get /v1/status/system-info Get system's information

Documentation For Models

Documentation For Authorization

Endpoints do not require authorization.

Author

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ContextOAuth2 takes a oauth2.TokenSource as authentication for the request.
	ContextOAuth2 = contextKey("token")

	// ContextBasicAuth takes BasicAuth as authentication for the request.
	ContextBasicAuth = contextKey("basic")

	// ContextAccessToken takes a string oauth2 access token as authentication for the request.
	ContextAccessToken = contextKey("accesstoken")
)

Functions

func CacheExpires 

func CacheExpires(r *http.Response) time.Time

CacheExpires helper function to determine remaining time before repeating a request.

Types

type APIClient 

type APIClient struct {
	DeploymentTargetsApi *DeploymentTargetsApiService

	DeploymentsApi *DeploymentsApiService

	EventsApi *EventsApiService

	JobsApi *JobsApiService

	NamespacesApi *NamespacesApiService

	SavepointsApi *SavepointsApiService

	SecretValuesApi *SecretValuesApiService

	StatusApi *StatusApiService
	// contains filtered or unexported fields
}

APIClient manages communication with the AppManager API API v1.0 In most cases there should be only one, shared, APIClient.

func NewAPIClient 

func NewAPIClient(cfg *Configuration) *APIClient

NewAPIClient creates a new API client. Requires a userAgent string describing your application. optionally a custom http.Client to allow for advanced features such as caching.

func (*APIClient) ChangeBasePath 

func (c *APIClient) ChangeBasePath(path string)

Change base path to allow switching to mocks

func (*APIClient) Configuration 

func (c *APIClient) Configuration() Configuration

Configuration gets the client's current configuration

type APIResponse 

type APIResponse struct {
	*http.Response `json:"-"`
	Message        string `json:"message,omitempty"`
	// Operation is the name of the swagger operation.
	Operation string `json:"operation,omitempty"`
	// RequestURL is the request URL. This value is always available, even if the
	// embedded *http.Response is nil.
	RequestURL string `json:"url,omitempty"`
	// Method is the HTTP method used for the request.  This value is always
	// available, even if the embedded *http.Response is nil.
	Method string `json:"method,omitempty"`
	// Payload holds the contents of the response body (which may be nil or empty).
	// This is provided here as the raw response.Body() reader will have already
	// been drained.
	Payload []byte `json:"-"`
}

func NewAPIResponse 

func NewAPIResponse(r *http.Response) *APIResponse

func NewAPIResponseWithError 

func NewAPIResponseWithError(errorMessage string) *APIResponse

type Any 

type Any interface{}

type ApiToken 

type ApiToken struct {
	Kind       string            `json:"kind,omitempty"`
	ApiVersion string            `json:"apiVersion,omitempty"`
	Metadata   *ApiTokenMetadata `json:"metadata"`
	Spec       *ApiTokenSpec     `json:"spec,omitempty"`
}

type ApiTokenMetadata 

type ApiTokenMetadata struct {
	Id         string    `json:"id,omitempty"`
	Name       string    `json:"name"`
	CreatedAt  time.Time `json:"createdAt,omitempty"`
	ModifiedAt time.Time `json:"modifiedAt,omitempty"`
}

type ApiTokenSpec 

type ApiTokenSpec struct {
	Token string `json:"token,omitempty"`
}

type Artifact 

type Artifact struct {
	Kind                 string `json:"kind"`
	JarUri               string `json:"jarUri"`
	MainArgs             string `json:"mainArgs,omitempty"`
	EntryClass           string `json:"entryClass,omitempty"`
	FlinkVersion         string `json:"flinkVersion,omitempty"`
	FlinkImageRegistry   string `json:"flinkImageRegistry,omitempty"`
	FlinkImageRepository string `json:"flinkImageRepository,omitempty"`
	FlinkImageTag        string `json:"flinkImageTag,omitempty"`
}

type BasicAuth 

type BasicAuth struct {
	UserName string `json:"userName,omitempty"`
	Password string `json:"password,omitempty"`
}

BasicAuth provides basic http authentication to a request passed via context using ContextBasicAuth

type Configuration 

type Configuration struct {
	BasePath      string            `json:"basePath,omitempty"`
	Host          string            `json:"host,omitempty"`
	Scheme        string            `json:"scheme,omitempty"`
	DefaultHeader map[string]string `json:"defaultHeader,omitempty"`
	UserAgent     string            `json:"userAgent,omitempty"`
	HTTPClient    *http.Client
}

func NewConfiguration 

func NewConfiguration() *Configuration

func (*Configuration) AddDefaultHeader 

func (c *Configuration) AddDefaultHeader(key string, value string)

type Deployment 

type Deployment struct {
	Kind       string              `json:"kind,omitempty"`
	ApiVersion string              `json:"apiVersion,omitempty"`
	Metadata   *DeploymentMetadata `json:"metadata"`
	Spec       *DeploymentSpec     `json:"spec"`
	Status     *DeploymentStatus   `json:"status,omitempty"`
}

type DeploymentMetadata 

type DeploymentMetadata struct {
	Id              string            `json:"id,omitempty"`
	Name            string            `json:"name,omitempty"`
	Namespace       string            `json:"namespace,omitempty"`
	CreatedAt       time.Time         `json:"createdAt,omitempty"`
	ModifiedAt      time.Time         `json:"modifiedAt,omitempty"`
	Labels          map[string]string `json:"labels,omitempty"`
	Annotations     map[string]string `json:"annotations,omitempty"`
	ResourceVersion int32             `json:"resourceVersion,omitempty"`
}

type DeploymentRestoreStrategy 

type DeploymentRestoreStrategy struct {
	Kind                  string `json:"kind,omitempty"`
	AllowNonRestoredState bool   `json:"allowNonRestoredState,omitempty"`
}

type DeploymentSpec 

type DeploymentSpec struct {
	State                        string                        `json:"state"`
	UpgradeStrategy              *DeploymentUpgradeStrategy    `json:"upgradeStrategy"`
	RestoreStrategy              *DeploymentRestoreStrategy    `json:"restoreStrategy,omitempty"`
	StartFromSavepoint           *DeploymentStartFromSavepoint `json:"startFromSavepoint,omitempty"`
	DeploymentTargetId           string                        `json:"deploymentTargetId"`
	MaxSavepointCreationAttempts int32                         `json:"maxSavepointCreationAttempts,omitempty"`
	MaxJobCreationAttempts       int32                         `json:"maxJobCreationAttempts,omitempty"`
	Template                     *DeploymentTemplate           `json:"template"`
}

type DeploymentStartFromSavepoint 

type DeploymentStartFromSavepoint struct {
	Kind string `json:"kind,omitempty"`
}

type DeploymentStatus 

type DeploymentStatus struct {
	State string `json:"state,omitempty"`
}

type DeploymentTarget 

type DeploymentTarget struct {
	Kind       string                    `json:"kind,omitempty"`
	ApiVersion string                    `json:"apiVersion,omitempty"`
	Metadata   *DeploymentTargetMetadata `json:"metadata"`
	Spec       *DeploymentTargetSpec     `json:"spec"`
}

type DeploymentTargetMetadata 

type DeploymentTargetMetadata struct {
	Id              string            `json:"id,omitempty"`
	Name            string            `json:"name"`
	Namespace       string            `json:"namespace,omitempty"`
	CreatedAt       time.Time         `json:"createdAt,omitempty"`
	ModifiedAt      time.Time         `json:"modifiedAt,omitempty"`
	Labels          map[string]string `json:"labels,omitempty"`
	Annotations     map[string]string `json:"annotations,omitempty"`
	ResourceVersion int32             `json:"resourceVersion,omitempty"`
}

type DeploymentTargetSpec 

type DeploymentTargetSpec struct {
	Kubernetes         *KubernetesTarget  `json:"kubernetes"`
	DeploymentPatchSet []JsonPatchGeneric `json:"deploymentPatchSet,omitempty"`
}

type DeploymentTargetsApiService 

type DeploymentTargetsApiService service

func (*DeploymentTargetsApiService) CreateDeploymentTarget 

func (a *DeploymentTargetsApiService) CreateDeploymentTarget(ctx context.Context, namespace string, body DeploymentTarget) (DeploymentTarget, *http.Response, error)

DeploymentTargetsApiService Create a deployment target

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param body

@return DeploymentTarget

func (*DeploymentTargetsApiService) DeleteDeploymentTarget 

func (a *DeploymentTargetsApiService) DeleteDeploymentTarget(ctx context.Context, namespace string, name string) (DeploymentTarget, *http.Response, error)

DeploymentTargetsApiService Delete a deployment target

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param name

@return DeploymentTarget

func (*DeploymentTargetsApiService) GetDeploymentTarget 

func (a *DeploymentTargetsApiService) GetDeploymentTarget(ctx context.Context, namespace string, name string) (DeploymentTarget, *http.Response, error)

DeploymentTargetsApiService Get a deployment target by name

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param name

@return DeploymentTarget

func (*DeploymentTargetsApiService) GetDeploymentTargets 

func (a *DeploymentTargetsApiService) GetDeploymentTargets(ctx context.Context, namespace string) (ResourceListDeploymentTarget, *http.Response, error)

DeploymentTargetsApiService List all deployment targets

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace

@return ResourceListDeploymentTarget

type DeploymentTemplate 

type DeploymentTemplate struct {
	Metadata *DeploymentTemplateMetadata `json:"metadata,omitempty"`
	Spec     *DeploymentTemplateSpec     `json:"spec"`
}

type DeploymentTemplateMetadata 

type DeploymentTemplateMetadata struct {
	Annotations map[string]string `json:"annotations,omitempty"`
}

type DeploymentTemplateSpec 

type DeploymentTemplateSpec struct {
	Artifact             *Artifact               `json:"artifact"`
	Parallelism          int32                   `json:"parallelism,omitempty"`
	NumberOfTaskManagers int32                   `json:"numberOfTaskManagers,omitempty"`
	Resources            map[string]ResourceSpec `json:"resources,omitempty"`
	FlinkConfiguration   map[string]string       `json:"flinkConfiguration,omitempty"`
	Logging              *Logging                `json:"logging,omitempty"`
	Kubernetes           *KubernetesOptions      `json:"kubernetes,omitempty"`
}

type DeploymentUpgradeStrategy 

type DeploymentUpgradeStrategy struct {
	Kind string `json:"kind,omitempty"`
}

type DeploymentsApiService 

type DeploymentsApiService service

func (*DeploymentsApiService) CreateDeployment 

func (a *DeploymentsApiService) CreateDeployment(ctx context.Context, namespace string, body Deployment) (Deployment, *http.Response, error)

DeploymentsApiService Create a deployment

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param body

@return Deployment

func (*DeploymentsApiService) DeleteDeployment 

func (a *DeploymentsApiService) DeleteDeployment(ctx context.Context, namespace string, deploymentId string) (Deployment, *http.Response, error)

DeploymentsApiService Delete deployment This operation expects the deployment to be in desired state CANCELLED

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param deploymentId

@return Deployment

func (*DeploymentsApiService) GetDeployment 

func (a *DeploymentsApiService) GetDeployment(ctx context.Context, namespace string, deploymentId string) (Deployment, *http.Response, error)

DeploymentsApiService Get a deployment by id

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param deploymentId

@return Deployment

func (*DeploymentsApiService) GetDeployments 

func (a *DeploymentsApiService) GetDeployments(ctx context.Context, namespace string, localVarOptionals *GetDeploymentsOpts) (ResourceListDeployment, *http.Response, error)

func (*DeploymentsApiService) UpdateDeployment 

func (a *DeploymentsApiService) UpdateDeployment(ctx context.Context, namespace string, deploymentId string, body Deployment) (Deployment, *http.Response, error)

DeploymentsApiService Update a deployment

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param deploymentId
  • @param body

@return Deployment

type EnvVar 

type EnvVar struct {
	Name      string    `json:"name,omitempty"`
	Value     string    `json:"value,omitempty"`
	ValueFrom *JsonNode `json:"valueFrom,omitempty"`
}

type Event 

type Event struct {
	Kind       string         `json:"kind,omitempty"`
	ApiVersion string         `json:"apiVersion,omitempty"`
	Metadata   *EventMetadata `json:"metadata,omitempty"`
	Spec       *EventSpec     `json:"spec,omitempty"`
}

type EventMetadata 

type EventMetadata struct {
	Id              string    `json:"id,omitempty"`
	CreatedAt       time.Time `json:"createdAt,omitempty"`
	DeploymentId    string    `json:"deploymentId,omitempty"`
	JobId           string    `json:"jobId,omitempty"`
	ResourceVersion int32     `json:"resourceVersion,omitempty"`
	Name            string    `json:"name,omitempty"`
	Namespace       string    `json:"namespace,omitempty"`
}

type EventSpec 

type EventSpec struct {
	Message string `json:"message,omitempty"`
}

type EventsApiService 

type EventsApiService service

func (*EventsApiService) GetEvents 

func (a *EventsApiService) GetEvents(ctx context.Context, namespace string, localVarOptionals *GetEventsOpts) (ResourceListEvent, *http.Response, error)

type Failure 

type Failure struct {
	Message  string    `json:"message,omitempty"`
	Reason   string    `json:"reason,omitempty"`
	FailedAt time.Time `json:"failedAt,omitempty"`
}

type GenericSwaggerError 

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

GenericSwaggerError Provides access to the body, error and model on returned errors.

func (GenericSwaggerError) Body 

func (e GenericSwaggerError) Body() []byte

Body returns the raw bytes of the response

func (GenericSwaggerError) Error 

func (e GenericSwaggerError) Error() string

Error returns non-empty string if there was an error.

func (GenericSwaggerError) Model 

func (e GenericSwaggerError) Model() interface{}

Model returns the unpacked model of the error

func (GenericSwaggerError) StatusCode 

func (e GenericSwaggerError) StatusCode() int

StatusCode returns the response status code

func (GenericSwaggerError) WithStatusCode 

func (e GenericSwaggerError) WithStatusCode(statusCode int) GenericSwaggerError

type GetDeploymentsOpts 

type GetDeploymentsOpts struct {
	LabelSelector optional.String
}

type GetEventsOpts 

type GetEventsOpts struct {
	DeploymentId optional.Interface
	JobId        optional.Interface
}

type GetJobsOpts 

type GetJobsOpts struct {
	DeploymentId optional.Interface
}

type GetSavepointsOpts 

type GetSavepointsOpts struct {
	DeploymentId optional.Interface
	JobId        optional.Interface
}

type IterableRoleBindingSubject 

type IterableRoleBindingSubject struct {
}

type IterableRoleRule 

type IterableRoleRule struct {
}

type Job 

type Job struct {
	Kind       string       `json:"kind,omitempty"`
	ApiVersion string       `json:"apiVersion,omitempty"`
	Metadata   *JobMetadata `json:"metadata,omitempty"`
	Spec       *JobSpec     `json:"spec,omitempty"`
	Status     *JobStatus   `json:"status,omitempty"`
}

type JobDeploymentTarget 

type JobDeploymentTarget struct {
	Kubernetes *KubernetesTarget `json:"kubernetes,omitempty"`
}

type JobMetadata 

type JobMetadata struct {
	Id              string            `json:"id,omitempty"`
	CreatedAt       time.Time         `json:"createdAt,omitempty"`
	ModifiedAt      time.Time         `json:"modifiedAt,omitempty"`
	TerminatedAt    int64             `json:"terminatedAt,omitempty"`
	DeploymentId    string            `json:"deploymentId,omitempty"`
	Annotations     map[string]string `json:"annotations,omitempty"`
	ResourceVersion int32             `json:"resourceVersion,omitempty"`
	Namespace       string            `json:"namespace,omitempty"`
}

type JobSpec 

type JobSpec struct {
	Artifact              *Artifact               `json:"artifact,omitempty"`
	Parallelism           int32                   `json:"parallelism,omitempty"`
	FlinkConfiguration    map[string]string       `json:"flinkConfiguration,omitempty"`
	Resources             map[string]ResourceSpec `json:"resources,omitempty"`
	SavepointLocation     string                  `json:"savepointLocation,omitempty"`
	AllowNonRestoredState bool                    `json:"allowNonRestoredState,omitempty"`
	NumberOfTaskManagers  int32                   `json:"numberOfTaskManagers,omitempty"`
	Logging               *Logging                `json:"logging,omitempty"`
	Kubernetes            *KubernetesOptions      `json:"kubernetes,omitempty"`
	DeploymentTarget      *JobDeploymentTarget    `json:"deploymentTarget,omitempty"`
}

type JobStatus 

type JobStatus struct {
	State   string   `json:"state,omitempty"`
	Failure *Failure `json:"failure,omitempty"`
}

type JobsApiService 

type JobsApiService service

func (*JobsApiService) GetJob 

func (a *JobsApiService) GetJob(ctx context.Context, namespace string, jobId string) (Job, *http.Response, error)

JobsApiService Get a job by id

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param jobId

@return Job

func (*JobsApiService) GetJobs 

func (a *JobsApiService) GetJobs(ctx context.Context, namespace string, localVarOptionals *GetJobsOpts) (ResourceListJob, *http.Response, error)

type JsonNode 

type JsonNode struct {
	ValueNode           bool   `json:"valueNode,omitempty"`
	ContainerNode       bool   `json:"containerNode,omitempty"`
	MissingNode         bool   `json:"missingNode,omitempty"`
	Object              bool   `json:"object,omitempty"`
	NodeType            string `json:"nodeType,omitempty"`
	Pojo                bool   `json:"pojo,omitempty"`
	Number              bool   `json:"number,omitempty"`
	IntegralNumber      bool   `json:"integralNumber,omitempty"`
	FloatingPointNumber bool   `json:"floatingPointNumber,omitempty"`
	Short               bool   `json:"short,omitempty"`
	Int_                bool   `json:"int,omitempty"`
	Long                bool   `json:"long,omitempty"`
	Float               bool   `json:"float,omitempty"`
	Double              bool   `json:"double,omitempty"`
	BigDecimal          bool   `json:"bigDecimal,omitempty"`
	BigInteger          bool   `json:"bigInteger,omitempty"`
	Textual             bool   `json:"textual,omitempty"`
	Boolean             bool   `json:"boolean,omitempty"`
	Binary              bool   `json:"binary,omitempty"`
	Array               bool   `json:"array,omitempty"`
	Null                bool   `json:"null,omitempty"`
}

type JsonPatchGeneric 

type JsonPatchGeneric struct {
	Op    string `json:"op"`
	Path  string `json:"path"`
	Value Any    `json:"value,omitempty"`
	From  string `json:"from,omitempty"`
}

Since Swagger 2 doesn't have oneOf support, this definition should fit all JSON Patch objects.

type KubernetesOptions 

type KubernetesOptions struct {
	Pods *Pods `json:"pods,omitempty"`
}

type KubernetesTarget 

type KubernetesTarget struct {
	Namespace string `json:"namespace,omitempty"`
}

type License 

type License struct {
	Kind       string           `json:"kind,omitempty"`
	ApiVersion string           `json:"apiVersion,omitempty"`
	Metadata   *LicenseMetadata `json:"metadata"`
	Spec       *LicenseSpec     `json:"spec"`
}

type LicenseMetadata 

type LicenseMetadata struct {
	Id          string            `json:"id,omitempty"`
	CreatedAt   time.Time         `json:"createdAt,omitempty"`
	Annotations map[string]string `json:"annotations,omitempty"`
}

type LicenseSpec 

type LicenseSpec struct {
	LicenseId  string            `json:"licenseId,omitempty"`
	LicensedTo string            `json:"licensedTo,omitempty"`
	Expires    int64             `json:"expires,omitempty"`
	Params     map[string]string `json:"params,omitempty"`
}

type LocalObjectReference 

type LocalObjectReference struct {
	Name string `json:"name"`
}

type Logging 

type Logging struct {
	Log4jLoggers map[string]string `json:"log4jLoggers,omitempty"`
}

type Namespace 

type Namespace struct {
	Kind       string             `json:"kind,omitempty"`
	ApiVersion string             `json:"apiVersion,omitempty"`
	Metadata   *NamespaceMetadata `json:"metadata"`
	Status     *NamespaceStatus   `json:"status,omitempty"`
}

type NamespaceMetadata 

type NamespaceMetadata struct {
	Id              string    `json:"id,omitempty"`
	Name            string    `json:"name"`
	CreatedAt       time.Time `json:"createdAt,omitempty"`
	ModifiedAt      time.Time `json:"modifiedAt,omitempty"`
	ResourceVersion int32     `json:"resourceVersion,omitempty"`
}

type NamespaceStatus 

type NamespaceStatus struct {
	State string `json:"state,omitempty"`
}

type NamespacesApiService 

type NamespacesApiService service

func (*NamespacesApiService) DeleteNamespace 

func (a *NamespacesApiService) DeleteNamespace(ctx context.Context, name string) (Namespace, *http.Response, error)

NamespacesApiService Delete a namespace by name

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param name

@return Namespace

func (*NamespacesApiService) GetNamespace 

func (a *NamespacesApiService) GetNamespace(ctx context.Context, name string) (Namespace, *http.Response, error)

NamespacesApiService Get a namespace by name

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param name

@return Namespace

func (*NamespacesApiService) ListNamespaces 

func (a *NamespacesApiService) ListNamespaces(ctx context.Context) (ResourceListNamespace, *http.Response, error)

NamespacesApiService List namespaces

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return ResourceListNamespace

func (*NamespacesApiService) PostNamespace 

func (a *NamespacesApiService) PostNamespace(ctx context.Context, localVarOptionals *PostNamespaceOpts) (Namespace, *http.Response, error)

type Pods 

type Pods struct {
	Annotations      map[string]string           `json:"annotations,omitempty"`
	NodeSelector     map[string]string           `json:"nodeSelector,omitempty"`
	SecurityContext  *core.SecurityContext       `json:"securityContext,omitempty"`
	Affinity         *core.Affinity              `json:"affinity,omitempty"`
	Tolerations      []core.Toleration           `json:"tolerations,omitempty"`
	VolumeMounts     []VolumeAndMount            `json:"volumeMounts,omitempty"`
	EnvVars          []core.EnvVar               `json:"envVars,omitempty"`
	ImagePullSecrets []core.LocalObjectReference `json:"imagePullSecrets,omitempty"`
}

type PostNamespaceOpts 

type PostNamespaceOpts struct {
	Body optional.Interface
}

type ResourceListDeployment 

type ResourceListDeployment struct {
	Kind       string                `json:"kind,omitempty"`
	ApiVersion string                `json:"apiVersion,omitempty"`
	Metadata   *ResourceListMetadata `json:"metadata,omitempty"`
	Items      []Deployment          `json:"items,omitempty"`
}

type ResourceListDeploymentTarget 

type ResourceListDeploymentTarget struct {
	Kind       string                `json:"kind,omitempty"`
	ApiVersion string                `json:"apiVersion,omitempty"`
	Metadata   *ResourceListMetadata `json:"metadata,omitempty"`
	Items      []DeploymentTarget    `json:"items,omitempty"`
}

type ResourceListEvent 

type ResourceListEvent struct {
	Kind       string                `json:"kind,omitempty"`
	ApiVersion string                `json:"apiVersion,omitempty"`
	Metadata   *ResourceListMetadata `json:"metadata,omitempty"`
	Items      []Event               `json:"items,omitempty"`
}

type ResourceListJob 

type ResourceListJob struct {
	Kind       string                `json:"kind,omitempty"`
	ApiVersion string                `json:"apiVersion,omitempty"`
	Metadata   *ResourceListMetadata `json:"metadata,omitempty"`
	Items      []Job                 `json:"items,omitempty"`
}

type ResourceListMetadata 

type ResourceListMetadata struct {
}

type ResourceListNamespace 

type ResourceListNamespace struct {
	Kind       string                `json:"kind,omitempty"`
	ApiVersion string                `json:"apiVersion,omitempty"`
	Metadata   *ResourceListMetadata `json:"metadata,omitempty"`
	Items      []Namespace           `json:"items,omitempty"`
}

type ResourceListRole 

type ResourceListRole struct {
	Kind       string                `json:"kind,omitempty"`
	ApiVersion string                `json:"apiVersion,omitempty"`
	Metadata   *ResourceListMetadata `json:"metadata,omitempty"`
	Items      []Role                `json:"items,omitempty"`
}

type ResourceListRoleBinding 

type ResourceListRoleBinding struct {
	Kind       string                `json:"kind,omitempty"`
	ApiVersion string                `json:"apiVersion,omitempty"`
	Metadata   *ResourceListMetadata `json:"metadata,omitempty"`
	Items      []RoleBinding         `json:"items,omitempty"`
}

type ResourceListSecretValue 

type ResourceListSecretValue struct {
	Kind       string                `json:"kind,omitempty"`
	ApiVersion string                `json:"apiVersion,omitempty"`
	Metadata   *ResourceListMetadata `json:"metadata,omitempty"`
	Items      []SecretValue         `json:"items,omitempty"`
}

type ResourceQuota 

type ResourceQuota struct {
	Kind       string               `json:"kind,omitempty"`
	ApiVersion string               `json:"apiVersion,omitempty"`
	Spec       *ResourceQuotaSpec   `json:"spec,omitempty"`
	Status     *ResourceQuotaStatus `json:"status,omitempty"`
}

type ResourceQuotaQuantity 

type ResourceQuotaQuantity struct {
	Cpu float64 `json:"cpu,omitempty"`
}

type ResourceQuotaSpec 

type ResourceQuotaSpec struct {
	Limits           *ResourceQuotaQuantity `json:"limits,omitempty"`
	ToleratedOveruse *ResourceQuotaQuantity `json:"toleratedOveruse,omitempty"`
	Type_            string                 `json:"type,omitempty"`
}

type ResourceQuotaStatus 

type ResourceQuotaStatus struct {
	Used *ResourceQuotaQuantity `json:"used,omitempty"`
}

type ResourceSpec 

type ResourceSpec struct {
	Cpu    float64 `json:"cpu,omitempty"`
	Memory string  `json:"memory,omitempty"`
}

type RevisionInformation 

type RevisionInformation struct {
	CommitShaLong  string `json:"commitShaLong,omitempty"`
	CommitShaShort string `json:"commitShaShort,omitempty"`
	BuildVersion   string `json:"buildVersion,omitempty"`
	BuildTime      string `json:"buildTime,omitempty"`
}

type Role 

type Role struct {
	Kind       string        `json:"kind,omitempty"`
	ApiVersion string        `json:"apiVersion,omitempty"`
	Metadata   *RoleMetadata `json:"metadata"`
	Spec       *RoleSpec     `json:"spec"`
}

type RoleBinding 

type RoleBinding struct {
	Kind       string               `json:"kind,omitempty"`
	ApiVersion string               `json:"apiVersion,omitempty"`
	Metadata   *RoleBindingMetadata `json:"metadata"`
	Spec       *RoleBindingSpec     `json:"spec"`
}

type RoleBindingMetadata 

type RoleBindingMetadata struct {
	Id              string            `json:"id,omitempty"`
	Name            string            `json:"name"`
	Namespace       string            `json:"namespace,omitempty"`
	CreatedAt       time.Time         `json:"createdAt,omitempty"`
	ModifiedAt      time.Time         `json:"modifiedAt,omitempty"`
	Labels          map[string]string `json:"labels,omitempty"`
	ResourceVersion int32             `json:"resourceVersion,omitempty"`
}

type RoleBindingRoleRef 

type RoleBindingRoleRef struct {
	Kind string `json:"kind"`
	Name string `json:"name"`
}

type RoleBindingSpec 

type RoleBindingSpec struct {
	Subjects *IterableRoleBindingSubject `json:"subjects"`
	RoleRef  *RoleBindingRoleRef         `json:"roleRef"`
}

type RoleMetadata 

type RoleMetadata struct {
	Id              string            `json:"id,omitempty"`
	Name            string            `json:"name"`
	Namespace       string            `json:"namespace,omitempty"`
	CreatedAt       time.Time         `json:"createdAt,omitempty"`
	ModifiedAt      time.Time         `json:"modifiedAt,omitempty"`
	Labels          map[string]string `json:"labels,omitempty"`
	ResourceVersion int32             `json:"resourceVersion,omitempty"`
}

type RoleSpec 

type RoleSpec struct {
	Rules *IterableRoleRule `json:"rules"`
}

type Savepoint 

type Savepoint struct {
	Kind       string             `json:"kind,omitempty"`
	ApiVersion string             `json:"apiVersion,omitempty"`
	Metadata   *SavepointMetadata `json:"metadata"`
	Status     *SavepointStatus   `json:"status"`
	Spec       *SavepointSpec     `json:"spec"`
}

type SavepointMetadata 

type SavepointMetadata struct {
	Id              string            `json:"id,omitempty"`
	CreatedAt       time.Time         `json:"createdAt,omitempty"`
	ModifiedAt      time.Time         `json:"modifiedAt,omitempty"`
	DeploymentId    string            `json:"deploymentId"`
	JobId           string            `json:"jobId,omitempty"`
	Origin          string            `json:"origin,omitempty"`
	Annotations     map[string]string `json:"annotations,omitempty"`
	ResourceVersion int32             `json:"resourceVersion,omitempty"`
	Namespace       string            `json:"namespace,omitempty"`
}

type SavepointSpec 

type SavepointSpec struct {
	SavepointLocation string `json:"savepointLocation"`
	FlinkSavepointId  string `json:"flinkSavepointId"`
}

type SavepointStatus 

type SavepointStatus struct {
	State   string   `json:"state"`
	Failure *Failure `json:"failure,omitempty"`
}

type SavepointsApiService 

type SavepointsApiService service

func (*SavepointsApiService) CreateSavepoint 

func (a *SavepointsApiService) CreateSavepoint(ctx context.Context, namespace string, body Savepoint) (Savepoint, *http.Response, error)

SavepointsApiService Create a new savepoint

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param body

@return Savepoint

func (*SavepointsApiService) GetSavepoint 

func (a *SavepointsApiService) GetSavepoint(ctx context.Context, namespace string, savepointId string) (Savepoint, *http.Response, error)

SavepointsApiService Get a savepoint by id

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param savepointId

@return Savepoint

func (*SavepointsApiService) GetSavepoints 

func (a *SavepointsApiService) GetSavepoints(ctx context.Context, namespace string, localVarOptionals *GetSavepointsOpts) ([]Savepoint, *http.Response, error)

type SecretValue 

type SecretValue struct {
	Kind       string               `json:"kind,omitempty"`
	ApiVersion string               `json:"apiVersion,omitempty"`
	Metadata   *SecretValueMetadata `json:"metadata"`
	Spec       *SecretValueSpec     `json:"spec"`
}

type SecretValueMetadata 

type SecretValueMetadata struct {
	Id              string            `json:"id,omitempty"`
	Name            string            `json:"name"`
	Namespace       string            `json:"namespace,omitempty"`
	CreatedAt       time.Time         `json:"createdAt,omitempty"`
	ModifiedAt      time.Time         `json:"modifiedAt,omitempty"`
	ResourceVersion int32             `json:"resourceVersion,omitempty"`
	Labels          map[string]string `json:"labels,omitempty"`
	Annotations     map[string]string `json:"annotations,omitempty"`
}

type SecretValueSpec 

type SecretValueSpec struct {
	Kind string `json:"kind,omitempty"`
}

type SecretValuesApiService 

type SecretValuesApiService service

func (*SecretValuesApiService) CreateSecretValue 

func (a *SecretValuesApiService) CreateSecretValue(ctx context.Context, namespace string, body SecretValue) (SecretValue, *http.Response, error)

SecretValuesApiService Create a secret value

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param body

@return SecretValue

func (*SecretValuesApiService) DeleteSecretValue 

func (a *SecretValuesApiService) DeleteSecretValue(ctx context.Context, namespace string, name string) (SecretValue, *http.Response, error)

SecretValuesApiService Delete a secret value

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param name

@return SecretValue

func (*SecretValuesApiService) GetSecretValue 

func (a *SecretValuesApiService) GetSecretValue(ctx context.Context, namespace string, name string) (SecretValue, *http.Response, error)

SecretValuesApiService Get a secret value by name

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param name

@return SecretValue

func (*SecretValuesApiService) GetSecretValues 

func (a *SecretValuesApiService) GetSecretValues(ctx context.Context, namespace string) (ResourceListSecretValue, *http.Response, error)

SecretValuesApiService List all secrets values

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace

@return ResourceListSecretValue

func (*SecretValuesApiService) UpdateSecretValue 

func (a *SecretValuesApiService) UpdateSecretValue(ctx context.Context, namespace string, name string, body SecretValue) (SecretValue, *http.Response, error)

SecretValuesApiService Update a secret value

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
  • @param namespace
  • @param name
  • @param body

@return SecretValue

type StatusApiService 

type StatusApiService service

func (*StatusApiService) GetStatus 

func (a *StatusApiService) GetStatus(ctx context.Context) (*http.Response, error)

StatusApiService Check that the server is running

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

func (*StatusApiService) GetSystemInfo 

func (a *StatusApiService) GetSystemInfo(ctx context.Context) (SystemInformation, *http.Response, error)

StatusApiService Get system's information

  • @param ctx context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().

@return SystemInformation

type SystemInformation 

type SystemInformation struct {
	Status     *SystemInformationStatus `json:"status,omitempty"`
	Kind       string                   `json:"kind,omitempty"`
	ApiVersion string                   `json:"apiVersion,omitempty"`
}

type SystemInformationStatus 

type SystemInformationStatus struct {
	JvmVersion          string               `json:"jvmVersion,omitempty"`
	RevisionInformation *RevisionInformation `json:"revisionInformation,omitempty"`
	ResourceQuota       *ResourceQuota       `json:"resourceQuota,omitempty"`
	License             *License             `json:"license,omitempty"`
}

type VolumeAndMount 

type VolumeAndMount struct {
	Name        string            `json:"name,omitempty"`
	Volume      *core.Volume      `json:"volume,omitempty"`
	VolumeMount *core.VolumeMount `json:"volumeMount,omitempty"`
}

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.