Documentation ¶
Index ¶
- Constants
- Variables
- type AzUtil
- func (p *AzUtil) CleanUncommittedBlocks(blobName string) error
- func (p *AzUtil) CreateContainerIfNotExists() (bool, error)
- func (p *AzUtil) CreatePageBlob(blobName string, size uint64) error
- func (p *AzUtil) GetBlobURLWithReadOnlySASToken(blobName string, expTime time.Time) url.URL
- func (p *AzUtil) IterateBlobList(prefix string, callback BlobCallback) error
- func (p *AzUtil) PutBlock(container string, blobName string, id string, body io.ReadSeeker) error
- func (p *AzUtil) PutBlockBlob(blobName string, body io.ReadSeeker, md5 []byte) error
- func (p *AzUtil) PutBlockList(blobName string, blockIDs []string) error
- func (p *AzUtil) PutEmptyBlockBlob(blobName string) error
- func (p *AzUtil) PutPages(blobName string, start int64, end int64, body io.ReadSeeker) error
- type BlobCallback
- type FileHandlePool
- type HandleMode
- type SourceFilter
- type TransferStatus
- type TransferTracker
Constants ¶
const ( //None No status avaiable. None = iota //Started Indicates that the file was included in the transfer. Started //Completed Indicates that the file was transferred succesfully. Completed //Ignored Indicates that the file was ignored - e.g. empty files... Ignored )
const ProgramVersion = "0.6.14"
ProgramVersion blobporter version
Variables ¶
var HTTPClientTimeout = 90
HTTPClientTimeout HTTP client timeout when reading from HTTP sources and try timeout for blob storage operations.
var UserAgentStr = fmt.Sprintf("%s/%s/%s", "BlobPorter", ProgramVersion, runtime.GOARCH)
UserAgentStr value included in the user-agent header when calling the blob API
Functions ¶
This section is empty.
Types ¶
type AzUtil ¶
type AzUtil struct {
// contains filtered or unexported fields
}
AzUtil TODO
func NewAzUtil ¶
func NewAzUtil(accountName string, accountKey string, container string, baseBlobURL string) (*AzUtil, error)
NewAzUtil TODO
func (*AzUtil) CleanUncommittedBlocks ¶
CleanUncommittedBlocks TODO
func (*AzUtil) CreateContainerIfNotExists ¶
CreateContainerIfNotExists returs true if the container did not exist.
func (*AzUtil) CreatePageBlob ¶
CreatePageBlob TODO
func (*AzUtil) GetBlobURLWithReadOnlySASToken ¶
GetBlobURLWithReadOnlySASToken TODO
func (*AzUtil) IterateBlobList ¶
func (p *AzUtil) IterateBlobList(prefix string, callback BlobCallback) error
IterateBlobList TODO
func (*AzUtil) PutBlockBlob ¶
PutBlockBlob TODO
func (*AzUtil) PutBlockList ¶
PutBlockList TODO
func (*AzUtil) PutEmptyBlockBlob ¶ added in v0.6.14
PutEmptyBlockBlob TODO
type FileHandlePool ¶
type FileHandlePool struct {
// contains filtered or unexported fields
}
FileHandlePool TODO
func NewFileHandlePool ¶
func NewFileHandlePool(maxHandlesPerFile int, mode HandleMode, overwrite bool) *FileHandlePool
NewFileHandlePool TODO
func (*FileHandlePool) CloseHandles ¶
func (f *FileHandlePool) CloseHandles(path string) error
CloseHandles TODO
func (*FileHandlePool) GetHandle ¶
func (f *FileHandlePool) GetHandle(path string) (*os.File, error)
GetHandle TODO
func (*FileHandlePool) ReturnHandle ¶
func (f *FileHandlePool) ReturnHandle(path string, handle *os.File) error
ReturnHandle TODO
type HandleMode ¶
type HandleMode int
HandleMode TODO
const ( //Read read only file handles Read HandleMode = iota //Write write and append file handles Write )
type SourceFilter ¶
SourceFilter TODO
type TransferStatus ¶
type TransferStatus int
TransferStatus TODO
func (TransferStatus) String ¶
func (t TransferStatus) String() string
type TransferTracker ¶
type TransferTracker struct {
// contains filtered or unexported fields
}
TransferTracker TODO
func NewTransferTracker ¶
func NewTransferTracker(logPath string) (*TransferTracker, error)
NewTransferTracker TODO
func (*TransferTracker) IsTransferredAndTrackIfNot ¶
func (t *TransferTracker) IsTransferredAndTrackIfNot(name string, size int64) (bool, error)
IsTransferredAndTrackIfNot returns true if the file was previously transferred. If not, track/log that the transferred was started.
func (*TransferTracker) TrackFileTransferComplete ¶
func (t *TransferTracker) TrackFileTransferComplete(name string) error
TrackFileTransferComplete TODO
func (*TransferTracker) TrackTransferComplete ¶
func (t *TransferTracker) TrackTransferComplete() error
TrackTransferComplete TODO