kk_minio

package

v0.0.0-...-2c2b435 Latest Latest Go to latest Published: Apr 30, 2024 License: BSD-3-Clause Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/cruvie/kk_go_kit

Documentation ¶

Index ¶

Variables
func BatchOperator(stage *kk_stage.Stage, opObjects []OPObject, ...) (err error)
func GetFileStream(stage *kk_stage.Stage, opObject OPObject) (io.Reader, error)
func InitMinIO(stage *kk_stage.Stage, endpoint string, accessKeyID string, ...)
func RemoveIncompleteObject(stage *kk_stage.Stage, opObject OPObject) (err error)
func RemoveObject(stage *kk_stage.Stage, opObject OPObject) (err error)
func RemoveObjectAndIncompleteObject(stage *kk_stage.Stage, opObject OPObject) (err error)
func StatObject(stage *kk_stage.Stage, opObject OPObject) (err error, info *minio.ObjectInfo)
func UploadFile(stage *kk_stage.Stage, opObject OPObject) (err error)
func UploadFileStream(stage *kk_stage.Stage, opObject OPObject) (err error)
type OPObject

Constants ¶

This section is empty.

Variables ¶

View Source

var MinioClient *minio.Client

Functions ¶

func BatchOperator ¶

func BatchOperator(stage *kk_stage.Stage, opObjects []OPObject, operator func(stage *kk_stage.Stage, opObject OPObject) (err error)) (err error)

func GetFileStream ¶

func GetFileStream(stage *kk_stage.Stage, opObject OPObject) (io.Reader, error)

func InitMinIO ¶

func InitMinIO(stage *kk_stage.Stage, endpoint string, accessKeyID string, secretAccessKey string, useSSL bool)

func RemoveIncompleteObject ¶

func RemoveIncompleteObject(stage *kk_stage.Stage, opObject OPObject) (err error)

func RemoveObject ¶

func RemoveObject(stage *kk_stage.Stage, opObject OPObject) (err error)

func RemoveObjectAndIncompleteObject ¶

func RemoveObjectAndIncompleteObject(stage *kk_stage.Stage, opObject OPObject) (err error)

func StatObject ¶

func StatObject(stage *kk_stage.Stage, opObject OPObject) (err error, info *minio.ObjectInfo)

StatObject verifies if object exists, you have permission to access it and returns information about the object.

func UploadFile ¶

func UploadFile(stage *kk_stage.Stage, opObject OPObject) (err error)

UploadFile localFilePath 要上传的本地的文件路径 objectName 文件上传的目的路径（路径+文件名）

func UploadFileStream ¶

func UploadFileStream(stage *kk_stage.Stage, opObject OPObject) (err error)

UploadFileStream objectName 文件上传的目的路径（路径+文件名）

Types ¶

type OPObject ¶

type OPObject struct {
	BucketName    string
	ObjectName    string
	LocalFilePath string
	Reader        io.Reader
	ObjectSize    int64
	ContentType   string
}

Source Files ¶

View all Source files

kk_minio.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL