flyteidl_flink

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Resource_PersistentVolume_Type_name = map[int32]string{
	0: "PD_STANDARD",
	1: "PD_SSD",
}
View Source 
var Resource_PersistentVolume_Type_value = map[string]int32{
	"PD_STANDARD": 0,
	"PD_SSD":      1,
}

Functions

This section is empty.

Types

type FlinkExecutionInfo 

type FlinkExecutionInfo struct {
	Job                  *JobExecutionInfo        `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	JobManager           *JobManagerExecutionInfo `protobuf:"bytes,2,opt,name=jobManager,proto3" json:"jobManager,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*FlinkExecutionInfo) Descriptor 

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

func (*FlinkExecutionInfo) GetJob 

func (m *FlinkExecutionInfo) GetJob() *JobExecutionInfo

func (*FlinkExecutionInfo) GetJobManager 

func (m *FlinkExecutionInfo) GetJobManager() *JobManagerExecutionInfo

func (*FlinkExecutionInfo) ProtoMessage 

func (*FlinkExecutionInfo) ProtoMessage()

func (*FlinkExecutionInfo) Reset 

func (m *FlinkExecutionInfo) Reset()

func (*FlinkExecutionInfo) String 

func (m *FlinkExecutionInfo) String() string

func (*FlinkExecutionInfo) Validate 

func (m *FlinkExecutionInfo) Validate() error

Validate checks the field values on FlinkExecutionInfo with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*FlinkExecutionInfo) XXX_DiscardUnknown 

func (m *FlinkExecutionInfo) XXX_DiscardUnknown()

func (*FlinkExecutionInfo) XXX_Marshal 

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

func (*FlinkExecutionInfo) XXX_Merge 

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

func (*FlinkExecutionInfo) XXX_Size 

func (m *FlinkExecutionInfo) XXX_Size() int

func (*FlinkExecutionInfo) XXX_Unmarshal 

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

type FlinkExecutionInfoValidationError 

type FlinkExecutionInfoValidationError struct {
	// contains filtered or unexported fields
}

FlinkExecutionInfoValidationError is the validation error returned by FlinkExecutionInfo.Validate if the designated constraints aren't met.

func (FlinkExecutionInfoValidationError) Cause 

func (e FlinkExecutionInfoValidationError) Cause() error

Cause function returns cause value.

func (FlinkExecutionInfoValidationError) Error 

func (e FlinkExecutionInfoValidationError) Error() string

Error satisfies the builtin error interface

func (FlinkExecutionInfoValidationError) ErrorName 

func (e FlinkExecutionInfoValidationError) ErrorName() string

ErrorName returns error name.

func (FlinkExecutionInfoValidationError) Field 

func (e FlinkExecutionInfoValidationError) Field() string

Field function returns field value.

func (FlinkExecutionInfoValidationError) Key 

func (e FlinkExecutionInfoValidationError) Key() bool

Key function returns key value.

func (FlinkExecutionInfoValidationError) Reason 

func (e FlinkExecutionInfoValidationError) Reason() string

Reason function returns reason value.

type FlinkJob 

type FlinkJob struct {
	JarFiles                []string          `protobuf:"bytes,1,rep,name=jarFiles,proto3" json:"jarFiles,omitempty"`
	MainClass               string            `protobuf:"bytes,2,opt,name=mainClass,proto3" json:"mainClass,omitempty"`
	Args                    []string          `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	FlinkProperties         map[string]string `` /* 171-byte string literal not displayed */
	JobManager              *JobManager       `protobuf:"bytes,5,opt,name=jobManager,proto3" json:"jobManager,omitempty"`
	TaskManager             *TaskManager      `protobuf:"bytes,6,opt,name=taskManager,proto3" json:"taskManager,omitempty"`
	ServiceAccount          string            `protobuf:"bytes,7,opt,name=serviceAccount,proto3" json:"serviceAccount,omitempty"`
	Image                   string            `protobuf:"bytes,8,opt,name=image,proto3" json:"image,omitempty"`
	FlinkVersion            string            `protobuf:"bytes,9,opt,name=flinkVersion,proto3" json:"flinkVersion,omitempty"`
	Parallelism             int32             `protobuf:"varint,10,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	KubernetesClusterName   string            `protobuf:"bytes,11,opt,name=kubernetesClusterName,proto3" json:"kubernetesClusterName,omitempty"`
	KubernetesClusterRegion string            `protobuf:"bytes,12,opt,name=kubernetesClusterRegion,proto3" json:"kubernetesClusterRegion,omitempty"`
	// if using experiment flytekit-java this will contain all artifacts required
	// to run the task
	Jflyte               *JFlyte  `protobuf:"bytes,100,opt,name=jflyte,proto3" json:"jflyte,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Custom Proto for Flink Plugin.

func (*FlinkJob) Descriptor 

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

func (*FlinkJob) GetArgs 

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

func (*FlinkJob) GetFlinkProperties 

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

func (*FlinkJob) GetFlinkVersion 

func (m *FlinkJob) GetFlinkVersion() string

func (*FlinkJob) GetImage 

func (m *FlinkJob) GetImage() string

func (*FlinkJob) GetJarFiles 

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

func (*FlinkJob) GetJflyte 

func (m *FlinkJob) GetJflyte() *JFlyte

func (*FlinkJob) GetJobManager 

func (m *FlinkJob) GetJobManager() *JobManager

func (*FlinkJob) GetKubernetesClusterName added in v0.2.1 

func (m *FlinkJob) GetKubernetesClusterName() string

func (*FlinkJob) GetKubernetesClusterRegion added in v0.2.1 

func (m *FlinkJob) GetKubernetesClusterRegion() string

func (*FlinkJob) GetMainClass 

func (m *FlinkJob) GetMainClass() string

func (*FlinkJob) GetParallelism added in v0.1.2 

func (m *FlinkJob) GetParallelism() int32

func (*FlinkJob) GetServiceAccount 

func (m *FlinkJob) GetServiceAccount() string

func (*FlinkJob) GetTaskManager 

func (m *FlinkJob) GetTaskManager() *TaskManager

func (*FlinkJob) ProtoMessage 

func (*FlinkJob) ProtoMessage()

func (*FlinkJob) Reset 

func (m *FlinkJob) Reset()

func (*FlinkJob) String 

func (m *FlinkJob) String() string

func (*FlinkJob) Validate 

func (m *FlinkJob) Validate() error

Validate checks the field values on FlinkJob with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*FlinkJob) XXX_DiscardUnknown 

func (m *FlinkJob) XXX_DiscardUnknown()

func (*FlinkJob) XXX_Marshal 

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

func (*FlinkJob) XXX_Merge 

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

func (*FlinkJob) XXX_Size 

func (m *FlinkJob) XXX_Size() int

func (*FlinkJob) XXX_Unmarshal 

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

type FlinkJobValidationError 

type FlinkJobValidationError struct {
	// contains filtered or unexported fields
}

FlinkJobValidationError is the validation error returned by FlinkJob.Validate if the designated constraints aren't met.

func (FlinkJobValidationError) Cause 

func (e FlinkJobValidationError) Cause() error

Cause function returns cause value.

func (FlinkJobValidationError) Error 

func (e FlinkJobValidationError) Error() string

Error satisfies the builtin error interface

func (FlinkJobValidationError) ErrorName 

func (e FlinkJobValidationError) ErrorName() string

ErrorName returns error name.

func (FlinkJobValidationError) Field 

func (e FlinkJobValidationError) Field() string

Field function returns field value.

func (FlinkJobValidationError) Key 

func (e FlinkJobValidationError) Key() bool

Key function returns key value.

func (FlinkJobValidationError) Reason 

func (e FlinkJobValidationError) Reason() string

Reason function returns reason value.

type JFlyte 

type JFlyte struct {
	IndexFileLocation    string             `protobuf:"bytes,1,opt,name=index_file_location,json=indexFileLocation,proto3" json:"index_file_location,omitempty"`
	Artifacts            []*JFlyte_Artifact `protobuf:"bytes,2,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*JFlyte) Descriptor 

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

func (*JFlyte) GetArtifacts 

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

func (*JFlyte) GetIndexFileLocation 

func (m *JFlyte) GetIndexFileLocation() string

func (*JFlyte) ProtoMessage 

func (*JFlyte) ProtoMessage()

func (*JFlyte) Reset 

func (m *JFlyte) Reset()

func (*JFlyte) String 

func (m *JFlyte) String() string

func (*JFlyte) Validate 

func (m *JFlyte) Validate() error

Validate checks the field values on JFlyte with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*JFlyte) XXX_DiscardUnknown 

func (m *JFlyte) XXX_DiscardUnknown()

func (*JFlyte) XXX_Marshal 

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

func (*JFlyte) XXX_Merge 

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

func (*JFlyte) XXX_Size 

func (m *JFlyte) XXX_Size() int

func (*JFlyte) XXX_Unmarshal 

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

type JFlyteValidationError 

type JFlyteValidationError struct {
	// contains filtered or unexported fields
}

JFlyteValidationError is the validation error returned by JFlyte.Validate if the designated constraints aren't met.

func (JFlyteValidationError) Cause 

func (e JFlyteValidationError) Cause() error

Cause function returns cause value.

func (JFlyteValidationError) Error 

func (e JFlyteValidationError) Error() string

Error satisfies the builtin error interface

func (JFlyteValidationError) ErrorName 

func (e JFlyteValidationError) ErrorName() string

ErrorName returns error name.

func (JFlyteValidationError) Field 

func (e JFlyteValidationError) Field() string

Field function returns field value.

func (JFlyteValidationError) Key 

func (e JFlyteValidationError) Key() bool

Key function returns key value.

func (JFlyteValidationError) Reason 

func (e JFlyteValidationError) Reason() string

Reason function returns reason value.

type JFlyte_Artifact 

type JFlyte_Artifact struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Location             string   `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JFlyte_Artifact) Descriptor 

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

func (*JFlyte_Artifact) GetLocation 

func (m *JFlyte_Artifact) GetLocation() string

func (*JFlyte_Artifact) GetName 

func (m *JFlyte_Artifact) GetName() string

func (*JFlyte_Artifact) ProtoMessage 

func (*JFlyte_Artifact) ProtoMessage()

func (*JFlyte_Artifact) Reset 

func (m *JFlyte_Artifact) Reset()

func (*JFlyte_Artifact) String 

func (m *JFlyte_Artifact) String() string

func (*JFlyte_Artifact) Validate 

func (m *JFlyte_Artifact) Validate() error

Validate checks the field values on JFlyte_Artifact with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*JFlyte_Artifact) XXX_DiscardUnknown 

func (m *JFlyte_Artifact) XXX_DiscardUnknown()

func (*JFlyte_Artifact) XXX_Marshal 

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

func (*JFlyte_Artifact) XXX_Merge 

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

func (*JFlyte_Artifact) XXX_Size 

func (m *JFlyte_Artifact) XXX_Size() int

func (*JFlyte_Artifact) XXX_Unmarshal 

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

type JFlyte_ArtifactValidationError 

type JFlyte_ArtifactValidationError struct {
	// contains filtered or unexported fields
}

JFlyte_ArtifactValidationError is the validation error returned by JFlyte_Artifact.Validate if the designated constraints aren't met.

func (JFlyte_ArtifactValidationError) Cause 

func (e JFlyte_ArtifactValidationError) Cause() error

Cause function returns cause value.

func (JFlyte_ArtifactValidationError) Error 

func (e JFlyte_ArtifactValidationError) Error() string

Error satisfies the builtin error interface

func (JFlyte_ArtifactValidationError) ErrorName 

func (e JFlyte_ArtifactValidationError) ErrorName() string

ErrorName returns error name.

func (JFlyte_ArtifactValidationError) Field 

func (e JFlyte_ArtifactValidationError) Field() string

Field function returns field value.

func (JFlyte_ArtifactValidationError) Key 

func (e JFlyte_ArtifactValidationError) Key() bool

Key function returns key value.

func (JFlyte_ArtifactValidationError) Reason 

func (e JFlyte_ArtifactValidationError) Reason() string

Reason function returns reason value.

type JobExecutionInfo 

type JobExecutionInfo struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobExecutionInfo) Descriptor 

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

func (*JobExecutionInfo) GetId 

func (m *JobExecutionInfo) GetId() string

func (*JobExecutionInfo) ProtoMessage 

func (*JobExecutionInfo) ProtoMessage()

func (*JobExecutionInfo) Reset 

func (m *JobExecutionInfo) Reset()

func (*JobExecutionInfo) String 

func (m *JobExecutionInfo) String() string

func (*JobExecutionInfo) Validate 

func (m *JobExecutionInfo) Validate() error

Validate checks the field values on JobExecutionInfo with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*JobExecutionInfo) XXX_DiscardUnknown 

func (m *JobExecutionInfo) XXX_DiscardUnknown()

func (*JobExecutionInfo) XXX_Marshal 

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

func (*JobExecutionInfo) XXX_Merge 

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

func (*JobExecutionInfo) XXX_Size 

func (m *JobExecutionInfo) XXX_Size() int

func (*JobExecutionInfo) XXX_Unmarshal 

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

type JobExecutionInfoValidationError 

type JobExecutionInfoValidationError struct {
	// contains filtered or unexported fields
}

JobExecutionInfoValidationError is the validation error returned by JobExecutionInfo.Validate if the designated constraints aren't met.

func (JobExecutionInfoValidationError) Cause 

func (e JobExecutionInfoValidationError) Cause() error

Cause function returns cause value.

func (JobExecutionInfoValidationError) Error 

func (e JobExecutionInfoValidationError) Error() string

Error satisfies the builtin error interface

func (JobExecutionInfoValidationError) ErrorName 

func (e JobExecutionInfoValidationError) ErrorName() string

ErrorName returns error name.

func (JobExecutionInfoValidationError) Field 

func (e JobExecutionInfoValidationError) Field() string

Field function returns field value.

func (JobExecutionInfoValidationError) Key 

func (e JobExecutionInfoValidationError) Key() bool

Key function returns key value.

func (JobExecutionInfoValidationError) Reason 

func (e JobExecutionInfoValidationError) Reason() string

Reason function returns reason value.

type JobManager 

type JobManager struct {
	Resource             *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*JobManager) Descriptor 

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

func (*JobManager) GetResource 

func (m *JobManager) GetResource() *Resource

func (*JobManager) ProtoMessage 

func (*JobManager) ProtoMessage()

func (*JobManager) Reset 

func (m *JobManager) Reset()

func (*JobManager) String 

func (m *JobManager) String() string

func (*JobManager) Validate 

func (m *JobManager) Validate() error

Validate checks the field values on JobManager with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*JobManager) XXX_DiscardUnknown 

func (m *JobManager) XXX_DiscardUnknown()

func (*JobManager) XXX_Marshal 

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

func (*JobManager) XXX_Merge 

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

func (*JobManager) XXX_Size 

func (m *JobManager) XXX_Size() int

func (*JobManager) XXX_Unmarshal 

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

type JobManagerExecutionInfo 

type JobManagerExecutionInfo struct {
	IngressURLs          []string `protobuf:"bytes,1,rep,name=ingressURLs,proto3" json:"ingressURLs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobManagerExecutionInfo) Descriptor 

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

func (*JobManagerExecutionInfo) GetIngressURLs 

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

func (*JobManagerExecutionInfo) ProtoMessage 

func (*JobManagerExecutionInfo) ProtoMessage()

func (*JobManagerExecutionInfo) Reset 

func (m *JobManagerExecutionInfo) Reset()

func (*JobManagerExecutionInfo) String 

func (m *JobManagerExecutionInfo) String() string

func (*JobManagerExecutionInfo) Validate 

func (m *JobManagerExecutionInfo) Validate() error

Validate checks the field values on JobManagerExecutionInfo with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*JobManagerExecutionInfo) XXX_DiscardUnknown 

func (m *JobManagerExecutionInfo) XXX_DiscardUnknown()

func (*JobManagerExecutionInfo) XXX_Marshal 

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

func (*JobManagerExecutionInfo) XXX_Merge 

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

func (*JobManagerExecutionInfo) XXX_Size 

func (m *JobManagerExecutionInfo) XXX_Size() int

func (*JobManagerExecutionInfo) XXX_Unmarshal 

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

type JobManagerExecutionInfoValidationError 

type JobManagerExecutionInfoValidationError struct {
	// contains filtered or unexported fields
}

JobManagerExecutionInfoValidationError is the validation error returned by JobManagerExecutionInfo.Validate if the designated constraints aren't met.

func (JobManagerExecutionInfoValidationError) Cause 

func (e JobManagerExecutionInfoValidationError) Cause() error

Cause function returns cause value.

func (JobManagerExecutionInfoValidationError) Error 

func (e JobManagerExecutionInfoValidationError) Error() string

Error satisfies the builtin error interface

func (JobManagerExecutionInfoValidationError) ErrorName 

func (e JobManagerExecutionInfoValidationError) ErrorName() string

ErrorName returns error name.

func (JobManagerExecutionInfoValidationError) Field 

func (e JobManagerExecutionInfoValidationError) Field() string

Field function returns field value.

func (JobManagerExecutionInfoValidationError) Key 

func (e JobManagerExecutionInfoValidationError) Key() bool

Key function returns key value.

func (JobManagerExecutionInfoValidationError) Reason 

func (e JobManagerExecutionInfoValidationError) Reason() string

Reason function returns reason value.

type JobManagerValidationError 

type JobManagerValidationError struct {
	// contains filtered or unexported fields
}

JobManagerValidationError is the validation error returned by JobManager.Validate if the designated constraints aren't met.

func (JobManagerValidationError) Cause 

func (e JobManagerValidationError) Cause() error

Cause function returns cause value.

func (JobManagerValidationError) Error 

func (e JobManagerValidationError) Error() string

Error satisfies the builtin error interface

func (JobManagerValidationError) ErrorName 

func (e JobManagerValidationError) ErrorName() string

ErrorName returns error name.

func (JobManagerValidationError) Field 

func (e JobManagerValidationError) Field() string

Field function returns field value.

func (JobManagerValidationError) Key 

func (e JobManagerValidationError) Key() bool

Key function returns key value.

func (JobManagerValidationError) Reason 

func (e JobManagerValidationError) Reason() string

Reason function returns reason value.

type Resource 

type Resource struct {
	Cpu                  *Resource_Quantity         `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory               *Resource_Quantity         `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"`
	PersistentVolume     *Resource_PersistentVolume `protobuf:"bytes,3,opt,name=persistentVolume,proto3" json:"persistentVolume,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*Resource) Descriptor 

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

func (*Resource) GetCpu 

func (m *Resource) GetCpu() *Resource_Quantity

func (*Resource) GetMemory 

func (m *Resource) GetMemory() *Resource_Quantity

func (*Resource) GetPersistentVolume 

func (m *Resource) GetPersistentVolume() *Resource_PersistentVolume

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) Reset 

func (m *Resource) Reset()

func (*Resource) String 

func (m *Resource) String() string

func (*Resource) Validate 

func (m *Resource) Validate() error

Validate checks the field values on Resource with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Resource) XXX_DiscardUnknown 

func (m *Resource) XXX_DiscardUnknown()

func (*Resource) XXX_Marshal 

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

func (*Resource) XXX_Merge 

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

func (*Resource) XXX_Size 

func (m *Resource) XXX_Size() int

func (*Resource) XXX_Unmarshal 

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

type ResourceValidationError 

type ResourceValidationError struct {
	// contains filtered or unexported fields
}

ResourceValidationError is the validation error returned by Resource.Validate if the designated constraints aren't met.

func (ResourceValidationError) Cause 

func (e ResourceValidationError) Cause() error

Cause function returns cause value.

func (ResourceValidationError) Error 

func (e ResourceValidationError) Error() string

Error satisfies the builtin error interface

func (ResourceValidationError) ErrorName 

func (e ResourceValidationError) ErrorName() string

ErrorName returns error name.

func (ResourceValidationError) Field 

func (e ResourceValidationError) Field() string

Field function returns field value.

func (ResourceValidationError) Key 

func (e ResourceValidationError) Key() bool

Key function returns key value.

func (ResourceValidationError) Reason 

func (e ResourceValidationError) Reason() string

Reason function returns reason value.

type Resource_PersistentVolume 

type Resource_PersistentVolume struct {
	Type                 Resource_PersistentVolume_Type `protobuf:"varint,1,opt,name=type,proto3,enum=flyteidl_flink.Resource_PersistentVolume_Type" json:"type,omitempty"`
	Size                 *Resource_Quantity             `protobuf:"bytes,2,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*Resource_PersistentVolume) Descriptor 

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

func (*Resource_PersistentVolume) GetSize 

func (m *Resource_PersistentVolume) GetSize() *Resource_Quantity

func (*Resource_PersistentVolume) GetType 

func (m *Resource_PersistentVolume) GetType() Resource_PersistentVolume_Type

func (*Resource_PersistentVolume) ProtoMessage 

func (*Resource_PersistentVolume) ProtoMessage()

func (*Resource_PersistentVolume) Reset 

func (m *Resource_PersistentVolume) Reset()

func (*Resource_PersistentVolume) String 

func (m *Resource_PersistentVolume) String() string

func (*Resource_PersistentVolume) Validate 

func (m *Resource_PersistentVolume) Validate() error

Validate checks the field values on Resource_PersistentVolume with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Resource_PersistentVolume) XXX_DiscardUnknown 

func (m *Resource_PersistentVolume) XXX_DiscardUnknown()

func (*Resource_PersistentVolume) XXX_Marshal 

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

func (*Resource_PersistentVolume) XXX_Merge 

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

func (*Resource_PersistentVolume) XXX_Size 

func (m *Resource_PersistentVolume) XXX_Size() int

func (*Resource_PersistentVolume) XXX_Unmarshal 

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

type Resource_PersistentVolumeValidationError 

type Resource_PersistentVolumeValidationError struct {
	// contains filtered or unexported fields
}

Resource_PersistentVolumeValidationError is the validation error returned by Resource_PersistentVolume.Validate if the designated constraints aren't met.

func (Resource_PersistentVolumeValidationError) Cause 

func (e Resource_PersistentVolumeValidationError) Cause() error

Cause function returns cause value.

func (Resource_PersistentVolumeValidationError) Error 

func (e Resource_PersistentVolumeValidationError) Error() string

Error satisfies the builtin error interface

func (Resource_PersistentVolumeValidationError) ErrorName 

func (e Resource_PersistentVolumeValidationError) ErrorName() string

ErrorName returns error name.

func (Resource_PersistentVolumeValidationError) Field 

func (e Resource_PersistentVolumeValidationError) Field() string

Field function returns field value.

func (Resource_PersistentVolumeValidationError) Key 

func (e Resource_PersistentVolumeValidationError) Key() bool

Key function returns key value.

func (Resource_PersistentVolumeValidationError) Reason 

func (e Resource_PersistentVolumeValidationError) Reason() string

Reason function returns reason value.

type Resource_PersistentVolume_Type 

type Resource_PersistentVolume_Type int32
const (
	Resource_PersistentVolume_PD_STANDARD Resource_PersistentVolume_Type = 0
	Resource_PersistentVolume_PD_SSD      Resource_PersistentVolume_Type = 1
)

func (Resource_PersistentVolume_Type) EnumDescriptor 

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

func (Resource_PersistentVolume_Type) String 

func (x Resource_PersistentVolume_Type) String() string

type Resource_Quantity 

type Resource_Quantity struct {
	String_              string   `protobuf:"bytes,1,opt,name=string,proto3" json:"string,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Value must be a valid k8s quantity. See https://github.com/kubernetes/apimachinery/blob/master/pkg/api/resource/quantity.go#L30-L80

func (*Resource_Quantity) Descriptor 

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

func (*Resource_Quantity) GetString_ 

func (m *Resource_Quantity) GetString_() string

func (*Resource_Quantity) ProtoMessage 

func (*Resource_Quantity) ProtoMessage()

func (*Resource_Quantity) Reset 

func (m *Resource_Quantity) Reset()

func (*Resource_Quantity) String 

func (m *Resource_Quantity) String() string

func (*Resource_Quantity) Validate 

func (m *Resource_Quantity) Validate() error

Validate checks the field values on Resource_Quantity with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Resource_Quantity) XXX_DiscardUnknown 

func (m *Resource_Quantity) XXX_DiscardUnknown()

func (*Resource_Quantity) XXX_Marshal 

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

func (*Resource_Quantity) XXX_Merge 

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

func (*Resource_Quantity) XXX_Size 

func (m *Resource_Quantity) XXX_Size() int

func (*Resource_Quantity) XXX_Unmarshal 

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

type Resource_QuantityValidationError 

type Resource_QuantityValidationError struct {
	// contains filtered or unexported fields
}

Resource_QuantityValidationError is the validation error returned by Resource_Quantity.Validate if the designated constraints aren't met.

func (Resource_QuantityValidationError) Cause 

func (e Resource_QuantityValidationError) Cause() error

Cause function returns cause value.

func (Resource_QuantityValidationError) Error 

func (e Resource_QuantityValidationError) Error() string

Error satisfies the builtin error interface

func (Resource_QuantityValidationError) ErrorName 

func (e Resource_QuantityValidationError) ErrorName() string

ErrorName returns error name.

func (Resource_QuantityValidationError) Field 

func (e Resource_QuantityValidationError) Field() string

Field function returns field value.

func (Resource_QuantityValidationError) Key 

func (e Resource_QuantityValidationError) Key() bool

Key function returns key value.

func (Resource_QuantityValidationError) Reason 

func (e Resource_QuantityValidationError) Reason() string

Reason function returns reason value.

type TaskManager 

type TaskManager struct {
	Resource             *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Replicas             int32     `protobuf:"varint,2,opt,name=replicas,proto3" json:"replicas,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*TaskManager) Descriptor 

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

func (*TaskManager) GetReplicas 

func (m *TaskManager) GetReplicas() int32

func (*TaskManager) GetResource 

func (m *TaskManager) GetResource() *Resource

func (*TaskManager) ProtoMessage 

func (*TaskManager) ProtoMessage()

func (*TaskManager) Reset 

func (m *TaskManager) Reset()

func (*TaskManager) String 

func (m *TaskManager) String() string

func (*TaskManager) Validate 

func (m *TaskManager) Validate() error

Validate checks the field values on TaskManager with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskManager) XXX_DiscardUnknown 

func (m *TaskManager) XXX_DiscardUnknown()

func (*TaskManager) XXX_Marshal 

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

func (*TaskManager) XXX_Merge 

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

func (*TaskManager) XXX_Size 

func (m *TaskManager) XXX_Size() int

func (*TaskManager) XXX_Unmarshal 

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

type TaskManagerValidationError 

type TaskManagerValidationError struct {
	// contains filtered or unexported fields
}

TaskManagerValidationError is the validation error returned by TaskManager.Validate if the designated constraints aren't met.

func (TaskManagerValidationError) Cause 

func (e TaskManagerValidationError) Cause() error

Cause function returns cause value.

func (TaskManagerValidationError) Error 

func (e TaskManagerValidationError) Error() string

Error satisfies the builtin error interface

func (TaskManagerValidationError) ErrorName 

func (e TaskManagerValidationError) ErrorName() string

ErrorName returns error name.

func (TaskManagerValidationError) Field 

func (e TaskManagerValidationError) Field() string

Field function returns field value.

func (TaskManagerValidationError) Key 

func (e TaskManagerValidationError) Key() bool

Key function returns key value.

func (TaskManagerValidationError) Reason 

func (e TaskManagerValidationError) Reason() string

Reason function returns reason value.

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.