oss

package

v0.2.7 Latest Latest Go to latest Published: May 9, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Details

View Source

const (
	UserAgent  = "Kusion-Server"
	EnvTimeout = "OSS_TIMEOUT"
)

View Source

var ErrNoExist = errors.New("oss: key not exist")

View Source

var Timeout = 5

Timeout default timeout is 5 second

This section is empty.

type Config struct {
	Endpoint      string
	AccessKey     string
	SecretKey     string
	SecurityToken string
	BucketName    string
}

type Payload struct {
	Data []byte
	MD5  []byte
}

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

func NewRemoteClient(endpoint, accessKey, secretKey, securityToken, bucket string) (*RemoteClient, error)

func (c *RemoteClient) DeleteObject(key string) error

func (c *RemoteClient) Get(objectName string) (*Payload, error)

Get obtains target object from oss bucket.

func (c *RemoteClient) GetObjectMeta(key string) (http.Header, error)

func (c *RemoteClient) GetObjectToFile(key, dstPath string) error

func (c *RemoteClient) GetOssClient() *oss.Client

func (c *RemoteClient) IsObjectExist(key string) (bool, error)

func (c *RemoteClient) ListObjects(prefix string) (*oss.ListObjectsResultV2, error)

func (c *RemoteClient) Ping() error

func (c *RemoteClient) PutObject(key string, val []byte) error

func (c *RemoteClient) PutObjectFromFile(key, path string) error

func (c *RemoteClient) WithBucket(bucket string) *RemoteClient