service

Documentation

Index

• Constants
• Variables
• func CheckRights(ctx context.Context, tenantId4Source string) (bool, string, string, error)
• func GetErrCode(err error) (errCode int32)
• func GetNameFromTier(tier int32, backendType string) (string, error)
• func GetTierFromName(name string, backendType string, tier *int32) error
• func NewS3Service() pb.S3Handler
• type DataStreamRecv
• type Int2String
• type StreamReader
  • func (dr *StreamReader) Read(p []byte) (n int, err error)
• type String2Int

Constants

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
)

const (
	MICRO_ENVIRONMENT = "MICRO_ENVIRONMENT"
	K8S               = "k8s"
)

const SecondsOneDay = 60 * 60 * 24

Variables

var CRUDSupportedClouds = []string{"aws-s3", "azure-blob", "gcp-s3", "hw-obs", "sony-oda", "alibaba-oss", "ceph-s3"}

var ChunkSize int = 2048

var ENC_IV_LEN int = 16

var ENC_KEY_LEN int = 32

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.

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.

var SupportedClasses []pb.StorageClass

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

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