s3x

package

Go to main page

Versions in this module

v0

v0.1.0

Apr 20, 2020

v0.0.7

Apr 17, 2020

Changes in this version

+ const DSTypeBadger

+ const DSTypeCrdt

+ type DSType string

type TEMX

+ CrdtTopic string

+ DSType DSType

v0.0.6

Mar 20, 2020

v0.0.5

Mar 20, 2020

v0.0.4

Mar 20, 2020

v0.0.3

Mar 2, 2020

Changes in this version

+ var ErrInvalidPartNumber = errors.New("invalid multipart part number")

type ObjectPartInfo

+ LastModified time.Time

+ func (m *ObjectPartInfo) GetLastModified() time.Time

v0.0.2

Feb 4, 2020

Changes in this version

type LedgerBucketEntry

+ Bucket *Bucket

+ func (m *LedgerBucketEntry) GetBucket() *Bucket

type MultipartUpload

+ ObjectInfo *ObjectInfo

+ func (m *MultipartUpload) GetObjectInfo() *ObjectInfo

v0.0.1

Jan 29, 2020

Changes in this version

+ var ErrIntOverflowS3 = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthS3 = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidUploadID = errors.New("invalid multipart upload id")

+ var ErrLedgerBucketDoesNotExist = errors.New("bucket does not exist")

+ var ErrLedgerBucketExists = errors.New("bucket exists")

+ var ErrLedgerNonEmptyBucket = errors.New("bucket is not empty")

+ var ErrLedgerObjectDoesNotExist = errors.New("object does not exist")

+ var ErrUnexpectedEndOfGroupS3 = fmt.Errorf("proto: unexpected end of group")

+ func RegisterInfoAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterInfoAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InfoAPIClient) error

+ func RegisterInfoAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterInfoAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InfoAPIServer) error

+ func RegisterInfoAPIServer(s *grpc.Server, srv InfoAPIServer)

+ type Bucket struct

+ BucketInfo BucketInfo

+ Data []byte

+ Objects map[string]string

+ func (*Bucket) Descriptor() ([]byte, []int)

+ func (*Bucket) ProtoMessage()

+ func (m *Bucket) GetBucketInfo() BucketInfo

+ func (m *Bucket) GetData() []byte

+ func (m *Bucket) GetObjects() map[string]string

+ func (m *Bucket) Marshal() (dAtA []byte, err error)

+ func (m *Bucket) MarshalTo(dAtA []byte) (int, error)

+ func (m *Bucket) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Bucket) Reset()

+ func (m *Bucket) Size() (n int)

+ func (m *Bucket) String() string

+ func (m *Bucket) Unmarshal(dAtA []byte) error

+ func (m *Bucket) XXX_DiscardUnknown()

+ func (m *Bucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Bucket) XXX_Merge(src proto.Message)

+ func (m *Bucket) XXX_Size() int

+ func (m *Bucket) XXX_Unmarshal(b []byte) error

+ type BucketInfo struct

+ Created time.Time

+ Location string

+ Name string

+ func (*BucketInfo) Descriptor() ([]byte, []int)

+ func (*BucketInfo) ProtoMessage()

+ func (m *BucketInfo) GetCreated() time.Time

+ func (m *BucketInfo) GetLocation() string

+ func (m *BucketInfo) GetName() string

+ func (m *BucketInfo) Marshal() (dAtA []byte, err error)

+ func (m *BucketInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *BucketInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BucketInfo) Reset()

+ func (m *BucketInfo) Size() (n int)

+ func (m *BucketInfo) String() string

+ func (m *BucketInfo) Unmarshal(dAtA []byte) error

+ func (m *BucketInfo) XXX_DiscardUnknown()

+ func (m *BucketInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BucketInfo) XXX_Merge(src proto.Message)

+ func (m *BucketInfo) XXX_Size() int

+ func (m *BucketInfo) XXX_Unmarshal(b []byte) error

+ type InfoAPIClient interface

+ GetHash func(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)

+ func NewInfoAPIClient(cc *grpc.ClientConn) InfoAPIClient

+ type InfoAPIServer interface

+ GetHash func(context.Context, *InfoRequest) (*InfoResponse, error)

+ type InfoRequest struct

+ Bucket string

+ Object string

+ ObjectDataOnly bool

+ func (*InfoRequest) Descriptor() ([]byte, []int)

+ func (*InfoRequest) ProtoMessage()

+ func (m *InfoRequest) GetBucket() string

+ func (m *InfoRequest) GetObject() string

+ func (m *InfoRequest) GetObjectDataOnly() bool

+ func (m *InfoRequest) Marshal() (dAtA []byte, err error)

+ func (m *InfoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *InfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *InfoRequest) Reset()

+ func (m *InfoRequest) Size() (n int)

+ func (m *InfoRequest) String() string

+ func (m *InfoRequest) Unmarshal(dAtA []byte) error

+ func (m *InfoRequest) XXX_DiscardUnknown()

+ func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InfoRequest) XXX_Merge(src proto.Message)

+ func (m *InfoRequest) XXX_Size() int

+ func (m *InfoRequest) XXX_Unmarshal(b []byte) error

+ type InfoResponse struct

+ Bucket string

+ Hash string

+ Object string

+ func (*InfoResponse) Descriptor() ([]byte, []int)

+ func (*InfoResponse) ProtoMessage()

+ func (m *InfoResponse) GetBucket() string

+ func (m *InfoResponse) GetHash() string

+ func (m *InfoResponse) GetObject() string

+ func (m *InfoResponse) Marshal() (dAtA []byte, err error)

+ func (m *InfoResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *InfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *InfoResponse) Reset()

+ func (m *InfoResponse) Size() (n int)

+ func (m *InfoResponse) String() string

+ func (m *InfoResponse) Unmarshal(dAtA []byte) error

+ func (m *InfoResponse) XXX_DiscardUnknown()

+ func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InfoResponse) XXX_Merge(src proto.Message)

+ func (m *InfoResponse) XXX_Size() int

+ func (m *InfoResponse) XXX_Unmarshal(b []byte) error

+ type Ledger struct

+ Buckets map[string]LedgerBucketEntry

+ MultipartUploads map[string]MultipartUpload

+ func (*Ledger) Descriptor() ([]byte, []int)

+ func (*Ledger) ProtoMessage()

+ func (m *Ledger) GetBuckets() map[string]LedgerBucketEntry

+ func (m *Ledger) GetMultipartUploads() map[string]MultipartUpload

+ func (m *Ledger) Marshal() (dAtA []byte, err error)

+ func (m *Ledger) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ledger) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ledger) Reset()

+ func (m *Ledger) Size() (n int)

+ func (m *Ledger) String() string

+ func (m *Ledger) Unmarshal(dAtA []byte) error

+ func (m *Ledger) XXX_DiscardUnknown()

+ func (m *Ledger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ledger) XXX_Merge(src proto.Message)

+ func (m *Ledger) XXX_Size() int

+ func (m *Ledger) XXX_Unmarshal(b []byte) error

+ type LedgerBucketEntry struct

+ IpfsHash string

+ Name string

+ Objects map[string]LedgerObjectEntry

+ func (*LedgerBucketEntry) Descriptor() ([]byte, []int)

+ func (*LedgerBucketEntry) ProtoMessage()

+ func (m *LedgerBucketEntry) GetIpfsHash() string

+ func (m *LedgerBucketEntry) GetName() string

+ func (m *LedgerBucketEntry) GetObjects() map[string]LedgerObjectEntry

+ func (m *LedgerBucketEntry) Marshal() (dAtA []byte, err error)

+ func (m *LedgerBucketEntry) MarshalTo(dAtA []byte) (int, error)

+ func (m *LedgerBucketEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LedgerBucketEntry) Reset()

+ func (m *LedgerBucketEntry) Size() (n int)

+ func (m *LedgerBucketEntry) String() string

+ func (m *LedgerBucketEntry) Unmarshal(dAtA []byte) error

+ func (m *LedgerBucketEntry) XXX_DiscardUnknown()

+ func (m *LedgerBucketEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LedgerBucketEntry) XXX_Merge(src proto.Message)

+ func (m *LedgerBucketEntry) XXX_Size() int

+ func (m *LedgerBucketEntry) XXX_Unmarshal(b []byte) error

+ type LedgerObjectEntry struct

+ IpfsHash string

+ Name string

+ func (*LedgerObjectEntry) Descriptor() ([]byte, []int)

+ func (*LedgerObjectEntry) ProtoMessage()

+ func (m *LedgerObjectEntry) GetIpfsHash() string

+ func (m *LedgerObjectEntry) GetName() string

+ func (m *LedgerObjectEntry) Marshal() (dAtA []byte, err error)

+ func (m *LedgerObjectEntry) MarshalTo(dAtA []byte) (int, error)

+ func (m *LedgerObjectEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LedgerObjectEntry) Reset()

+ func (m *LedgerObjectEntry) Size() (n int)

+ func (m *LedgerObjectEntry) String() string

+ func (m *LedgerObjectEntry) Unmarshal(dAtA []byte) error

+ func (m *LedgerObjectEntry) XXX_DiscardUnknown()

+ func (m *LedgerObjectEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LedgerObjectEntry) XXX_Merge(src proto.Message)

+ func (m *LedgerObjectEntry) XXX_Size() int

+ func (m *LedgerObjectEntry) XXX_Unmarshal(b []byte) error

+ type LedgerStore struct

+ func (le *LedgerStore) AbortMultipartUpload(bucketName, multipartID string) error

+ func (le *LedgerStore) AddObjectToBucket(bucketName, objectName, objectHash string) error

+ func (le *LedgerStore) BucketExists(name string) bool

+ func (le *LedgerStore) Close() error

+ func (le *LedgerStore) DeleteBucket(name string) error

+ func (le *LedgerStore) GetBucketHash(name string) (string, error)

+ func (le *LedgerStore) GetBucketNames() ([]string, error)

+ func (le *LedgerStore) GetMultipartHashes(bucket, multipartID string) ([]string, error)

+ func (le *LedgerStore) GetObjectHash(bucketName, objectName string) (string, error)

+ func (le *LedgerStore) GetObjectHashes(bucket string) (map[string]string, error)

+ func (le *LedgerStore) GetObjectParts(id string) ([]ObjectPartInfo, error)

+ func (le *LedgerStore) IsEmptyBucket(name string) error

+ func (le *LedgerStore) MultipartIDExists(id string) error

+ func (le *LedgerStore) NewBucket(name, hash string) error

+ func (le *LedgerStore) NewMultipartUpload(bucketName, objectName, multipartID string) error

+ func (le *LedgerStore) ObjectExists(bucketName, objectName string) error

+ func (le *LedgerStore) PutObjectPart(bucketName, objectName, partHash, multipartID string, partNumber int64) error

+ func (le *LedgerStore) RemoveObject(bucketName, objectName string) error

+ func (le *LedgerStore) UpdateBucketHash(name, hash string) error

+ type MultipartUpload struct

+ Bucket string

+ Id string

+ Object string

+ ObjectParts []ObjectPartInfo

+ func (*MultipartUpload) Descriptor() ([]byte, []int)

+ func (*MultipartUpload) ProtoMessage()

+ func (m *MultipartUpload) GetBucket() string

+ func (m *MultipartUpload) GetId() string

+ func (m *MultipartUpload) GetObject() string

+ func (m *MultipartUpload) GetObjectParts() []ObjectPartInfo

+ func (m *MultipartUpload) Marshal() (dAtA []byte, err error)

+ func (m *MultipartUpload) MarshalTo(dAtA []byte) (int, error)

+ func (m *MultipartUpload) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MultipartUpload) Reset()

+ func (m *MultipartUpload) Size() (n int)

+ func (m *MultipartUpload) String() string

+ func (m *MultipartUpload) Unmarshal(dAtA []byte) error

+ func (m *MultipartUpload) XXX_DiscardUnknown()

+ func (m *MultipartUpload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MultipartUpload) XXX_Merge(src proto.Message)

+ func (m *MultipartUpload) XXX_Size() int

+ func (m *MultipartUpload) XXX_Unmarshal(b []byte) error

+ type Object struct

+ DataHash string

+ ObjectInfo ObjectInfo

+ func (*Object) Descriptor() ([]byte, []int)

+ func (*Object) ProtoMessage()

+ func (m *Object) GetDataHash() string

+ func (m *Object) GetObjectInfo() ObjectInfo

+ func (m *Object) Marshal() (dAtA []byte, err error)

+ func (m *Object) MarshalTo(dAtA []byte) (int, error)

+ func (m *Object) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Object) Reset()

+ func (m *Object) Size() (n int)

+ func (m *Object) String() string

+ func (m *Object) Unmarshal(dAtA []byte) error

+ func (m *Object) XXX_DiscardUnknown()

+ func (m *Object) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Object) XXX_Merge(src proto.Message)

+ func (m *Object) XXX_Size() int

+ func (m *Object) XXX_Unmarshal(b []byte) error

+ type ObjectInfo struct

+ AccTime *time.Time

+ BackendType string

+ Bucket string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ Etag string

+ Expires string

+ IsDir bool

+ MetadataOnly bool

+ ModTime time.Time

+ Name string

+ Parts []ObjectPartInfo

+ Size_ int64

+ StorageClass string

+ UserDefined map[string]string

+ func (*ObjectInfo) Descriptor() ([]byte, []int)

+ func (*ObjectInfo) ProtoMessage()

+ func (m *ObjectInfo) GetAccTime() *time.Time

+ func (m *ObjectInfo) GetBackendType() string

+ func (m *ObjectInfo) GetBucket() string

+ func (m *ObjectInfo) GetContentDisposition() string

+ func (m *ObjectInfo) GetContentEncoding() string

+ func (m *ObjectInfo) GetContentLanguage() string

+ func (m *ObjectInfo) GetContentType() string

+ func (m *ObjectInfo) GetEtag() string

+ func (m *ObjectInfo) GetExpires() string

+ func (m *ObjectInfo) GetIsDir() bool

+ func (m *ObjectInfo) GetMetadataOnly() bool

+ func (m *ObjectInfo) GetModTime() time.Time

+ func (m *ObjectInfo) GetName() string

+ func (m *ObjectInfo) GetParts() []ObjectPartInfo

+ func (m *ObjectInfo) GetSize_() int64

+ func (m *ObjectInfo) GetStorageClass() string

+ func (m *ObjectInfo) GetUserDefined() map[string]string

+ func (m *ObjectInfo) Marshal() (dAtA []byte, err error)

+ func (m *ObjectInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *ObjectInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ObjectInfo) Reset()

+ func (m *ObjectInfo) Size() (n int)

+ func (m *ObjectInfo) String() string

+ func (m *ObjectInfo) Unmarshal(dAtA []byte) error

+ func (m *ObjectInfo) XXX_DiscardUnknown()

+ func (m *ObjectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ObjectInfo) XXX_Merge(src proto.Message)

+ func (m *ObjectInfo) XXX_Size() int

+ func (m *ObjectInfo) XXX_Unmarshal(b []byte) error

+ type ObjectPartInfo struct

+ ActualSize int64

+ DataHash string

+ Etag string

+ Name string

+ Number int64

+ Size_ int64

+ func (*ObjectPartInfo) Descriptor() ([]byte, []int)

+ func (*ObjectPartInfo) ProtoMessage()

+ func (m *ObjectPartInfo) GetActualSize() int64

+ func (m *ObjectPartInfo) GetDataHash() string

+ func (m *ObjectPartInfo) GetEtag() string

+ func (m *ObjectPartInfo) GetName() string

+ func (m *ObjectPartInfo) GetNumber() int64

+ func (m *ObjectPartInfo) GetSize_() int64

+ func (m *ObjectPartInfo) Marshal() (dAtA []byte, err error)

+ func (m *ObjectPartInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *ObjectPartInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ObjectPartInfo) Reset()

+ func (m *ObjectPartInfo) Size() (n int)

+ func (m *ObjectPartInfo) String() string

+ func (m *ObjectPartInfo) Unmarshal(dAtA []byte) error

+ func (m *ObjectPartInfo) XXX_DiscardUnknown()

+ func (m *ObjectPartInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ObjectPartInfo) XXX_Merge(src proto.Message)

+ func (m *ObjectPartInfo) XXX_Size() int

+ func (m *ObjectPartInfo) XXX_Unmarshal(b []byte) error

+ type TEMX struct

+ DSPath string

+ GRPCAddr string

+ HTTPAddr string

+ Insecure bool

+ XAddr string

+ func (g *TEMX) Name() string

+ func (g *TEMX) NewGatewayLayer(creds auth.Credentials) (minio.ObjectLayer, error)

+ func (g *TEMX) Production() bool

+ type UnimplementedInfoAPIServer struct

+ func (*UnimplementedInfoAPIServer) GetHash(ctx context.Context, req *InfoRequest) (*InfoResponse, error)

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