utils

Documentation

Index

• func CursorToState(cursor string) ([]byte, error)
• func GetRootDir() (*string, error)
• func IsDebug(key string) bool
• func MD5(text string) string
• func Migrate(ctx context.Context, hosts []string, params map[string]interface{}, ...) error
• func NewBucket(template string) (string, int64)
• func NewBucketFromTime(template string, t time.Time) (string, int64)
• func NewId(prefix string) string
• func ScanFiles(root, ext string) ([]string, error)
• func StateToCursor(state []byte) string
• func WithHealthCheck(keyPath string) error

Functions

func CursorToState

func CursorToState(cursor string) ([]byte, error)

func GetRootDir

func GetRootDir() (*string, error)

func IsDebug

func IsDebug(key string) bool

func MD5

func MD5(text string) string

func Migrate

func Migrate(ctx context.Context, hosts []string, params map[string]interface{}, dirs []string) error

func NewBucket

func NewBucket(template string) (string, int64)

func NewBucketFromTime

func NewBucketFromTime(template string, t time.Time) (string, int64)

func NewId

func NewId(prefix string) string

func ScanFiles

func ScanFiles(root, ext string) ([]string, error)

func StateToCursor

func StateToCursor(state []byte) string

func WithHealthCheck

func WithHealthCheck(keyPath string) error