Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FlinkUserConfig ¶
type FlinkUserConfig struct { // +kubebuilder:validation:MaxItems=1 // +kubebuilder:deprecatedversion:warning="additional_backup_regions is deprecated" // Deprecated. Additional Cloud Regions for Backup Replication AdditionalBackupRegions []string `groups:"create,update" json:"additional_backup_regions,omitempty"` // +kubebuilder:validation:Enum="1.19" // +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable" // Flink major version FlinkVersion *string `groups:"create" json:"flink_version,omitempty"` // +kubebuilder:validation:MaxItems=1024 // Allow incoming connections from CIDR address block, e.g. '10.20.0.0/16' IpFilter []*IpFilter `groups:"create,update" json:"ip_filter,omitempty"` // +kubebuilder:validation:Minimum=1 // +kubebuilder:validation:Maximum=1024 // Task slots per node. For a 3 node plan, total number of task slots is 3x this value NumberOfTaskSlots *int `groups:"create,update" json:"number_of_task_slots,omitempty"` // +kubebuilder:validation:Minimum=5 // +kubebuilder:validation:Maximum=60 // Timeout in seconds used for all futures and blocking Pekko requests PekkoAskTimeoutS *int `groups:"create,update" json:"pekko_ask_timeout_s,omitempty"` // +kubebuilder:validation:Minimum=1048576 // +kubebuilder:validation:Maximum=52428800 // Maximum size in bytes for messages exchanged between the JobManager and the TaskManagers PekkoFramesizeB *int `groups:"create,update" json:"pekko_framesize_b,omitempty"` // Allow access to selected service components through Privatelink PrivatelinkAccess *PrivatelinkAccess `groups:"create,update" json:"privatelink_access,omitempty"` // Allow access to selected service ports from the public Internet PublicAccess *PublicAccess `groups:"create,update" json:"public_access,omitempty"` // Store logs for the service so that they are available in the HTTP API and console. ServiceLog *bool `groups:"create,update" json:"service_log,omitempty"` // Use static public IP addresses StaticIps *bool `groups:"create,update" json:"static_ips,omitempty"` }
func (*FlinkUserConfig) DeepCopy ¶
func (in *FlinkUserConfig) DeepCopy() *FlinkUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlinkUserConfig.
func (*FlinkUserConfig) DeepCopyInto ¶
func (in *FlinkUserConfig) DeepCopyInto(out *FlinkUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type IpFilter ¶
type IpFilter struct { // +kubebuilder:validation:MaxLength=1024 // Description for IP filter list entry Description *string `groups:"create,update" json:"description,omitempty"` // +kubebuilder:validation:MaxLength=43 // CIDR address block Network string `groups:"create,update" json:"network"` }
CIDR address block, either as a string, or in a dict with an optional description field
func (*IpFilter) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IpFilter.
func (*IpFilter) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PrivatelinkAccess ¶
type PrivatelinkAccess struct { // Enable flink Flink *bool `groups:"create,update" json:"flink,omitempty"` // Enable prometheus Prometheus *bool `groups:"create,update" json:"prometheus,omitempty"` }
Allow access to selected service components through Privatelink
func (*PrivatelinkAccess) DeepCopy ¶
func (in *PrivatelinkAccess) DeepCopy() *PrivatelinkAccess
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrivatelinkAccess.
func (*PrivatelinkAccess) DeepCopyInto ¶
func (in *PrivatelinkAccess) DeepCopyInto(out *PrivatelinkAccess)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PublicAccess ¶
type PublicAccess struct { // Allow clients to connect to flink from the public internet for service nodes that are in a project VPC or another type of private network Flink *bool `groups:"create,update" json:"flink,omitempty"` }
Allow access to selected service ports from the public Internet
func (*PublicAccess) DeepCopy ¶
func (in *PublicAccess) DeepCopy() *PublicAccess
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublicAccess.
func (*PublicAccess) DeepCopyInto ¶
func (in *PublicAccess) DeepCopyInto(out *PublicAccess)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.