purger

Documentation

Index

• func FanIn(done <-chan interface{}, channels ...<-chan *TableBatchResult) chan *TableBatchResult
• type AzureTablePurger
  • func NewTablePurger(accountName, accountKey, tableName string, ...) (AzureTablePurger, error)
  • func NewTablePurgerWithClient(client storage.Client, accountName, accountKey, tableName string, ...) (AzureTablePurger, error)
• type DefaultQueryOptionsGenerator
  • func (q *DefaultQueryOptionsGenerator) Generate(done <-chan interface{}) <-chan *storage.QueryOptions
• type DefaultTablePurger
  • func (d *DefaultTablePurger) PurgeEntities() (PurgeResult, error)
  • func (d *DefaultTablePurger) PurgeEntitiesWithin(period *util.Period) (PurgeResult, error)
• type FixedDurationQueryOptionsGenerator
  • func (q *FixedDurationQueryOptionsGenerator) Generate(done <-chan interface{}) <-chan *storage.QueryOptions
• type Partition
• type PurgeResult
  • func (p *PurgeResult) HasErrors() bool
• type QueryOptionsGenerator
  • func NewDefaultQueryOptionsGenerator(start, end time.Time) (QueryOptionsGenerator, error)
  • func SenderWithLogging(duration time.Time) QueryOptionsGenerator
• type QueryOptionsGeneratorFunc
  • func (sf QueryOptionsGeneratorFunc) Generate(done <-chan interface{}) <-chan *storage.QueryOptions
• type QueryResult
• type TableBatchResult

Functions

func FanIn

func FanIn(done <-chan interface{}, channels ...<-chan *TableBatchResult) chan *TableBatchResult

FanIn FanIn

Types

type AzureTablePurger

type AzureTablePurger interface {
	PurgeEntities() (PurgeResult, error)
	PurgeEntitiesWithin(period *util.Period) (PurgeResult, error)
}

AzureTablePurger purges entities from Storage Tables

func NewTablePurger

func NewTablePurger(accountName, accountKey, tableName string, purgeEntitiesOlderThanDays, periodLengthInHours, numWorkers int, usePool, dryRun bool) (AzureTablePurger, error)

NewTablePurger creates a new Basic Purger

func NewTablePurgerWithClient

func NewTablePurgerWithClient(client storage.Client, accountName, accountKey, tableName string, purgeEntitiesOlderThanDays, periodLengthInHours, numWorkers int, usePool, dryRun bool) (AzureTablePurger, error)

NewTablePurgerWithClient creates a new Basic Purger

type DefaultQueryOptionsGenerator

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

func (*DefaultQueryOptionsGenerator) Generate

func (q *DefaultQueryOptionsGenerator) Generate(done <-chan interface{}) <-chan *storage.QueryOptions

type DefaultTablePurger

type DefaultTablePurger struct {
	Metrics *metrics.Metrics
	// contains filtered or unexported fields
}

DefaultTablePurger default table purger

func (*DefaultTablePurger) PurgeEntities

func (d *DefaultTablePurger) PurgeEntities() (PurgeResult, error)

PurgeEntities sdf

func (*DefaultTablePurger) PurgeEntitiesWithin

func (d *DefaultTablePurger) PurgeEntitiesWithin(period *util.Period) (PurgeResult, error)

PurgeEntitiesWithin all entities within Period

type FixedDurationQueryOptionsGenerator

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

func (*FixedDurationQueryOptionsGenerator) Generate

func (q *FixedDurationQueryOptionsGenerator) Generate(done <-chan interface{}) <-chan *storage.QueryOptions

type Partition

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

Partition contains the entities grouped by partition

type PurgeResult

type PurgeResult struct {
	PageCount       int64     `json:"page_count"`
	PartitionCount  int64     `json:"partition_count"`
	RowCount        int64     `json:"row_count"`
	BatchCount      int64     `json:"batch_count"`
	BatchErrorCount int64     `json:"batch_error_count"`
	RowErrorCount   int64     `json:"row_error_count"`
	StartTime       time.Time `json:"start_time"`
	EndTime         time.Time `json:"end_time"`
}

PurgeResult details and metrics about the purge operation

func (*PurgeResult) HasErrors

func (p *PurgeResult) HasErrors() bool

HasErrors whether or not any error occurred during the purge job

type QueryOptionsGenerator

type QueryOptionsGenerator interface {
	Generate(done <-chan interface{}) <-chan *storage.QueryOptions
}

func NewDefaultQueryOptionsGenerator

func NewDefaultQueryOptionsGenerator(start, end time.Time) (QueryOptionsGenerator, error)

func SenderWithLogging

func SenderWithLogging(duration time.Time) QueryOptionsGenerator

type QueryOptionsGeneratorFunc

type QueryOptionsGeneratorFunc func(done <-chan interface{}) <-chan *storage.QueryOptions

QueryOptionsGeneratorFunc is a method that implements the Sender interface.

func (QueryOptionsGeneratorFunc) Generate

func (sf QueryOptionsGeneratorFunc) Generate(done <-chan interface{}) <-chan *storage.QueryOptions

Generate implements the QueryOptionsGenerator interface on QueryOptionsGeneratorFunc.

type QueryResult

type QueryResult struct {
	Error             error
	EntityQueryResult *storage.EntityQueryResult
}

QueryResult groups 2 query possible outcomes

type TableBatchResult

type TableBatchResult struct {
	Error error
	Batch *storage.TableBatch
}

TableBatchResult holds the result of a batch operation