spark

package
v1.366.0 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2024 License: Apache-2.0 Imports: 12 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AttachVirtualNodeGroupRequest added in v1.128.0 

type AttachVirtualNodeGroupRequest struct {
	VngID *string `json:"id,omitempty"`
}

type AttachVngInput 

type AttachVngInput struct {
	ClusterID        *string                        `json:"-"`
	VirtualNodeGroup *AttachVirtualNodeGroupRequest `json:"virtualNodeGroup,omitempty"`
}

type AttachVngOutput 

type AttachVngOutput struct {
	VirtualNodeGroup *DedicatedVirtualNodeGroup `json:"virtualNodeGroup,omitempty"`
}

type Cluster 

type Cluster struct {
	Config *Config `json:"config,omitempty"`

	// Read-only fields.
	ID                    *string    `json:"id,omitempty"`
	ControllerClusterID   *string    `json:"controllerClusterId,omitempty"`
	OceanClusterID        *string    `json:"oceanClusterId,omitempty"`
	Region                *string    `json:"region,omitempty"`
	State                 *string    `json:"state,omitempty"`
	K8sVersion            *string    `json:"k8sVersion,omitempty"`
	OperatorVersion       *string    `json:"operatorVersion,omitempty"`
	OperatorLastHeartbeat *time.Time `json:"operatorLastHeartbeat,omitempty"`
	CreatedAt             *time.Time `json:"createdAt,omitempty"`
	UpdatedAt             *time.Time `json:"updatedAt,omitempty"`
	// contains filtered or unexported fields
}

func (Cluster) MarshalJSON added in v1.128.0 

func (c Cluster) MarshalJSON() ([]byte, error)

func (*Cluster) SetConfig added in v1.128.0 

func (c *Cluster) SetConfig(v *Config) *Cluster

type ClusterManager 

type ClusterManager interface {
}

type ComputeConfig 

type ComputeConfig struct {
	UseTaints  *bool `json:"useTaints,omitempty"`
	CreateVngs *bool `json:"createVngs,omitempty"`
	// contains filtered or unexported fields
}

func (ComputeConfig) MarshalJSON added in v1.128.0 

func (c ComputeConfig) MarshalJSON() ([]byte, error)

func (*ComputeConfig) SetCreateVNGs added in v1.128.0 

func (c *ComputeConfig) SetCreateVNGs(v *bool) *ComputeConfig

func (*ComputeConfig) SetUseTaints added in v1.128.0 

func (c *ComputeConfig) SetUseTaints(v *bool) *ComputeConfig

type Config 

type Config struct {
	Ingress       *IngressConfig       `json:"ingress,omitempty"`
	Webhook       *WebhookConfig       `json:"webhook,omitempty"`
	Compute       *ComputeConfig       `json:"compute,omitempty"`
	LogCollection *LogCollectionConfig `json:"logCollection,omitempty"`
	Spark         *SparkConfig         `json:"spark,omitempty"`
	// contains filtered or unexported fields
}

func (Config) MarshalJSON added in v1.128.0 

func (c Config) MarshalJSON() ([]byte, error)

func (*Config) SetCompute added in v1.128.0 

func (c *Config) SetCompute(v *ComputeConfig) *Config

func (*Config) SetIngress added in v1.128.0 

func (c *Config) SetIngress(v *IngressConfig) *Config

func (*Config) SetLogCollection added in v1.128.0 

func (c *Config) SetLogCollection(v *LogCollectionConfig) *Config

func (*Config) SetSpark added in v1.146.0 

func (c *Config) SetSpark(v *SparkConfig) *Config

func (*Config) SetWebhook added in v1.128.0 

func (c *Config) SetWebhook(v *WebhookConfig) *Config

type CreateClusterInput 

type CreateClusterInput struct {
	Cluster *CreateClusterRequest `json:"cluster,omitempty"`
}

type CreateClusterOutput 

type CreateClusterOutput struct {
	Cluster *Cluster `json:"cluster,omitempty"`
}

type CreateClusterRequest 

type CreateClusterRequest struct {
	OceanClusterID *string `json:"oceanClusterId,omitempty"`
	Config         *Config `json:"config,omitempty"`
}

type DedicatedVirtualNodeGroup 

type DedicatedVirtualNodeGroup struct {
	OceanClusterID      *string `json:"oceanClusterId,omitempty"`
	OceanSparkClusterID *string `json:"oceanSparkClusterId,omitempty"`
	VngID               *string `json:"vngId,omitempty"`
}

type DeleteClusterInput 

type DeleteClusterInput struct {
	ForceDelete *bool   `json:"-"`
	ClusterID   *string `json:"clusterId,omitempty"`
}

type DeleteClusterOutput 

type DeleteClusterOutput struct{}

type DetachVngInput 

type DetachVngInput struct {
	ClusterID *string `json:"clusterId,omitempty"`
	VngID     *string `json:"vngId,omitempty"`
}

type DetachVngOutput 

type DetachVngOutput struct{}

type IngressConfig 

type IngressConfig struct {
	// Deprecated: Use LoadBalancer.ServiceAnnotations instead.
	ServiceAnnotations map[string]string `json:"serviceAnnotations,omitempty"`
	// Deprecated: Has no effect.
	DeployIngress *bool `json:"deployIngress,omitempty"`

	Controller     *IngressConfigController     `json:"controller,omitempty"`
	CustomEndpoint *IngressConfigCustomEndpoint `json:"customEndpoint,omitempty"`
	LoadBalancer   *IngressConfigLoadBalancer   `json:"loadBalancer,omitempty"`
	PrivateLink    *IngressConfigPrivateLink    `json:"privateLink,omitempty"`
	// contains filtered or unexported fields
}

func (IngressConfig) MarshalJSON added in v1.128.0 

func (i IngressConfig) MarshalJSON() ([]byte, error)

func (*IngressConfig) SetController added in v1.133.0 

func (i *IngressConfig) SetController(c *IngressConfigController) *IngressConfig

func (*IngressConfig) SetCustomEndpoint added in v1.133.0 

func (i *IngressConfig) SetCustomEndpoint(ce *IngressConfigCustomEndpoint) *IngressConfig

func (*IngressConfig) SetDeployIngress added in v1.128.0 

func (i *IngressConfig) SetDeployIngress(v *bool) *IngressConfig

func (*IngressConfig) SetLoadBalancer added in v1.133.0 

func (i *IngressConfig) SetLoadBalancer(lb *IngressConfigLoadBalancer) *IngressConfig
func (i *IngressConfig) SetPrivateLink(pl *IngressConfigPrivateLink) *IngressConfig

func (*IngressConfig) SetServiceAnnotations added in v1.128.0 

func (i *IngressConfig) SetServiceAnnotations(v map[string]string) *IngressConfig

type IngressConfigController added in v1.133.0 

type IngressConfigController struct {
	Managed *bool `json:"managed,omitempty"`
	// contains filtered or unexported fields
}

func (IngressConfigController) MarshalJSON added in v1.133.0 

func (c IngressConfigController) MarshalJSON() ([]byte, error)

func (*IngressConfigController) SetManaged added in v1.133.0 

func (c *IngressConfigController) SetManaged(v *bool) *IngressConfigController

type IngressConfigCustomEndpoint added in v1.133.0 

type IngressConfigCustomEndpoint struct {
	Enabled *bool   `json:"enabled,omitempty"`
	Address *string `json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (IngressConfigCustomEndpoint) MarshalJSON added in v1.133.0 

func (ce IngressConfigCustomEndpoint) MarshalJSON() ([]byte, error)

func (*IngressConfigCustomEndpoint) SetAddress added in v1.133.0 

func (ce *IngressConfigCustomEndpoint) SetAddress(v *string) *IngressConfigCustomEndpoint

func (*IngressConfigCustomEndpoint) SetEnabled added in v1.133.0 

func (ce *IngressConfigCustomEndpoint) SetEnabled(v *bool) *IngressConfigCustomEndpoint

type IngressConfigLoadBalancer added in v1.133.0 

type IngressConfigLoadBalancer struct {
	Managed            *bool             `json:"managed,omitempty"`
	TargetGroupARN     *string           `json:"targetGroupArn,omitempty"`
	ServiceAnnotations map[string]string `json:"serviceAnnotations,omitempty"`
	// contains filtered or unexported fields
}

func (IngressConfigLoadBalancer) MarshalJSON added in v1.133.0 

func (lb IngressConfigLoadBalancer) MarshalJSON() ([]byte, error)

func (*IngressConfigLoadBalancer) SetManaged added in v1.133.0 

func (lb *IngressConfigLoadBalancer) SetManaged(v *bool) *IngressConfigLoadBalancer

func (*IngressConfigLoadBalancer) SetServiceAnnotations added in v1.133.0 

func (lb *IngressConfigLoadBalancer) SetServiceAnnotations(v map[string]string) *IngressConfigLoadBalancer

func (*IngressConfigLoadBalancer) SetTargetGroupARN added in v1.133.0 

func (lb *IngressConfigLoadBalancer) SetTargetGroupARN(v *string) *IngressConfigLoadBalancer
type IngressConfigPrivateLink struct {
	Enabled            *bool   `json:"enabled,omitempty"`
	VPCEndpointService *string `json:"vpcEndpointService,omitempty"`
	// contains filtered or unexported fields
}

func (IngressConfigPrivateLink) MarshalJSON added in v1.133.0 

func (pl IngressConfigPrivateLink) MarshalJSON() ([]byte, error)

func (*IngressConfigPrivateLink) SetEnabled added in v1.133.0 

func (pl *IngressConfigPrivateLink) SetEnabled(v *bool) *IngressConfigPrivateLink

func (*IngressConfigPrivateLink) SetVPCEndpointService added in v1.133.0 

func (pl *IngressConfigPrivateLink) SetVPCEndpointService(v *string) *IngressConfigPrivateLink

type ListClustersInput 

type ListClustersInput struct {
	ControllerClusterID *string `json:"controllerClusterId,omitempty"`
	ClusterState        *string `json:"clusterState,omitempty"`
}

type ListClustersOutput 

type ListClustersOutput struct {
	Clusters []*Cluster `json:"clusters,omitempty"`
}

type ListVngsInput added in v1.143.0 

type ListVngsInput struct {
	ClusterID *string `json:"clusterId,omitempty"`
}

type ListVngsOutput added in v1.143.0 

type ListVngsOutput struct {
	VirtualNodeGroups []*DedicatedVirtualNodeGroup `json:"virtualNodeGroups,omitempty"`
}

type LogCollectionConfig 

type LogCollectionConfig struct {
	// Deprecated: Use CollectAppLogs instead.
	CollectDriverLogs *bool `json:"collectDriverLogs,omitempty"`
	CollectAppLogs    *bool `json:"collectAppLogs,omitempty"`
	// contains filtered or unexported fields
}

func (LogCollectionConfig) MarshalJSON added in v1.128.0 

func (l LogCollectionConfig) MarshalJSON() ([]byte, error)

func (*LogCollectionConfig) SetCollectAppLogs added in v1.160.0 

func (l *LogCollectionConfig) SetCollectAppLogs(v *bool) *LogCollectionConfig

func (*LogCollectionConfig) SetCollectDriverLogs added in v1.128.0 

func (l *LogCollectionConfig) SetCollectDriverLogs(v *bool) *LogCollectionConfig

type ReadClusterInput 

type ReadClusterInput struct {
	ClusterID *string `json:"clusterId,omitempty"`
}

type ReadClusterOutput 

type ReadClusterOutput struct {
	Cluster *Cluster `json:"cluster,omitempty"`
}

type Service 

type Service interface {
	ReadCluster(context.Context, *ReadClusterInput) (*ReadClusterOutput, error)
	ListClusters(context.Context, *ListClustersInput) (*ListClustersOutput, error)
	DeleteCluster(context.Context, *DeleteClusterInput) (*DeleteClusterOutput, error)
	CreateCluster(context.Context, *CreateClusterInput) (*CreateClusterOutput, error)
	UpdateCluster(context.Context, *UpdateClusterInput) (*UpdateClusterOutput, error)
	ListVirtualNodeGroups(context.Context, *ListVngsInput) (*ListVngsOutput, error)
	DetachVirtualNodeGroup(context.Context, *DetachVngInput) (*DetachVngOutput, error)
	AttachVirtualNodeGroup(context.Context, *AttachVngInput) (*AttachVngOutput, error)
}

Service provides the API operation methods for making requests to endpoints of the Spotinst API. See this package's package overview docs for details on the service.

type ServiceOp 

type ServiceOp struct {
	Client *client.Client
}

func New 

func New(sess *session.Session, cfgs ...*spotinst.Config) *ServiceOp

func (*ServiceOp) AttachVirtualNodeGroup 

func (s *ServiceOp) AttachVirtualNodeGroup(ctx context.Context, input *AttachVngInput) (*AttachVngOutput, error)

func (*ServiceOp) CreateCluster 

func (s *ServiceOp) CreateCluster(ctx context.Context, input *CreateClusterInput) (*CreateClusterOutput, error)

func (*ServiceOp) DeleteCluster 

func (s *ServiceOp) DeleteCluster(ctx context.Context, input *DeleteClusterInput) (*DeleteClusterOutput, error)

func (*ServiceOp) DetachVirtualNodeGroup 

func (s *ServiceOp) DetachVirtualNodeGroup(ctx context.Context, input *DetachVngInput) (*DetachVngOutput, error)

func (*ServiceOp) ListClusters 

func (s *ServiceOp) ListClusters(ctx context.Context, input *ListClustersInput) (*ListClustersOutput, error)

region Cluster

func (*ServiceOp) ListVirtualNodeGroups added in v1.143.0 

func (s *ServiceOp) ListVirtualNodeGroups(ctx context.Context, input *ListVngsInput) (*ListVngsOutput, error)

region Virtual Node Group

func (*ServiceOp) ReadCluster 

func (s *ServiceOp) ReadCluster(ctx context.Context, input *ReadClusterInput) (*ReadClusterOutput, error)

func (*ServiceOp) UpdateCluster 

func (s *ServiceOp) UpdateCluster(ctx context.Context, input *UpdateClusterInput) (*UpdateClusterOutput, error)

type SparkConfig added in v1.146.0 

type SparkConfig struct {
	AppNamespaces []*string `json:"appNamespaces,omitempty"`
	// contains filtered or unexported fields
}

func (SparkConfig) MarshalJSON added in v1.146.0 

func (s SparkConfig) MarshalJSON() ([]byte, error)

func (*SparkConfig) SetAppNamespaces added in v1.146.0 

func (s *SparkConfig) SetAppNamespaces(v []*string) *SparkConfig

type UpdateClusterInput 

type UpdateClusterInput struct {
	ClusterID *string               `json:"-"`
	Cluster   *UpdateClusterRequest `json:"cluster,omitempty"`
}

type UpdateClusterOutput 

type UpdateClusterOutput struct{}

type UpdateClusterRequest 

type UpdateClusterRequest struct {
	Config *Config `json:"config,omitempty"`
}

type WebhookConfig 

type WebhookConfig struct {
	UseHostNetwork   *bool  `json:"useHostNetwork,omitempty"`
	HostNetworkPorts []*int `json:"hostNetworkPorts,omitempty"`
	// contains filtered or unexported fields
}

func (WebhookConfig) MarshalJSON added in v1.128.0 

func (w WebhookConfig) MarshalJSON() ([]byte, error)

func (*WebhookConfig) SetHostNetworkPorts added in v1.128.0 

func (w *WebhookConfig) SetHostNetworkPorts(v []*int) *WebhookConfig

func (*WebhookConfig) SetUseHostNetwork added in v1.128.0 

func (w *WebhookConfig) SetUseHostNetwork(v *bool) *WebhookConfig

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.