service

package
Version: v1.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 11, 2021 License: Apache-2.0 Imports: 32 Imported by: 4

Documentation

Index

Constants

View Source
const (
	MIN_PART_SIZE   = 5 << 20
	MAX_PART_SIZE   = 5 << 30 // 5GB, max object size in single upload
	MAX_PART_NUMBER = 10000   // max upload part number in one multipart upload
)
View Source
const (
	MICRO_ENVIRONMENT = "MICRO_ENVIRONMENT"
	K8S               = "k8s"
)
View Source
const SecondsOneDay = 60 * 60 * 24

Variables

View Source
var CRUDSupportedClouds = []string{"aws-s3", "azure-blob", "gcp-s3", "hw-obs", "sony-oda", "alibaba-oss", "ceph-s3"}
View Source
var ChunkSize int = 2048
View Source
var ENC_IV_LEN int = 16
View Source
var ENC_KEY_LEN int = 32
View Source
var Ext2IntTierMap map[string]*String2Int

map from cloud vendor name to a map, which is used to map from storage class name to internal tier.

View Source
var Int2ExtTierMap map[string]*Int2String

map from cloud vendor name to a map, which is used to map from internal tier to it's storage class name.

View Source
var SupportedClasses []pb.StorageClass
View Source
var TransitionMap map[int32][]int32

map from a specific tier to an array of tiers, that means transition can happens from the specific tier to those tiers in the array.

Functions

func CheckRights

func CheckRights(ctx context.Context, tenantId4Source string) (bool, string, string, error)

func GetErrCode

func GetErrCode(err error) (errCode int32)

func GetNameFromTier

func GetNameFromTier(tier int32, backendType string) (string, error)

func GetTierFromName added in v1.2.0

func GetTierFromName(name string, backendType string, tier *int32) error

This function returns the OSDS tier fromt the backend Storage Class

func NewS3Service

func NewS3Service() pb.S3Handler

Types

type DataStreamRecv

type DataStreamRecv interface {
	Recv() (*pb.PutDataStream, error)
}

type Int2String

type Int2String map[int32]string

type StreamReader

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

func (*StreamReader) Read

func (dr *StreamReader) Read(p []byte) (n int, err error)

type String2Int

type String2Int map[string]int32

Jump to

Keyboard shortcuts

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