storage

package

Go to main page

Versions in this module

v1

v1.2.2

Apr 9, 2019

v1.2.1

Mar 21, 2019

Changes in this version

type CephStorage

+ func (cluster *CephStorage) Append(poolname string, oid string, data io.Reader, offset uint64, isExist bool) (size int64, err error)

type YigStorage

+ func (yig *YigStorage) AppendObject(bucketName string, objectName string, credential common.Credential, ...) (result datatype.AppendObjectResult, err error)

v1.1.10

Jan 17, 2019

v1.1.9

Jan 9, 2019

Changes in this version

type YigStorage

+ func (y *YigStorage) PingCache(interval time.Duration)

v1.1.8

Dec 26, 2018

Changes in this version

type YigStorage

+ func (yig *YigStorage) UpdateObjectAttrs(targetObject *meta.Object, credential common.Credential) (result datatype.PutObjectResult, err error)

v1.1.7

Dec 22, 2018

v1.1.6

Dec 21, 2018

v1.1.5

Dec 21, 2018

v1.1.4

Dec 11, 2018

v1.1.3

Dec 6, 2018

Changes in this version

type YigStorage

+ KMS crypto.KMS

+ func (yig *YigStorage) DeleteBucketPolicy(credential common.Credential, bucketName string) error

+ func (yig *YigStorage) GetBucketPolicy(credential common.Credential, bucketName string) (bucketPolicy policy.Policy, err error)

+ func (yig *YigStorage) SetBucketPolicy(credential common.Credential, bucketName string, bucketPolicy policy.Policy) (err error)

v1.1.2

Jul 16, 2018

v1.1.1

Jul 5, 2018

v1.1.0

May 8, 2018

Changes in this version

+ const AES_BLOCK_SIZE

+ const AIO_CONCURRENT

+ const BIG_FILE_POOLNAME

+ const BIG_FILE_THRESHOLD

+ const BUFFER_SIZE

+ const CLUSTER_MAX_USED_SPACE_PERCENT

+ const DEFAULT_CEPHCONFIG_PATTERN

+ const ENCRYPTION_KEY_LENGTH

+ const FILE_CACHE_THRESHOLD_SIZE

+ const INITIALIZATION_VECTOR_LENGTH

+ const MAX_CHUNK_SIZE

+ const MAX_PART_NUMBER

+ const MAX_PART_SIZE

+ const MAX_TRY_TIMES

+ const MIN_CHUNK_SIZE

+ const MIN_PART_SIZE

+ const MON_TIMEOUT

+ const OBJECT_SIZE

+ const OSD_TIMEOUT

+ const RECYCLE_QUEUE_SIZE

+ const SMALL_FILE_POOLNAME

+ const STRIPE_COUNT

+ const STRIPE_UNIT

+ var RecycleQueue chan objectToRecycle

+ var RootContext = context.Background()

+ type CephStorage struct

+ Conn *rados.Conn

+ CountMutex *sync.Mutex

+ Counter uint64

+ InstanceId uint64

+ Logger *log.Logger

+ Name string

+ func NewCephStorage(configFile string, logger *log.Logger) *CephStorage

+ func (c *CephStorage) Shutdown()

+ func (cluster *CephStorage) GetUniqUploadName() string

+ func (cluster *CephStorage) GetUsedSpacePercent() (pct int, err error)

+ func (cluster *CephStorage) Put(poolname string, oid string, data io.Reader) (size int64, err error)

+ func (cluster *CephStorage) Remove(poolname string, oid string) error

+ type DataCache interface

+ GetAlignedReader func(object *meta.Object, startOffset int64, length int64, ...) (io.ReadCloser, error)

+ Remove func(key string)

+ WriteFromCache func(object *meta.Object, startOffset int64, length int64, out io.Writer, ...) error

+ type RadosDownloader struct

+ func (rd *RadosDownloader) Close() error

+ func (rd *RadosDownloader) Read(p []byte) (n int, err error)

+ func (rd *RadosDownloader) Seek(offset int64, whence int) (int64, error)

+ type RadosSmallDownloader struct

+ func (rd *RadosSmallDownloader) Close() error

+ func (rd *RadosSmallDownloader) Read(p []byte) (n int, err error)

+ func (rd *RadosSmallDownloader) Seek(offset int64, whence int) (int64, error)

+ type ReadCloser struct

+ func (r *ReadCloser) Close() error

+ func (r *ReadCloser) Read(b []byte) (n int, err error)

+ type YigStorage struct

+ DataCache DataCache

+ DataStorage map[string]*CephStorage

+ Logger *log.Logger

+ MetaStorage *meta.Meta

+ Stopping bool

+ WaitGroup *sync.WaitGroup

+ func New(logger *log.Logger, metaCacheType int, enableDataCache bool, ...) *YigStorage

+ func (y *YigStorage) Stop()

+ func (yig *YigStorage) AbortMultipartUpload(credential iam.Credential, bucketName, objectName, uploadId string) error

+ func (yig *YigStorage) CompleteMultipartUpload(credential iam.Credential, bucketName, objectName, uploadId string, ...) (result datatype.CompleteMultipartResult, err error)

+ func (yig *YigStorage) CopyObject(targetObject *meta.Object, source io.Reader, credential iam.Credential, ...) (result datatype.PutObjectResult, err error)

+ func (yig *YigStorage) CopyObjectPart(bucketName, objectName, uploadId string, partId int, size int64, ...) (result datatype.PutObjectResult, err error)

+ func (yig *YigStorage) DelBucketLc(bucketName string, credential iam.Credential) error

+ func (yig *YigStorage) DeleteBucket(bucketName string, credential iam.Credential) (err error)

+ func (yig *YigStorage) DeleteBucketCors(bucketName string, credential iam.Credential) error

+ func (yig *YigStorage) DeleteObject(bucketName string, objectName string, version string, ...) (result datatype.DeleteObjectResult, err error)

+ func (yig *YigStorage) GetBucket(bucketName string) (meta.Bucket, error)

+ func (yig *YigStorage) GetBucketAcl(bucketName string, credential iam.Credential) (policy datatype.AccessControlPolicy, err error)

+ func (yig *YigStorage) GetBucketCors(bucketName string, credential iam.Credential) (cors datatype.Cors, err error)

+ func (yig *YigStorage) GetBucketInfo(bucketName string, credential iam.Credential) (bucket meta.Bucket, err error)

+ func (yig *YigStorage) GetBucketLc(bucketName string, credential iam.Credential) (lc datatype.Lc, err error)

+ func (yig *YigStorage) GetBucketVersioning(bucketName string, credential iam.Credential) (versioning datatype.Versioning, err error)

+ func (yig *YigStorage) GetClusterByFsName(fsName string) (cluster *CephStorage, err error)

+ func (yig *YigStorage) GetObject(object *meta.Object, startOffset int64, length int64, writer io.Writer, ...) (err error)

+ func (yig *YigStorage) GetObjectAcl(bucketName string, objectName string, version string, ...) (policy datatype.AccessControlPolicy, err error)

+ func (yig *YigStorage) GetObjectInfo(bucketName string, objectName string, version string, ...) (object *meta.Object, err error)

+ func (yig *YigStorage) ListBuckets(credential iam.Credential) (buckets []meta.Bucket, err error)

+ func (yig *YigStorage) ListMultipartUploads(credential iam.Credential, bucketName string, ...) (result datatype.ListMultipartUploadsResponse, err error)

+ func (yig *YigStorage) ListObjectParts(credential iam.Credential, bucketName, objectName string, ...) (result datatype.ListPartsResponse, err error)

+ func (yig *YigStorage) ListObjects(credential iam.Credential, bucketName string, ...) (result meta.ListObjectsInfo, err error)

+ func (yig *YigStorage) ListObjectsInternal(bucketName string, request datatype.ListObjectsRequest) (retObjects []*meta.Object, prefixes []string, truncated bool, ...)

+ func (yig *YigStorage) ListVersionedObjects(credential iam.Credential, bucketName string, ...) (result meta.VersionedListObjectsInfo, err error)

+ func (yig *YigStorage) MakeBucket(bucketName string, acl datatype.Acl, credential iam.Credential) error

+ func (yig *YigStorage) NewMultipartUpload(credential iam.Credential, bucketName, objectName string, ...) (uploadId string, err error)

+ func (yig *YigStorage) PickOneClusterAndPool(bucket string, object string, size int64) (cluster *CephStorage, poolName string)

+ func (yig *YigStorage) PutObject(bucketName string, objectName string, credential iam.Credential, size int64, ...) (result datatype.PutObjectResult, err error)

+ func (yig *YigStorage) PutObjectPart(bucketName, objectName string, credential iam.Credential, uploadId string, ...) (result datatype.PutObjectPartResult, err error)

+ func (yig *YigStorage) SetBucketAcl(bucketName string, policy datatype.AccessControlPolicy, acl datatype.Acl, ...) error

+ func (yig *YigStorage) SetBucketCors(bucketName string, cors datatype.Cors, credential iam.Credential) error

+ func (yig *YigStorage) SetBucketLc(bucketName string, lc datatype.Lc, credential iam.Credential) error

+ func (yig *YigStorage) SetBucketVersioning(bucketName string, versioning datatype.Versioning, credential iam.Credential) error

+ func (yig *YigStorage) SetObjectAcl(bucketName string, objectName string, version string, ...) error

Incompatible versions in this module

v2.0.0+incompatible

Nov 28, 2018

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