pkg

Documentation

Index

• type Command
  • func (c *Command) Build() string
  • func (c *Command) FieldConfig(field, value string) *Command
• type MinioClient
  • func AutoConnMinio(endpoints, accessKeyID, secretAccessKey string) (*MinioClient, error)
  • func (m *MinioClient) TracFile(bucket, prefix string) error
• type ZooKeeper
  • func AutoConnZk(quorum string) (*ZooKeeper, error)
  • func (zoo *ZooKeeper) AutoDelete(path string) error

Types

type Command

type Command struct {
	strings.Builder
}

func (*Command) Build

func (c *Command) Build() string

func (*Command) FieldConfig

func (c *Command) FieldConfig(field, value string) *Command

type MinioClient

type MinioClient struct {
	*minio.Client
}

func AutoConnMinio

func AutoConnMinio(endpoints, accessKeyID, secretAccessKey string) (*MinioClient, error)

func (*MinioClient) TracFile

func (m *MinioClient) TracFile(bucket, prefix string) error

TracFile 清理 minio 中 ha 相关的文件 ，从而达到 flink 可用状态 逻辑如下： 1、如果没有 bucket ，要创建 2、如果有 bucket，要删除指定路径下的 object ，然后创建 2.1、清除逻辑参考 mc 源码 (https://github.com/minio/mc/blob/RELEASE.2022-02-23T03-15-59Z/cmd/rb-main.go#L153) ，批量删除后清除空 bucket

type ZooKeeper

type ZooKeeper struct {
	*zk.Conn
}

func AutoConnZk

func AutoConnZk(quorum string) (*ZooKeeper, error)

func (*ZooKeeper) AutoDelete

func (zoo *ZooKeeper) AutoDelete(path string) error

TODO: 递归删除