service

Documentation

Index

• Constants
• Variables
• func CheckRights(ctx context.Context, tenantId4Source string) (bool, string, string, error)
• func GetEncObject(ctx context.Context, req *pb.GetObjectInput, stream pb.S3_GetObjectStream, ...) error
• func GetErrCode(err error) (errCode int32)
• func GetNameFromTier(tier int32, backendType string) (string, error)
• func GetObject(ctx context.Context, req *pb.GetObjectInput, stream pb.S3_GetObjectStream, ...) 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 (
	MAX_PART_SIZE   = 5 << 30 // 5GB, max object size in single upload
	MAX_PART_NUMBER = 10000   // max upload part number in one multipart upload
)

Variables

var ChunkSize int = 2048

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 GetEncObject

func GetEncObject(ctx context.Context, req *pb.GetObjectInput, stream pb.S3_GetObjectStream, s *s3Service) error

func GetErrCode

func GetErrCode(err error) (errCode int32)

func GetNameFromTier

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

func GetObject

func GetObject(ctx context.Context, req *pb.GetObjectInput, stream pb.S3_GetObjectStream, s *s3Service) error

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