Documentation ¶
Index ¶
- Constants
- Variables
- func ComposeFlinkCluster(data apistructs.BigdataConf, hostURL string) *flinkoperatorv1beta1.FlinkCluster
- type K8sFlink
- func (k *K8sFlink) BatchDelete(ctx context.Context, tasks []*spec.PipelineTask) (interface{}, error)
- func (k *K8sFlink) Create(ctx context.Context, task *spec.PipelineTask) (interface{}, error)
- func (k *K8sFlink) GetClusterInfo(name string) (map[string]string, error)
- func (k *K8sFlink) GetFlinkClusterInfo(ctx context.Context, data apistructs.BigdataConf) (*flinkoperatorv1beta1.FlinkCluster, error)
- func (k *K8sFlink) Inspect(ctx context.Context, task *spec.PipelineTask) (apistructs.TaskInspect, error)
- func (k *K8sFlink) Kind() types.Kind
- func (k *K8sFlink) Name() types.Name
- func (k *K8sFlink) Remove(ctx context.Context, task *spec.PipelineTask) (interface{}, error)
- func (k *K8sFlink) Status(ctx context.Context, task *spec.PipelineTask) (apistructs.StatusDesc, error)
Constants ¶
View Source
const ( DiceRootDomain = "DICE_ROOT_DOMAIN" DiceClusterInfo = "dice-cluster-info" )
View Source
const (
FlinkIngressPrefix = "flinkcluster"
)
Variables ¶
View Source
var Kind = types.Kind("k8sflink")
Functions ¶
func ComposeFlinkCluster ¶
func ComposeFlinkCluster(data apistructs.BigdataConf, hostURL string) *flinkoperatorv1beta1.FlinkCluster
Types ¶
type K8sFlink ¶
type K8sFlink struct {
// contains filtered or unexported fields
}
func New ¶
func New(name types.Name, clusterName string, cluster apistructs.ClusterInfo) (*K8sFlink, error)
func (*K8sFlink) BatchDelete ¶
func (*K8sFlink) GetClusterInfo ¶
func (*K8sFlink) GetFlinkClusterInfo ¶
func (k *K8sFlink) GetFlinkClusterInfo(ctx context.Context, data apistructs.BigdataConf) (*flinkoperatorv1beta1.FlinkCluster, error)
func (*K8sFlink) Inspect ¶
func (k *K8sFlink) Inspect(ctx context.Context, task *spec.PipelineTask) (apistructs.TaskInspect, error)
Inspect k8sflink doesn`t support inspect, flinkcluster`s logs are too long
func (*K8sFlink) Status ¶
func (k *K8sFlink) Status(ctx context.Context, task *spec.PipelineTask) (apistructs.StatusDesc, error)
Click to show internal directories.
Click to hide internal directories.