swift

package module

Go to main page

Versions in this module

v2

v2.0.4

Jun 3, 2025

Changes in this version

type Connection

+ Token string

v2.0.3

Aug 29, 2024

Changes in this version

type Container

+ QuotaBytes int64

+ QuotaCount int64

v2.0.2

Jun 13, 2023

v2.0.1

Oct 7, 2021

Changes in this version

type Connection

+ FetchUntilEmptyPage bool

+ PartialPageFetchThreshold int

+ func (c *Connection) GetStorageUrl(ctx context.Context) (string, error)

v2.0.0

Jan 22, 2021

Changes in this version

+ const DefaultRetries

+ const DefaultUserAgent

+ const EndpointTypeAdmin

+ const EndpointTypeInternal

+ const EndpointTypePublic

+ const IS_AT_LEAST_GO_16

+ const TimeFormat

+ const UploadTar

+ const UploadTarBzip2

+ const UploadTarGzip

+ var AuthorizationFailed = newError(401, "Authorization Failed")

+ var BadRequest = newError(400, "Bad Request")

+ var ContainerErrorMap = errorMap

+ var ContainerNotEmpty = newError(409, "Container Not Empty")

+ var ContainerNotFound = newError(404, "Container Not Found")

+ var Forbidden = newError(403, "Operation forbidden")

+ var NotLargeObject = errors.New("Not a large object")

+ var NotModified = newError(304, "Not Modified")

+ var ObjectCorrupted = newError(422, "Object Corrupted")

+ var ObjectNotFound = newError(404, "Object Not Found")

+ var RateLimit = newError(498, "Rate Limit")

+ var SLONotSupported = errors.New("SLO not supported")

+ var TimeoutError = newError(408, "Timeout when reading or writing data")

+ var TooLargeObject = newError(413, "Too Large Object")

+ var TooManyRequests = newError(429, "TooManyRequests")

+ func AddExpectAndTransferEncoding(req *http.Request, hasContentLength bool)

+ func FloatStringToTime(s string) (t time.Time, err error)

+ func SetExpectContinueTimeout(tr *http.Transport, t time.Duration)

+ func TimeToFloatString(t time.Time) string

+ type Account struct

+ BytesUsed int64

+ Containers int64

+ Objects int64

+ type Authenticator interface

+ CdnUrl func() string

+ Request func(context.Context, *Connection) (*http.Request, error)

+ Response func(ctx context.Context, resp *http.Response) error

+ StorageUrl func(Internal bool) string

+ Token func() string

+ type BulkDeleteResult struct

+ Errors map[string]error

+ Headers Headers

+ NumberDeleted int64

+ NumberNotFound int64

+ type BulkUploadResult struct

+ Errors map[string]error

+ Headers Headers

+ NumberCreated int64

+ type Connection struct

+ ApiKey string

+ ApplicationCredentialId string

+ ApplicationCredentialName string

+ ApplicationCredentialSecret string

+ Auth Authenticator

+ AuthToken string

+ AuthUrl string

+ AuthVersion int

+ ConnectTimeout time.Duration

+ Domain string

+ DomainId string

+ EndpointType EndpointType

+ Expires time.Time

+ Internal bool

+ Region string

+ Retries int

+ StorageUrl string

+ Tenant string

+ TenantDomain string

+ TenantDomainId string

+ TenantId string

+ Timeout time.Duration

+ Transport http.RoundTripper

+ TrustId string

+ UserAgent string

+ UserId string

+ UserName string

+ func (c *Connection) Account(ctx context.Context) (info Account, headers Headers, err error)

+ func (c *Connection) AccountUpdate(ctx context.Context, h Headers) error

+ func (c *Connection) ApplyEnvironment() (err error)

+ func (c *Connection) Authenticate(ctx context.Context) (err error)

+ func (c *Connection) Authenticated() bool

+ func (c *Connection) BulkDelete(ctx context.Context, container string, objectNames []string) (result BulkDeleteResult, err error)

+ func (c *Connection) BulkDeleteHeaders(ctx context.Context, container string, objectNames []string, h Headers) (result BulkDeleteResult, err error)

+ func (c *Connection) BulkUpload(ctx context.Context, uploadPath string, dataStream io.Reader, format string, ...) (result BulkUploadResult, err error)

+ func (c *Connection) Call(ctx context.Context, targetUrl string, p RequestOpts) (resp *http.Response, headers Headers, err error)

+ func (c *Connection) Container(ctx context.Context, container string) (info Container, headers Headers, err error)

+ func (c *Connection) ContainerCreate(ctx context.Context, container string, h Headers) error

+ func (c *Connection) ContainerDelete(ctx context.Context, container string) error

+ func (c *Connection) ContainerNames(ctx context.Context, opts *ContainersOpts) ([]string, error)

+ func (c *Connection) ContainerNamesAll(ctx context.Context, opts *ContainersOpts) ([]string, error)

+ func (c *Connection) ContainerUpdate(ctx context.Context, container string, h Headers) error

+ func (c *Connection) Containers(ctx context.Context, opts *ContainersOpts) ([]Container, error)

+ func (c *Connection) ContainersAll(ctx context.Context, opts *ContainersOpts) ([]Container, error)

+ func (c *Connection) DynamicLargeObjectCreate(ctx context.Context, opts *LargeObjectOpts) (LargeObjectFile, error)

+ func (c *Connection) DynamicLargeObjectCreateFile(ctx context.Context, opts *LargeObjectOpts) (LargeObjectFile, error)

+ func (c *Connection) DynamicLargeObjectDelete(ctx context.Context, container string, path string) error

+ func (c *Connection) DynamicLargeObjectMove(ctx context.Context, srcContainer string, srcObjectName string, ...) error

+ func (c *Connection) LargeObjectDelete(ctx context.Context, container string, objectName string) error

+ func (c *Connection) LargeObjectGetSegments(ctx context.Context, container string, path string) (string, []Object, error)

+ func (c *Connection) Object(ctx context.Context, container string, objectName string) (info Object, headers Headers, err error)

+ func (c *Connection) ObjectCopy(ctx context.Context, srcContainer string, srcObjectName string, ...) (headers Headers, err error)

+ func (c *Connection) ObjectCreate(ctx context.Context, container string, objectName string, checkHash bool, ...) (file *ObjectCreateFile, err error)

+ func (c *Connection) ObjectDelete(ctx context.Context, container string, objectName string) error

+ func (c *Connection) ObjectGet(ctx context.Context, container string, objectName string, contents io.Writer, ...) (headers Headers, err error)

+ func (c *Connection) ObjectGetBytes(ctx context.Context, container string, objectName string) (contents []byte, err error)

+ func (c *Connection) ObjectGetString(ctx context.Context, container string, objectName string) (contents string, err error)

+ func (c *Connection) ObjectMove(ctx context.Context, srcContainer string, srcObjectName string, ...) (err error)

+ func (c *Connection) ObjectNames(ctx context.Context, container string, opts *ObjectsOpts) ([]string, error)

+ func (c *Connection) ObjectNamesAll(ctx context.Context, container string, opts *ObjectsOpts) ([]string, error)

+ func (c *Connection) ObjectOpen(ctx context.Context, container string, objectName string, checkHash bool, ...) (file *ObjectOpenFile, headers Headers, err error)

+ func (c *Connection) ObjectPut(ctx context.Context, container string, objectName string, contents io.Reader, ...) (headers Headers, err error)

+ func (c *Connection) ObjectPutBytes(ctx context.Context, container string, objectName string, contents []byte, ...) (err error)

+ func (c *Connection) ObjectPutString(ctx context.Context, container string, objectName string, contents string, ...) (err error)

+ func (c *Connection) ObjectSymlinkCreate(ctx context.Context, container string, symlink string, targetAccount string, ...) (headers Headers, err error)

+ func (c *Connection) ObjectTempUrl(container string, objectName string, secretKey string, method string, ...) string

+ func (c *Connection) ObjectUpdate(ctx context.Context, container string, objectName string, h Headers) error

+ func (c *Connection) ObjectUpdateContentType(ctx context.Context, container string, objectName string, contentType string) (err error)

+ func (c *Connection) Objects(ctx context.Context, container string, opts *ObjectsOpts) ([]Object, error)

+ func (c *Connection) ObjectsAll(ctx context.Context, container string, opts *ObjectsOpts) ([]Object, error)

+ func (c *Connection) ObjectsWalk(ctx context.Context, container string, opts *ObjectsOpts, walkFn ObjectsWalkFn) error

+ func (c *Connection) QueryInfo(ctx context.Context) (infos SwiftInfo, err error)

+ func (c *Connection) StaticLargeObjectCreate(ctx context.Context, opts *LargeObjectOpts) (LargeObjectFile, error)

+ func (c *Connection) StaticLargeObjectCreateFile(ctx context.Context, opts *LargeObjectOpts) (LargeObjectFile, error)

+ func (c *Connection) StaticLargeObjectDelete(ctx context.Context, container string, path string) error

+ func (c *Connection) StaticLargeObjectMove(ctx context.Context, srcContainer string, srcObjectName string, ...) error

+ func (c *Connection) UnAuthenticate()

+ func (c *Connection) VersionContainerCreate(ctx context.Context, current, version string) error

+ func (c *Connection) VersionDisable(ctx context.Context, current string) error

+ func (c *Connection) VersionEnable(ctx context.Context, current, version string) error

+ func (c *Connection) VersionObjectList(ctx context.Context, version, object string) ([]string, error)

+ type Container struct

+ Bytes int64

+ Count int64

+ Name string

+ type ContainersOpts struct

+ EndMarker string

+ Headers Headers

+ Limit int

+ Marker string

+ Prefix string

+ type CustomEndpointAuthenticator interface

+ StorageUrlForEndpoint func(endpointType EndpointType) string

+ type DynamicLargeObjectCreateFile struct

+ func (file *DynamicLargeObjectCreateFile) Close() error

+ func (file *DynamicLargeObjectCreateFile) CloseWithContext(ctx context.Context) error

+ func (file *DynamicLargeObjectCreateFile) Flush(ctx context.Context) error

+ func (file *DynamicLargeObjectCreateFile) Seek(offset int64, whence int) (int64, error)

+ func (file *DynamicLargeObjectCreateFile) Size() int64

+ func (file *DynamicLargeObjectCreateFile) Write(buf []byte) (int, error)

+ func (file *DynamicLargeObjectCreateFile) WriteWithContext(ctx context.Context, buf []byte) (int, error)

+ type EndpointType string

+ type Error struct

+ StatusCode int

+ Text string

+ func (e *Error) Error() string

+ type Expireser interface

+ Expires func() time.Time

+ type Headers map[string]string

+ func (h Headers) AccountMetadata() Metadata

+ func (h Headers) ContainerMetadata() Metadata

+ func (h Headers) Metadata(metaPrefix string) Metadata

+ func (h Headers) ObjectMetadata() Metadata

+ func (headers Headers) IsLargeObject() bool

+ func (headers Headers) IsLargeObjectDLO() bool

+ func (headers Headers) IsLargeObjectSLO() bool

+ type LargeObjectFile interface

+ CloseWithContext func(ctx context.Context) error

+ Flush func(ctx context.Context) error

+ Size func() int64

+ WriteWithContext func(ctx context.Context, p []byte) (n int, err error)

+ type LargeObjectOpts struct

+ CheckHash bool

+ ChunkSize int64

+ Container string

+ ContentType string

+ Flags int

+ Hash string

+ Headers Headers

+ MinChunkSize int64

+ NoBuffer bool

+ ObjectName string

+ SegmentContainer string

+ SegmentPrefix string

+ type Metadata map[string]string

+ func (m Metadata) AccountHeaders() Headers

+ func (m Metadata) ContainerHeaders() Headers

+ func (m Metadata) GetModTime() (t time.Time, err error)

+ func (m Metadata) Headers(metaPrefix string) Headers

+ func (m Metadata) ObjectHeaders() Headers

+ func (m Metadata) SetModTime(t time.Time)

+ type Object struct

+ Bytes int64

+ ContentType string

+ Hash string

+ LastModified time.Time

+ Name string

+ ObjectType ObjectType

+ PseudoDirectory bool

+ SLOHash string

+ ServerLastModified string

+ SubDir string

+ type ObjectCreateFile struct

+ func (file *ObjectCreateFile) Close() error

+ func (file *ObjectCreateFile) CloseWithError(err error) error

+ func (file *ObjectCreateFile) Headers() (Headers, error)

+ func (file *ObjectCreateFile) Write(p []byte) (n int, err error)

+ type ObjectOpenFile struct

+ func (file *ObjectOpenFile) Close() (err error)

+ func (file *ObjectOpenFile) Length(ctx context.Context) (int64, error)

+ func (file *ObjectOpenFile) Read(p []byte) (n int, err error)

+ func (file *ObjectOpenFile) Seek(ctx context.Context, offset int64, whence int) (newPos int64, err error)

+ type ObjectType int

+ const DynamicLargeObjectType

+ const RegularObjectType

+ const StaticLargeObjectType

+ type ObjectsOpts struct

+ Delimiter rune

+ EndMarker string

+ Headers Headers

+ KeepMarker bool

+ Limit int

+ Marker string

+ Path string

+ Prefix string

+ type ObjectsWalkFn func(context.Context, *ObjectsOpts) (interface{}, error)

+ type RequestOpts struct

+ Body io.Reader

+ Container string

+ ErrorMap errorMap

+ Headers Headers

+ NoResponse bool

+ ObjectName string

+ OnReAuth func() (string, error)

+ Operation string

+ Parameters url.Values

+ Retries int

+ type StaticLargeObjectCreateFile struct

+ func (file *StaticLargeObjectCreateFile) Close() error

+ func (file *StaticLargeObjectCreateFile) CloseWithContext(ctx context.Context) error

+ func (file *StaticLargeObjectCreateFile) Flush(ctx context.Context) error

+ func (file *StaticLargeObjectCreateFile) Seek(offset int64, whence int) (int64, error)

+ func (file *StaticLargeObjectCreateFile) Size() int64

+ func (file *StaticLargeObjectCreateFile) Write(buf []byte) (int, error)

+ func (file *StaticLargeObjectCreateFile) WriteWithContext(ctx context.Context, buf []byte) (int, error)

+ type SwiftInfo map[string]interface

+ func (i SwiftInfo) SLOMinSegmentSize() int64

+ func (i SwiftInfo) SupportsBulkDelete() bool

+ func (i SwiftInfo) SupportsSLO() bool

Other modules containing this package

github.com/ncw/swift

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