pgpartitioner

Documentation

Index

• func PartitionCleanup(tx *sql.Tx, options PgPartitionsDeleteOptions) (partitionTablesDeleted []string, err error)
• func PartitionCreate(tx *sql.Tx, options PgPartitionsCreateOptions) (partitionTablesAdded []string, err error)
• type DailyPartitionOptions
  • func (dailyPartitionOptions *DailyPartitionOptions) BoundarySqlText(boundaryTime time.Time) (boundarySqlTxt string)
  • func (dailyPartitionOptions *DailyPartitionOptions) NextBoundary(curTime time.Time) (boundaryTime time.Time)
  • func (dailyPartitionOptions *DailyPartitionOptions) NotAfterBoundary() (boundaryTime time.Time)
  • func (dailyPartitionOptions *DailyPartitionOptions) NotBeforeBoundary() (boundaryTime time.Time)
  • func (dailyPartitionOptions *DailyPartitionOptions) PartitionTable(curTime time.Time) (partitionTable string)
  • func (dailyPartitionOptions *DailyPartitionOptions) PrevBoundary(curTime time.Time) (boundaryTime time.Time)
  • func (dailyPartitionOptions *DailyPartitionOptions) Table() (table string)
• type HourlyPartitionOptions
  • func (hourlyPartitionOptions *HourlyPartitionOptions) BoundarySqlText(boundaryTime time.Time) (boundarySqlTxt string)
  • func (hourlyPartitionOptions *HourlyPartitionOptions) NextBoundary(curTime time.Time) (boundaryTime time.Time)
  • func (hourlyPartitionOptions *HourlyPartitionOptions) NotAfterBoundary() (boundaryTime time.Time)
  • func (hourlyPartitionOptions *HourlyPartitionOptions) NotBeforeBoundary() (boundaryTime time.Time)
  • func (hourlyPartitionOptions *HourlyPartitionOptions) PartitionTable(curTime time.Time) (partitionTable string)
  • func (hourlyPartitionOptions *HourlyPartitionOptions) PrevBoundary(curTime time.Time) (boundaryTime time.Time)
  • func (hourlyPartitionOptions *HourlyPartitionOptions) Table() (table string)
• type PgPartitionsCreateOptions
• type PgPartitionsDeleteOptions

Functions

func PartitionCleanup

func PartitionCleanup(tx *sql.Tx, options PgPartitionsDeleteOptions) (partitionTablesDeleted []string, err error)

func PartitionCreate

func PartitionCreate(tx *sql.Tx, options PgPartitionsCreateOptions) (partitionTablesAdded []string, err error)

Types

type DailyPartitionOptions

type DailyPartitionOptions struct {
	TableName    string
	DaysForward  int
	DaysBackward int
}

func (*DailyPartitionOptions) BoundarySqlText

func (dailyPartitionOptions *DailyPartitionOptions) BoundarySqlText(boundaryTime time.Time) (boundarySqlTxt string)

func (*DailyPartitionOptions) NextBoundary

func (dailyPartitionOptions *DailyPartitionOptions) NextBoundary(curTime time.Time) (boundaryTime time.Time)

func (*DailyPartitionOptions) NotAfterBoundary

func (dailyPartitionOptions *DailyPartitionOptions) NotAfterBoundary() (boundaryTime time.Time)

func (*DailyPartitionOptions) NotBeforeBoundary

func (dailyPartitionOptions *DailyPartitionOptions) NotBeforeBoundary() (boundaryTime time.Time)

func (*DailyPartitionOptions) PartitionTable

func (dailyPartitionOptions *DailyPartitionOptions) PartitionTable(curTime time.Time) (partitionTable string)

func (*DailyPartitionOptions) PrevBoundary

func (dailyPartitionOptions *DailyPartitionOptions) PrevBoundary(curTime time.Time) (boundaryTime time.Time)

func (*DailyPartitionOptions) Table

func (dailyPartitionOptions *DailyPartitionOptions) Table() (table string)

type HourlyPartitionOptions

type HourlyPartitionOptions struct {
	TableName     string
	HoursForward  int
	HoursBackward int
}

func (*HourlyPartitionOptions) BoundarySqlText

func (hourlyPartitionOptions *HourlyPartitionOptions) BoundarySqlText(boundaryTime time.Time) (boundarySqlTxt string)

func (*HourlyPartitionOptions) NextBoundary

func (hourlyPartitionOptions *HourlyPartitionOptions) NextBoundary(curTime time.Time) (boundaryTime time.Time)

func (*HourlyPartitionOptions) NotAfterBoundary

func (hourlyPartitionOptions *HourlyPartitionOptions) NotAfterBoundary() (boundaryTime time.Time)

func (*HourlyPartitionOptions) NotBeforeBoundary

func (hourlyPartitionOptions *HourlyPartitionOptions) NotBeforeBoundary() (boundaryTime time.Time)

func (*HourlyPartitionOptions) PartitionTable

func (hourlyPartitionOptions *HourlyPartitionOptions) PartitionTable(curTime time.Time) (partitionTable string)

func (*HourlyPartitionOptions) PrevBoundary

func (hourlyPartitionOptions *HourlyPartitionOptions) PrevBoundary(curTime time.Time) (boundaryTime time.Time)

func (*HourlyPartitionOptions) Table

func (hourlyPartitionOptions *HourlyPartitionOptions) Table() (table string)

type PgPartitionsCreateOptions

type PgPartitionsCreateOptions interface {
	Table() (table string)
	BoundarySqlText(boundaryTime time.Time) (boundarySqlTxt string)
	PartitionTable(curTime time.Time) (partitionName string)
	PrevBoundary(curTime time.Time) (boundaryTime time.Time)
	NextBoundary(curTime time.Time) (boundaryTime time.Time)
	NotBeforeBoundary() (boundaryTime time.Time)
	NotAfterBoundary() (boundaryTime time.Time)
}

type PgPartitionsDeleteOptions

type PgPartitionsDeleteOptions interface {
	PartitionTable(curTime time.Time) (partitionName string)
	PrevBoundary(curTime time.Time) (boundaryTime time.Time)
	NotBeforeBoundary() (boundaryTime time.Time)
}