appmanagerapi

package
v0.8.1 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

README

Go API client for appManagerApiClient

Application Manager APIs to control Apache Flink jobs

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: 2.1.0
  • Package version: 1.0.0
  • Build package: io.swagger.codegen.languages.GoClientCodegen For more information, please visit https://www.ververica.com

Installation

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

import "./appManagerApiClient"

Documentation for API Endpoints

All URIs are relative to https://localhost:8081

Class Method HTTP request Description
DeploymentDefaultsResourceApi GetDeploymentDefaultsUsingGET Get /api/v1/namespaces/{namespace}/deployment-defaults Get deployment defaults
DeploymentDefaultsResourceApi UpdateDeploymentDefaultsUsingPATCH Patch /api/v1/namespaces/{namespace}/deployment-defaults Update a deployment defaults
DeploymentResourceApi CreateDeploymentUsingPOST Post /api/v1/namespaces/{namespace}/deployments Create a deployment
DeploymentResourceApi DeleteDeploymentUsingDELETE Delete /api/v1/namespaces/{namespace}/deployments/{deploymentId} Delete deployment
DeploymentResourceApi GetDeploymentUsingGET Get /api/v1/namespaces/{namespace}/deployments/{deploymentId} Get a deployment by id
DeploymentResourceApi GetDeploymentsUsingGET Get /api/v1/namespaces/{namespace}/deployments List all deployments
DeploymentResourceApi UpdateDeploymentUsingPATCH Patch /api/v1/namespaces/{namespace}/deployments/{deploymentId} Update a deployment
DeploymentTargetResourceApi CreateDeploymentTargetUsingPOST Post /api/v1/namespaces/{namespace}/deployment-targets Create a deployment target
DeploymentTargetResourceApi DeleteDeploymentTargetUsingDELETE Delete /api/v1/namespaces/{namespace}/deployment-targets/{name} Delete a deployment target
DeploymentTargetResourceApi GetDeploymentTargetUsingGET Get /api/v1/namespaces/{namespace}/deployment-targets/{name} Get a deployment target by name
DeploymentTargetResourceApi GetDeploymentTargetsUsingGET Get /api/v1/namespaces/{namespace}/deployment-targets List all deployment targets
EventResourceApi GetEventsUsingGET Get /api/v1/namespaces/{namespace}/events Filter all events for a deployment or job
JobResourceApi GetJobUsingGET Get /api/v1/namespaces/{namespace}/jobs/{jobId} Get a job by id
JobResourceApi GetJobsUsingGET Get /api/v1/namespaces/{namespace}/jobs List all jobs. Can be filtered by DeploymentId
SavepointResourceApi CreateSavepointUsingPOST Post /api/v1/namespaces/{namespace}/savepoints Create a new savepoint
SavepointResourceApi GetSavepointUsingGET Get /api/v1/namespaces/{namespace}/savepoints/{savepointId} Get a savepoint by id
SavepointResourceApi GetSavepointsUsingGET Get /api/v1/namespaces/{namespace}/savepoints List all savepoints. Can be filtered by DeploymentId
SecretValueResourceApi CreateSecretValueUsingPOST Post /api/v1/namespaces/{namespace}/secret-values Create a secret value
SecretValueResourceApi DeleteSecretValueUsingDELETE Delete /api/v1/namespaces/{namespace}/secret-values/{name} Delete a secret value
SecretValueResourceApi GetSecretValueUsingGET Get /api/v1/namespaces/{namespace}/secret-values/{name} Get a secret value by name
SecretValueResourceApi GetSecretValuesUsingGET Get /api/v1/namespaces/{namespace}/secret-values List all secrets values
SecretValueResourceApi UpdateSecretValueUsingPATCH Patch /api/v1/namespaces/{namespace}/secret-values/{name} Update a secret value
StatusResourceApi GetStatusUsingGET Get /api/v1/status Check that the server is running
StatusResourceApi GetSystemInfoUsingGET Get /api/v1/status/system-info Get system's information

Documentation For Models

Documentation For Authorization

Endpoints do not require authorization.

Author

platform@ververica.com

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")

	// ContextAPIKey takes an APIKey as authentication for the request
	ContextAPIKey = contextKey("apikey")
)

Functions

This section is empty.

Types

type APIClient 

type APIClient struct {
	DeploymentDefaultsResourceApi *DeploymentDefaultsResourceApiService

	DeploymentResourceApi *DeploymentResourceApiService

	DeploymentTargetResourceApi *DeploymentTargetResourceApiService

	EventResourceApi *EventResourceApiService

	JobResourceApi *JobResourceApiService

	SavepointResourceApi *SavepointResourceApiService

	SecretValueResourceApi *SecretValueResourceApiService

	StatusResourceApi *StatusResourceApiService
	// contains filtered or unexported fields
}

APIClient manages communication with the Application Manager API API v2.1.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

type APIKey 

type APIKey struct {
	Key    string
	Prefix string
}

APIKey provides API key based authentication to a request passed via context using ContextAPIKey

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 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 {
	ApiVersion string              `json:"apiVersion,omitempty"`
	Kind       string              `json:"kind,omitempty"`
	Metadata   *DeploymentMetadata `json:"metadata,omitempty"`
	Spec       *DeploymentSpec     `json:"spec,omitempty"`
	Status     *DeploymentStatus   `json:"status,omitempty"`
}

type DeploymentCondition 

type DeploymentCondition struct {
	LastTransitionTime *time.Time `json:"lastTransitionTime,omitempty"`
	LastUpdateTime     *time.Time `json:"lastUpdateTime,omitempty"`
	Message            string     `json:"message,omitempty"`
	Reason             string     `json:"reason,omitempty"`
	Status             string     `json:"status,omitempty"`
	Type_              string     `json:"type,omitempty"`
}

type DeploymentDefaults 

type DeploymentDefaults struct {
	ApiVersion string                      `json:"apiVersion,omitempty"`
	Kind       string                      `json:"kind,omitempty"`
	Metadata   *DeploymentDefaultsMetadata `json:"metadata,omitempty"`
	Spec       *DeploymentSpec             `json:"spec,omitempty"`
}

type DeploymentDefaultsMetadata 

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

type DeploymentDefaultsResourceApiService 

type DeploymentDefaultsResourceApiService service

func (*DeploymentDefaultsResourceApiService) GetDeploymentDefaultsUsingGET 

func (a *DeploymentDefaultsResourceApiService) GetDeploymentDefaultsUsingGET(ctx context.Context, namespace string) (DeploymentDefaults, *http.Response, error)

DeploymentDefaultsResourceApiService Get deployment defaults

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

@return DeploymentDefaults

func (*DeploymentDefaultsResourceApiService) UpdateDeploymentDefaultsUsingPATCH 

func (a *DeploymentDefaultsResourceApiService) UpdateDeploymentDefaultsUsingPATCH(ctx context.Context, body DeploymentDefaults, namespace string) (DeploymentDefaults, *http.Response, error)

DeploymentDefaultsResourceApiService Update a deployment defaults

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

@return DeploymentDefaults

type DeploymentMetadata 

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

type DeploymentResourceApiService 

type DeploymentResourceApiService service

func (*DeploymentResourceApiService) CreateDeploymentUsingPOST 

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

DeploymentResourceApiService Create a deployment

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

@return Deployment

func (*DeploymentResourceApiService) DeleteDeploymentUsingDELETE 

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

DeploymentResourceApiService 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 deploymentId deploymentId
  • @param namespace namespace

@return Deployment

func (*DeploymentResourceApiService) GetDeploymentUsingGET 

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

DeploymentResourceApiService Get a deployment by id

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

@return Deployment

func (*DeploymentResourceApiService) GetDeploymentsUsingGET 

func (a *DeploymentResourceApiService) GetDeploymentsUsingGET(ctx context.Context, namespace string, localVarOptionals *GetDeploymentsUsingGETOpts) (ResourceListOfDeployment, *http.Response, error)

func (*DeploymentResourceApiService) UpdateDeploymentUsingPATCH 

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

DeploymentResourceApiService Update a deployment

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

@return Deployment

type DeploymentRestoreStrategy 

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

type DeploymentSpec 

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

type DeploymentStatus 

type DeploymentStatus struct {
	Running *DeploymentStatusRunning `json:"running,omitempty"`
	State   string                   `json:"state,omitempty"`
}

type DeploymentStatusRunning 

type DeploymentStatusRunning struct {
	Conditions     []DeploymentCondition `json:"conditions,omitempty"`
	JobId          string                `json:"jobId,omitempty"`
	TransitionTime *time.Time            `json:"transitionTime,omitempty"`
}

type DeploymentTarget 

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

type DeploymentTargetMetadata 

type DeploymentTargetMetadata 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"`
	Annotations     map[string]string `json:"annotations,omitempty"`
	Labels          map[string]string `json:"labels,omitempty"`
	ResourceVersion int32             `json:"resourceVersion,omitempty"`
}

type DeploymentTargetResourceApiService 

type DeploymentTargetResourceApiService service

func (*DeploymentTargetResourceApiService) CreateDeploymentTargetUsingPOST 

func (a *DeploymentTargetResourceApiService) CreateDeploymentTargetUsingPOST(ctx context.Context, deploymentTarget DeploymentTarget, namespace string) (DeploymentTarget, *http.Response, error)

DeploymentTargetResourceApiService Create a deployment target

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

@return DeploymentTarget

func (*DeploymentTargetResourceApiService) DeleteDeploymentTargetUsingDELETE 

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

DeploymentTargetResourceApiService Delete a deployment target

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

@return DeploymentTarget

func (*DeploymentTargetResourceApiService) GetDeploymentTargetUsingGET 

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

DeploymentTargetResourceApiService 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 name name
  • @param namespace namespace

@return DeploymentTarget

func (*DeploymentTargetResourceApiService) GetDeploymentTargetsUsingGET 

func (a *DeploymentTargetResourceApiService) GetDeploymentTargetsUsingGET(ctx context.Context, namespace string) (ResourceListOfDeploymentTarget, *http.Response, error)

DeploymentTargetResourceApiService List all deployment targets

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

@return ResourceListOfDeploymentTarget

type DeploymentTargetSpec 

type DeploymentTargetSpec struct {
	Kubernetes *KubernetesTarget `json:"kubernetes"`
}

type DeploymentTemplate 

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

type DeploymentTemplateMetadata 

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

type DeploymentTemplateSpec 

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

type DeploymentUpgradeStrategy 

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

type EnvVar 

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

type Event 

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

type EventMetadata 

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

type EventResourceApiService 

type EventResourceApiService service

func (*EventResourceApiService) GetEventsUsingGET 

func (a *EventResourceApiService) GetEventsUsingGET(ctx context.Context, namespace string, localVarOptionals *GetEventsUsingGETOpts) (ResourceListOfEvent, *http.Response, error)

type EventSpec 

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

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

type GetDeploymentsUsingGETOpts 

type GetDeploymentsUsingGETOpts struct {
	LabelSelector optional.String
}

type GetEventsUsingGETOpts 

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

type GetJobsUsingGETOpts 

type GetJobsUsingGETOpts struct {
	DeploymentId optional.Interface
}

type GetSavepointsUsingGETOpts 

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

type Job 

type Job struct {
	ApiVersion string       `json:"apiVersion,omitempty"`
	Kind       string       `json:"kind,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 {
	Annotations     map[string]string `json:"annotations,omitempty"`
	CreatedAt       time.Time         `json:"createdAt,omitempty"`
	DeploymentId    string            `json:"deploymentId,omitempty"`
	DeploymentName  string            `json:"deploymentName,omitempty"`
	Id              string            `json:"id,omitempty"`
	ModifiedAt      time.Time         `json:"modifiedAt,omitempty"`
	Namespace       string            `json:"namespace,omitempty"`
	ResourceVersion int32             `json:"resourceVersion,omitempty"`
	TerminatedAt    time.Time         `json:"terminatedAt,omitempty"`
}

type JobResourceApiService 

type JobResourceApiService service

func (*JobResourceApiService) GetJobUsingGET 

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

JobResourceApiService Get a job by id

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

@return Job

func (*JobResourceApiService) GetJobsUsingGET 

func (a *JobResourceApiService) GetJobsUsingGET(ctx context.Context, namespace string, localVarOptionals *GetJobsUsingGETOpts) (ResourceListOfJob, *http.Response, error)

type JobSpec 

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

type JobStatus 

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

type JobStatusStarted 

type JobStatusStarted struct {
	FlinkJobId               string     `json:"flinkJobId,omitempty"`
	LastUpdateTime           *time.Time `json:"lastUpdateTime,omitempty"`
	ObservedFlinkJobRestarts int32      `json:"observedFlinkJobRestarts,omitempty"`
	ObservedFlinkJobStatus   string     `json:"observedFlinkJobStatus,omitempty"`
	StartedAt                time.Time  `json:"startedAt,omitempty"`
}

type JsonNode 

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

type KubernetesOptions 

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

type KubernetesTarget 

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

type LocalObjectReference 

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

type Logging 

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

type ObjectNode 

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

type Pods 

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

type ResourceListMetadata 

type ResourceListMetadata struct {
}

type ResourceListOfDeployment 

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

type ResourceListOfDeploymentTarget 

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

type ResourceListOfEvent 

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

type ResourceListOfJob 

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

type ResourceListOfSavepoint 

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

type ResourceListOfSecretValue 

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

type ResourceQuota 

type ResourceQuota struct {
	ApiVersion string               `json:"apiVersion,omitempty"`
	Kind       string               `json:"kind,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 {
	BuildTime      string `json:"buildTime,omitempty"`
	BuildVersion   string `json:"buildVersion,omitempty"`
	CommitShaLong  string `json:"commitShaLong,omitempty"`
	CommitShaShort string `json:"commitShaShort,omitempty"`
}

type Savepoint 

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

type SavepointMetadata 

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

type SavepointResourceApiService 

type SavepointResourceApiService service

func (*SavepointResourceApiService) CreateSavepointUsingPOST 

func (a *SavepointResourceApiService) CreateSavepointUsingPOST(ctx context.Context, namespace string, savepointChange Savepoint) (Savepoint, *http.Response, error)

SavepointResourceApiService Create a new savepoint

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

@return Savepoint

func (*SavepointResourceApiService) GetSavepointUsingGET 

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

SavepointResourceApiService 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 namespace
  • @param savepointId savepointId

@return Savepoint

func (*SavepointResourceApiService) GetSavepointsUsingGET 

func (a *SavepointResourceApiService) GetSavepointsUsingGET(ctx context.Context, namespace string, localVarOptionals *GetSavepointsUsingGETOpts) (ResourceListOfSavepoint, *http.Response, error)

type SavepointSpec 

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

type SavepointStatus 

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

type SecretValue 

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

type SecretValueMetadata 

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

type SecretValueResourceApiService 

type SecretValueResourceApiService service

func (*SecretValueResourceApiService) CreateSecretValueUsingPOST 

func (a *SecretValueResourceApiService) CreateSecretValueUsingPOST(ctx context.Context, namespace string, secretValue SecretValue) (SecretValue, *http.Response, error)

SecretValueResourceApiService Create a secret value

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

@return SecretValue

func (*SecretValueResourceApiService) DeleteSecretValueUsingDELETE 

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

SecretValueResourceApiService Delete a secret value

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

@return SecretValue

func (*SecretValueResourceApiService) GetSecretValueUsingGET 

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

SecretValueResourceApiService 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 name name
  • @param namespace namespace

@return SecretValue

func (*SecretValueResourceApiService) GetSecretValuesUsingGET 

func (a *SecretValueResourceApiService) GetSecretValuesUsingGET(ctx context.Context, namespace string) (ResourceListOfSecretValue, *http.Response, error)

SecretValueResourceApiService List all secrets values

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

@return ResourceListOfSecretValue

func (*SecretValueResourceApiService) UpdateSecretValueUsingPATCH 

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

SecretValueResourceApiService Update a secret value

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

@return SecretValue

type SecretValueSpec 

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

type StatusResourceApiService 

type StatusResourceApiService service

func (*StatusResourceApiService) GetStatusUsingGET 

func (a *StatusResourceApiService) GetStatusUsingGET(ctx context.Context) (interface{}, *http.Response, error)

StatusResourceApiService Check that the server is running

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

@return interface{}

func (*StatusResourceApiService) GetSystemInfoUsingGET 

func (a *StatusResourceApiService) GetSystemInfoUsingGET(ctx context.Context) (SystemInformation, *http.Response, error)

StatusResourceApiService 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 {
	ApiVersion string                   `json:"apiVersion,omitempty"`
	Kind       string                   `json:"kind,omitempty"`
	Status     *SystemInformationStatus `json:"status,omitempty"`
}

type SystemInformationStatus 

type SystemInformationStatus struct {
	JvmVersion          string               `json:"jvmVersion,omitempty"`
	ResourceQuota       *ResourceQuota       `json:"resourceQuota,omitempty"`
	RevisionInformation *RevisionInformation `json:"revisionInformation,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.