flyteidl_flink

Jul 27, 2023

Changes in this version

type FlinkJob

+ KubernetesClusterName string

+ KubernetesClusterRegion string

+ func (m *FlinkJob) GetKubernetesClusterName() string

+ func (m *FlinkJob) GetKubernetesClusterRegion() string

May 6, 2021

Changes in this version

type FlinkJob

+ Parallelism int32

+ func (m *FlinkJob) GetParallelism() int32

Apr 29, 2021

Changes in this version

+ var Resource_PersistentVolume_Type_name = map[int32]string

+ var Resource_PersistentVolume_Type_value = map[string]int32

+ type FlinkExecutionInfo struct

+ Job *JobExecutionInfo

+ JobManager *JobManagerExecutionInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FlinkExecutionInfo) Descriptor() ([]byte, []int)

+ func (*FlinkExecutionInfo) ProtoMessage()

+ func (m *FlinkExecutionInfo) GetJob() *JobExecutionInfo

+ func (m *FlinkExecutionInfo) GetJobManager() *JobManagerExecutionInfo

+ func (m *FlinkExecutionInfo) Reset()

+ func (m *FlinkExecutionInfo) String() string

+ func (m *FlinkExecutionInfo) Validate() error

+ func (m *FlinkExecutionInfo) XXX_DiscardUnknown()

+ func (m *FlinkExecutionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FlinkExecutionInfo) XXX_Merge(src proto.Message)

+ func (m *FlinkExecutionInfo) XXX_Size() int

+ func (m *FlinkExecutionInfo) XXX_Unmarshal(b []byte) error

+ type FlinkExecutionInfoValidationError struct

+ func (e FlinkExecutionInfoValidationError) Cause() error

+ func (e FlinkExecutionInfoValidationError) Error() string

+ func (e FlinkExecutionInfoValidationError) ErrorName() string

+ func (e FlinkExecutionInfoValidationError) Field() string

+ func (e FlinkExecutionInfoValidationError) Key() bool

+ func (e FlinkExecutionInfoValidationError) Reason() string

+ type FlinkJob struct

+ Args []string

+ FlinkProperties map[string]string

+ FlinkVersion string

+ Image string

+ JarFiles []string

+ Jflyte *JFlyte

+ JobManager *JobManager

+ MainClass string

+ ServiceAccount string

+ TaskManager *TaskManager

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FlinkJob) Descriptor() ([]byte, []int)

+ func (*FlinkJob) ProtoMessage()

+ func (m *FlinkJob) GetArgs() []string

+ func (m *FlinkJob) GetFlinkProperties() map[string]string

+ func (m *FlinkJob) GetFlinkVersion() string

+ func (m *FlinkJob) GetImage() string

+ func (m *FlinkJob) GetJarFiles() []string

+ func (m *FlinkJob) GetJflyte() *JFlyte

+ func (m *FlinkJob) GetJobManager() *JobManager

+ func (m *FlinkJob) GetMainClass() string

+ func (m *FlinkJob) GetServiceAccount() string

+ func (m *FlinkJob) GetTaskManager() *TaskManager

+ func (m *FlinkJob) Reset()

+ func (m *FlinkJob) String() string

+ func (m *FlinkJob) Validate() error

+ func (m *FlinkJob) XXX_DiscardUnknown()

+ func (m *FlinkJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FlinkJob) XXX_Merge(src proto.Message)

+ func (m *FlinkJob) XXX_Size() int

+ func (m *FlinkJob) XXX_Unmarshal(b []byte) error

+ type FlinkJobValidationError struct

+ func (e FlinkJobValidationError) Cause() error

+ func (e FlinkJobValidationError) Error() string

+ func (e FlinkJobValidationError) ErrorName() string

+ func (e FlinkJobValidationError) Field() string

+ func (e FlinkJobValidationError) Key() bool

+ func (e FlinkJobValidationError) Reason() string

+ type JFlyte struct

+ Artifacts []*JFlyte_Artifact

+ IndexFileLocation string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*JFlyte) Descriptor() ([]byte, []int)

+ func (*JFlyte) ProtoMessage()

+ func (m *JFlyte) GetArtifacts() []*JFlyte_Artifact

+ func (m *JFlyte) GetIndexFileLocation() string

+ func (m *JFlyte) Reset()

+ func (m *JFlyte) String() string

+ func (m *JFlyte) Validate() error

+ func (m *JFlyte) XXX_DiscardUnknown()

+ func (m *JFlyte) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *JFlyte) XXX_Merge(src proto.Message)

+ func (m *JFlyte) XXX_Size() int

+ func (m *JFlyte) XXX_Unmarshal(b []byte) error

+ type JFlyteValidationError struct

+ func (e JFlyteValidationError) Cause() error

+ func (e JFlyteValidationError) Error() string

+ func (e JFlyteValidationError) ErrorName() string

+ func (e JFlyteValidationError) Field() string

+ func (e JFlyteValidationError) Key() bool

+ func (e JFlyteValidationError) Reason() string

+ type JFlyte_Artifact struct

+ Location string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*JFlyte_Artifact) Descriptor() ([]byte, []int)

+ func (*JFlyte_Artifact) ProtoMessage()

+ func (m *JFlyte_Artifact) GetLocation() string

+ func (m *JFlyte_Artifact) GetName() string

+ func (m *JFlyte_Artifact) Reset()

+ func (m *JFlyte_Artifact) String() string

+ func (m *JFlyte_Artifact) Validate() error

+ func (m *JFlyte_Artifact) XXX_DiscardUnknown()

+ func (m *JFlyte_Artifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *JFlyte_Artifact) XXX_Merge(src proto.Message)

+ func (m *JFlyte_Artifact) XXX_Size() int

+ func (m *JFlyte_Artifact) XXX_Unmarshal(b []byte) error

+ type JFlyte_ArtifactValidationError struct

+ func (e JFlyte_ArtifactValidationError) Cause() error

+ func (e JFlyte_ArtifactValidationError) Error() string

+ func (e JFlyte_ArtifactValidationError) ErrorName() string

+ func (e JFlyte_ArtifactValidationError) Field() string

+ func (e JFlyte_ArtifactValidationError) Key() bool

+ func (e JFlyte_ArtifactValidationError) Reason() string

+ type JobExecutionInfo struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*JobExecutionInfo) Descriptor() ([]byte, []int)

+ func (*JobExecutionInfo) ProtoMessage()

+ func (m *JobExecutionInfo) GetId() string

+ func (m *JobExecutionInfo) Reset()

+ func (m *JobExecutionInfo) String() string

+ func (m *JobExecutionInfo) Validate() error

+ func (m *JobExecutionInfo) XXX_DiscardUnknown()

+ func (m *JobExecutionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *JobExecutionInfo) XXX_Merge(src proto.Message)

+ func (m *JobExecutionInfo) XXX_Size() int

+ func (m *JobExecutionInfo) XXX_Unmarshal(b []byte) error

+ type JobExecutionInfoValidationError struct

+ func (e JobExecutionInfoValidationError) Cause() error

+ func (e JobExecutionInfoValidationError) Error() string

+ func (e JobExecutionInfoValidationError) ErrorName() string

+ func (e JobExecutionInfoValidationError) Field() string

+ func (e JobExecutionInfoValidationError) Key() bool

+ func (e JobExecutionInfoValidationError) Reason() string

+ type JobManager struct

+ Resource *Resource

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*JobManager) Descriptor() ([]byte, []int)

+ func (*JobManager) ProtoMessage()

+ func (m *JobManager) GetResource() *Resource

+ func (m *JobManager) Reset()

+ func (m *JobManager) String() string

+ func (m *JobManager) Validate() error

+ func (m *JobManager) XXX_DiscardUnknown()

+ func (m *JobManager) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *JobManager) XXX_Merge(src proto.Message)

+ func (m *JobManager) XXX_Size() int

+ func (m *JobManager) XXX_Unmarshal(b []byte) error

+ type JobManagerExecutionInfo struct

+ IngressURLs []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*JobManagerExecutionInfo) Descriptor() ([]byte, []int)

+ func (*JobManagerExecutionInfo) ProtoMessage()

+ func (m *JobManagerExecutionInfo) GetIngressURLs() []string

+ func (m *JobManagerExecutionInfo) Reset()

+ func (m *JobManagerExecutionInfo) String() string

+ func (m *JobManagerExecutionInfo) Validate() error

+ func (m *JobManagerExecutionInfo) XXX_DiscardUnknown()

+ func (m *JobManagerExecutionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *JobManagerExecutionInfo) XXX_Merge(src proto.Message)

+ func (m *JobManagerExecutionInfo) XXX_Size() int

+ func (m *JobManagerExecutionInfo) XXX_Unmarshal(b []byte) error

+ type JobManagerExecutionInfoValidationError struct

+ func (e JobManagerExecutionInfoValidationError) Cause() error

+ func (e JobManagerExecutionInfoValidationError) Error() string

+ func (e JobManagerExecutionInfoValidationError) ErrorName() string

+ func (e JobManagerExecutionInfoValidationError) Field() string

+ func (e JobManagerExecutionInfoValidationError) Key() bool

+ func (e JobManagerExecutionInfoValidationError) Reason() string

+ type JobManagerValidationError struct

+ func (e JobManagerValidationError) Cause() error

+ func (e JobManagerValidationError) Error() string

+ func (e JobManagerValidationError) ErrorName() string

+ func (e JobManagerValidationError) Field() string

+ func (e JobManagerValidationError) Key() bool

+ func (e JobManagerValidationError) Reason() string

+ type Resource struct

+ Cpu *Resource_Quantity

+ Memory *Resource_Quantity

+ PersistentVolume *Resource_PersistentVolume

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Resource) Descriptor() ([]byte, []int)

+ func (*Resource) ProtoMessage()

+ func (m *Resource) GetCpu() *Resource_Quantity

+ func (m *Resource) GetMemory() *Resource_Quantity

+ func (m *Resource) GetPersistentVolume() *Resource_PersistentVolume

+ func (m *Resource) Reset()

+ func (m *Resource) String() string

+ func (m *Resource) Validate() error

+ func (m *Resource) XXX_DiscardUnknown()

+ func (m *Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Resource) XXX_Merge(src proto.Message)

+ func (m *Resource) XXX_Size() int

+ func (m *Resource) XXX_Unmarshal(b []byte) error

+ type ResourceValidationError struct

+ func (e ResourceValidationError) Cause() error

+ func (e ResourceValidationError) Error() string

+ func (e ResourceValidationError) ErrorName() string

+ func (e ResourceValidationError) Field() string

+ func (e ResourceValidationError) Key() bool

+ func (e ResourceValidationError) Reason() string

+ type Resource_PersistentVolume struct

+ Size *Resource_Quantity

+ Type Resource_PersistentVolume_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Resource_PersistentVolume) Descriptor() ([]byte, []int)

+ func (*Resource_PersistentVolume) ProtoMessage()

+ func (m *Resource_PersistentVolume) GetSize() *Resource_Quantity

+ func (m *Resource_PersistentVolume) GetType() Resource_PersistentVolume_Type

+ func (m *Resource_PersistentVolume) Reset()

+ func (m *Resource_PersistentVolume) String() string

+ func (m *Resource_PersistentVolume) Validate() error

+ func (m *Resource_PersistentVolume) XXX_DiscardUnknown()

+ func (m *Resource_PersistentVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Resource_PersistentVolume) XXX_Merge(src proto.Message)

+ func (m *Resource_PersistentVolume) XXX_Size() int

+ func (m *Resource_PersistentVolume) XXX_Unmarshal(b []byte) error

+ type Resource_PersistentVolumeValidationError struct

+ func (e Resource_PersistentVolumeValidationError) Cause() error

+ func (e Resource_PersistentVolumeValidationError) Error() string

+ func (e Resource_PersistentVolumeValidationError) ErrorName() string

+ func (e Resource_PersistentVolumeValidationError) Field() string

+ func (e Resource_PersistentVolumeValidationError) Key() bool

+ func (e Resource_PersistentVolumeValidationError) Reason() string

+ type Resource_PersistentVolume_Type int32

+ const Resource_PersistentVolume_PD_SSD

+ const Resource_PersistentVolume_PD_STANDARD

+ func (Resource_PersistentVolume_Type) EnumDescriptor() ([]byte, []int)

+ func (x Resource_PersistentVolume_Type) String() string

+ type Resource_Quantity struct

+ String_ string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Resource_Quantity) Descriptor() ([]byte, []int)

+ func (*Resource_Quantity) ProtoMessage()

+ func (m *Resource_Quantity) GetString_() string

+ func (m *Resource_Quantity) Reset()

+ func (m *Resource_Quantity) String() string

+ func (m *Resource_Quantity) Validate() error

+ func (m *Resource_Quantity) XXX_DiscardUnknown()

+ func (m *Resource_Quantity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Resource_Quantity) XXX_Merge(src proto.Message)

+ func (m *Resource_Quantity) XXX_Size() int

+ func (m *Resource_Quantity) XXX_Unmarshal(b []byte) error

+ type Resource_QuantityValidationError struct

+ func (e Resource_QuantityValidationError) Cause() error

+ func (e Resource_QuantityValidationError) Error() string

+ func (e Resource_QuantityValidationError) ErrorName() string

+ func (e Resource_QuantityValidationError) Field() string

+ func (e Resource_QuantityValidationError) Key() bool

+ func (e Resource_QuantityValidationError) Reason() string

+ type TaskManager struct

+ Replicas int32

+ Resource *Resource

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskManager) Descriptor() ([]byte, []int)

+ func (*TaskManager) ProtoMessage()

+ func (m *TaskManager) GetReplicas() int32

+ func (m *TaskManager) GetResource() *Resource

+ func (m *TaskManager) Reset()

+ func (m *TaskManager) String() string

+ func (m *TaskManager) Validate() error

+ func (m *TaskManager) XXX_DiscardUnknown()

+ func (m *TaskManager) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskManager) XXX_Merge(src proto.Message)

+ func (m *TaskManager) XXX_Size() int

+ func (m *TaskManager) XXX_Unmarshal(b []byte) error

+ type TaskManagerValidationError struct

+ func (e TaskManagerValidationError) Cause() error

+ func (e TaskManagerValidationError) Error() string

+ func (e TaskManagerValidationError) ErrorName() string

+ func (e TaskManagerValidationError) Field() string

+ func (e TaskManagerValidationError) Key() bool

+ func (e TaskManagerValidationError) Reason() string