storagereader

Documentation

Index

• type BlobDetails
  • func NewBlobDetails(name, etag string, length, lastModified int64) BlobDetails
• type Config
• type StorageReader
  • func NewStorageReader(accountName, accountKey, containerName string) (*StorageReader, error)
  • func (sr *StorageReader) ListBlobsModifiedBetween(startTime, endTime int64) *[]BlobDetails
  • func (sr *StorageReader) ReadBlobData(path string, startIndex, length int64) []byte

Types

type BlobDetails

type BlobDetails struct {
	Name         string
	PartitionKey string
	RowKey       string
	ETag         string
	Length       int64
	LastModified int64
}

BlobDetails - represents blob list item

func NewBlobDetails

func NewBlobDetails(name, etag string, length, lastModified int64) BlobDetails

NewBlobDetails - Creates a new instance of BlobDetails

type Config

type Config struct {
	// contains filtered or unexported fields
}

Config holds storage reader configuration

type StorageReader

type StorageReader struct {
	// contains filtered or unexported fields
}

StorageReader interacts with Azure Blob storage

func NewStorageReader

func NewStorageReader(accountName, accountKey, containerName string) (*StorageReader, error)

NewStorageReader creates a new instance of StorageReader

func (*StorageReader) ListBlobsModifiedBetween

func (sr *StorageReader) ListBlobsModifiedBetween(startTime, endTime int64) *[]BlobDetails

ListBlobsModifiedBetween - Get list of blobs modified between two specified timestamps

func (*StorageReader) ReadBlobData

func (sr *StorageReader) ReadBlobData(path string, startIndex, length int64) []byte

ReadBlobData - Reads blob from specified starting location