Versions in this module Expand all Collapse all v0 v0.6.0 Dec 23, 2019 v0.5.0 Dec 22, 2019 Changes in this version + var ContextAccessToken = contextKey("accesstoken") + var ContextBasicAuth = contextKey("basic") + var ContextOAuth2 = contextKey("token") + func CacheExpires(r *http.Response) time.Time + type APIClient struct + DeploymentTargetsApi *DeploymentTargetsApiService + DeploymentsApi *DeploymentsApiService + EventsApi *EventsApiService + JobsApi *JobsApiService + NamespacesApi *NamespacesApiService + SavepointsApi *SavepointsApiService + SecretValuesApi *SecretValuesApiService + StatusApi *StatusApiService + func NewAPIClient(cfg *Configuration) *APIClient + func (c *APIClient) ChangeBasePath(path string) + func (c *APIClient) Configuration() Configuration + type APIResponse struct + Message string + Method string + Operation string + Payload []byte + RequestURL string + func NewAPIResponse(r *http.Response) *APIResponse + func NewAPIResponseWithError(errorMessage string) *APIResponse + type Any interface + type ApiToken struct + ApiVersion string + Kind string + Metadata *ApiTokenMetadata + Spec *ApiTokenSpec + type ApiTokenMetadata struct + CreatedAt time.Time + Id string + ModifiedAt time.Time + Name string + type ApiTokenSpec struct + Token string + type Artifact struct + EntryClass string + FlinkImageRegistry string + FlinkImageRepository string + FlinkImageTag string + FlinkVersion string + JarUri string + Kind string + MainArgs string + type BasicAuth struct + Password string + UserName string + type Configuration struct + BasePath string + DefaultHeader map[string]string + HTTPClient *http.Client + Host string + Scheme string + UserAgent string + func NewConfiguration() *Configuration + func (c *Configuration) AddDefaultHeader(key string, value string) + type Deployment struct + ApiVersion string + Kind string + Metadata *DeploymentMetadata + Spec *DeploymentSpec + Status *DeploymentStatus + type DeploymentMetadata struct + Annotations map[string]string + CreatedAt time.Time + Id string + Labels map[string]string + ModifiedAt time.Time + Name string + Namespace string + ResourceVersion int32 + type DeploymentRestoreStrategy struct + AllowNonRestoredState bool + Kind string + type DeploymentSpec struct + DeploymentTargetId string + MaxJobCreationAttempts int32 + MaxSavepointCreationAttempts int32 + RestoreStrategy *DeploymentRestoreStrategy + StartFromSavepoint *DeploymentStartFromSavepoint + State string + Template *DeploymentTemplate + UpgradeStrategy *DeploymentUpgradeStrategy + type DeploymentStartFromSavepoint struct + Kind string + type DeploymentStatus struct + State string + type DeploymentTarget struct + ApiVersion string + Kind string + Metadata *DeploymentTargetMetadata + Spec *DeploymentTargetSpec + type DeploymentTargetMetadata struct + Annotations map[string]string + CreatedAt time.Time + Id string + Labels map[string]string + ModifiedAt time.Time + Name string + Namespace string + ResourceVersion int32 + type DeploymentTargetSpec struct + DeploymentPatchSet []JsonPatchGeneric + Kubernetes *KubernetesTarget + type DeploymentTargetsApiService service + func (a *DeploymentTargetsApiService) CreateDeploymentTarget(ctx context.Context, namespace string, body DeploymentTarget) (DeploymentTarget, *http.Response, error) + func (a *DeploymentTargetsApiService) DeleteDeploymentTarget(ctx context.Context, namespace string, name string) (DeploymentTarget, *http.Response, error) + func (a *DeploymentTargetsApiService) GetDeploymentTarget(ctx context.Context, namespace string, name string) (DeploymentTarget, *http.Response, error) + func (a *DeploymentTargetsApiService) GetDeploymentTargets(ctx context.Context, namespace string) (ResourceListDeploymentTarget, *http.Response, error) + type DeploymentTemplate struct + Metadata *DeploymentTemplateMetadata + Spec *DeploymentTemplateSpec + type DeploymentTemplateMetadata struct + Annotations map[string]string + type DeploymentTemplateSpec struct + Artifact *Artifact + FlinkConfiguration map[string]string + Kubernetes *KubernetesOptions + Logging *Logging + NumberOfTaskManagers int32 + Parallelism int32 + Resources map[string]ResourceSpec + type DeploymentUpgradeStrategy struct + Kind string + type DeploymentsApiService service + func (a *DeploymentsApiService) CreateDeployment(ctx context.Context, namespace string, body Deployment) (Deployment, *http.Response, error) + func (a *DeploymentsApiService) DeleteDeployment(ctx context.Context, namespace string, deploymentId string) (Deployment, *http.Response, error) + func (a *DeploymentsApiService) GetDeployment(ctx context.Context, namespace string, deploymentId string) (Deployment, *http.Response, error) + func (a *DeploymentsApiService) GetDeployments(ctx context.Context, namespace string, localVarOptionals *GetDeploymentsOpts) (ResourceListDeployment, *http.Response, error) + func (a *DeploymentsApiService) UpdateDeployment(ctx context.Context, namespace string, deploymentId string, body Deployment) (Deployment, *http.Response, error) + type EnvVar struct + Name string + Value string + ValueFrom *JsonNode + type Event struct + ApiVersion string + Kind string + Metadata *EventMetadata + Spec *EventSpec + type EventMetadata struct + CreatedAt time.Time + DeploymentId string + Id string + JobId string + Name string + Namespace string + ResourceVersion int32 + type EventSpec struct + Message string + type EventsApiService service + func (a *EventsApiService) GetEvents(ctx context.Context, namespace string, localVarOptionals *GetEventsOpts) (ResourceListEvent, *http.Response, error) + type Failure struct + FailedAt time.Time + Message string + Reason string + type GenericSwaggerError struct + func (e GenericSwaggerError) Body() []byte + func (e GenericSwaggerError) Error() string + func (e GenericSwaggerError) Model() interface{} + func (e GenericSwaggerError) StatusCode() int + func (e GenericSwaggerError) WithStatusCode(statusCode int) GenericSwaggerError + type GetDeploymentsOpts struct + LabelSelector optional.String + type GetEventsOpts struct + DeploymentId optional.Interface + JobId optional.Interface + type GetJobsOpts struct + DeploymentId optional.Interface + type GetSavepointsOpts struct + DeploymentId optional.Interface + JobId optional.Interface + type IterableRoleBindingSubject struct + type IterableRoleRule struct + type Job struct + ApiVersion string + Kind string + Metadata *JobMetadata + Spec *JobSpec + Status *JobStatus + type JobDeploymentTarget struct + Kubernetes *KubernetesTarget + type JobMetadata struct + Annotations map[string]string + CreatedAt time.Time + DeploymentId string + Id string + ModifiedAt time.Time + Namespace string + ResourceVersion int32 + TerminatedAt int64 + type JobSpec struct + AllowNonRestoredState bool + Artifact *Artifact + DeploymentTarget *JobDeploymentTarget + FlinkConfiguration map[string]string + Kubernetes *KubernetesOptions + Logging *Logging + NumberOfTaskManagers int32 + Parallelism int32 + Resources map[string]ResourceSpec + SavepointLocation string + type JobStatus struct + Failure *Failure + State string + type JobsApiService service + func (a *JobsApiService) GetJob(ctx context.Context, namespace string, jobId string) (Job, *http.Response, error) + func (a *JobsApiService) GetJobs(ctx context.Context, namespace string, localVarOptionals *GetJobsOpts) (ResourceListJob, *http.Response, error) + type JsonNode struct + Array bool + BigDecimal bool + BigInteger bool + Binary bool + Boolean bool + ContainerNode bool + Double bool + Float bool + FloatingPointNumber bool + Int_ bool + IntegralNumber bool + Long bool + MissingNode bool + NodeType string + Null bool + Number bool + Object bool + Pojo bool + Short bool + Textual bool + ValueNode bool + type JsonPatchGeneric struct + From string + Op string + Path string + Value Any + type KubernetesOptions struct + Pods *Pods + type KubernetesTarget struct + Namespace string + type License struct + ApiVersion string + Kind string + Metadata *LicenseMetadata + Spec *LicenseSpec + type LicenseMetadata struct + Annotations map[string]string + CreatedAt time.Time + Id string + type LicenseSpec struct + Expires int64 + LicenseId string + LicensedTo string + Params map[string]string + type LocalObjectReference struct + Name string + type Logging struct + Log4jLoggers map[string]string + type Namespace struct + ApiVersion string + Kind string + Metadata *NamespaceMetadata + Status *NamespaceStatus + type NamespaceMetadata struct + CreatedAt time.Time + Id string + ModifiedAt time.Time + Name string + ResourceVersion int32 + type NamespaceStatus struct + State string + type NamespacesApiService service + func (a *NamespacesApiService) DeleteNamespace(ctx context.Context, name string) (Namespace, *http.Response, error) + func (a *NamespacesApiService) GetNamespace(ctx context.Context, name string) (Namespace, *http.Response, error) + func (a *NamespacesApiService) ListNamespaces(ctx context.Context) (ResourceListNamespace, *http.Response, error) + func (a *NamespacesApiService) PostNamespace(ctx context.Context, localVarOptionals *PostNamespaceOpts) (Namespace, *http.Response, error) + type Pods struct + Affinity *core.Affinity + Annotations map[string]string + EnvVars []core.EnvVar + ImagePullSecrets []core.LocalObjectReference + NodeSelector map[string]string + SecurityContext *core.SecurityContext + Tolerations []core.Toleration + VolumeMounts []VolumeAndMount + type PostNamespaceOpts struct + Body optional.Interface + type ResourceListDeployment struct + ApiVersion string + Items []Deployment + Kind string + Metadata *ResourceListMetadata + type ResourceListDeploymentTarget struct + ApiVersion string + Items []DeploymentTarget + Kind string + Metadata *ResourceListMetadata + type ResourceListEvent struct + ApiVersion string + Items []Event + Kind string + Metadata *ResourceListMetadata + type ResourceListJob struct + ApiVersion string + Items []Job + Kind string + Metadata *ResourceListMetadata + type ResourceListMetadata struct + type ResourceListNamespace struct + ApiVersion string + Items []Namespace + Kind string + Metadata *ResourceListMetadata + type ResourceListRole struct + ApiVersion string + Items []Role + Kind string + Metadata *ResourceListMetadata + type ResourceListRoleBinding struct + ApiVersion string + Items []RoleBinding + Kind string + Metadata *ResourceListMetadata + type ResourceListSecretValue struct + ApiVersion string + Items []SecretValue + Kind string + Metadata *ResourceListMetadata + type ResourceQuota struct + ApiVersion string + Kind string + Spec *ResourceQuotaSpec + Status *ResourceQuotaStatus + type ResourceQuotaQuantity struct + Cpu float64 + type ResourceQuotaSpec struct + Limits *ResourceQuotaQuantity + ToleratedOveruse *ResourceQuotaQuantity + Type_ string + type ResourceQuotaStatus struct + Used *ResourceQuotaQuantity + type ResourceSpec struct + Cpu float64 + Memory string + type RevisionInformation struct + BuildTime string + BuildVersion string + CommitShaLong string + CommitShaShort string + type Role struct + ApiVersion string + Kind string + Metadata *RoleMetadata + Spec *RoleSpec + type RoleBinding struct + ApiVersion string + Kind string + Metadata *RoleBindingMetadata + Spec *RoleBindingSpec + type RoleBindingMetadata struct + CreatedAt time.Time + Id string + Labels map[string]string + ModifiedAt time.Time + Name string + Namespace string + ResourceVersion int32 + type RoleBindingRoleRef struct + Kind string + Name string + type RoleBindingSpec struct + RoleRef *RoleBindingRoleRef + Subjects *IterableRoleBindingSubject + type RoleMetadata struct + CreatedAt time.Time + Id string + Labels map[string]string + ModifiedAt time.Time + Name string + Namespace string + ResourceVersion int32 + type RoleSpec struct + Rules *IterableRoleRule + type Savepoint struct + ApiVersion string + Kind string + Metadata *SavepointMetadata + Spec *SavepointSpec + Status *SavepointStatus + type SavepointMetadata struct + Annotations map[string]string + CreatedAt time.Time + DeploymentId string + Id string + JobId string + ModifiedAt time.Time + Namespace string + Origin string + ResourceVersion int32 + type SavepointSpec struct + FlinkSavepointId string + SavepointLocation string + type SavepointStatus struct + Failure *Failure + State string + type SavepointsApiService service + func (a *SavepointsApiService) CreateSavepoint(ctx context.Context, namespace string, body Savepoint) (Savepoint, *http.Response, error) + func (a *SavepointsApiService) GetSavepoint(ctx context.Context, namespace string, savepointId string) (Savepoint, *http.Response, error) + func (a *SavepointsApiService) GetSavepoints(ctx context.Context, namespace string, localVarOptionals *GetSavepointsOpts) ([]Savepoint, *http.Response, error) + type SecretValue struct + ApiVersion string + Kind string + Metadata *SecretValueMetadata + Spec *SecretValueSpec + type SecretValueMetadata struct + Annotations map[string]string + CreatedAt time.Time + Id string + Labels map[string]string + ModifiedAt time.Time + Name string + Namespace string + ResourceVersion int32 + type SecretValueSpec struct + Kind string + type SecretValuesApiService service + func (a *SecretValuesApiService) CreateSecretValue(ctx context.Context, namespace string, body SecretValue) (SecretValue, *http.Response, error) + func (a *SecretValuesApiService) DeleteSecretValue(ctx context.Context, namespace string, name string) (SecretValue, *http.Response, error) + func (a *SecretValuesApiService) GetSecretValue(ctx context.Context, namespace string, name string) (SecretValue, *http.Response, error) + func (a *SecretValuesApiService) GetSecretValues(ctx context.Context, namespace string) (ResourceListSecretValue, *http.Response, error) + func (a *SecretValuesApiService) UpdateSecretValue(ctx context.Context, namespace string, name string, body SecretValue) (SecretValue, *http.Response, error) + type StatusApiService service + func (a *StatusApiService) GetStatus(ctx context.Context) (*http.Response, error) + func (a *StatusApiService) GetSystemInfo(ctx context.Context) (SystemInformation, *http.Response, error) + type SystemInformation struct + ApiVersion string + Kind string + Status *SystemInformationStatus + type SystemInformationStatus struct + JvmVersion string + License *License + ResourceQuota *ResourceQuota + RevisionInformation *RevisionInformation + type VolumeAndMount struct + Name string + Volume *core.Volume + VolumeMount *core.VolumeMount
Go to main page