pgpart

Documentation

Index

• Constants
• func MonthStart(now time.Time) time.Time
• type Round
• type Table
  • func (t *Table) DropExpired(ctx context.Context, now time.Time) ([]string, error)
  • func (t *Table) EnsureForward(ctx context.Context, now time.Time) ([]string, error)
  • func (t *Table) Maintain(ctx context.Context, now time.Time) (Round, error)

Constants

const (
	DefaultRetentionMonths = 12

	EnsureAhead = 2
)

Functions

func MonthStart

func MonthStart(now time.Time) time.Time

Types

type Round

type Round struct {
	Skipped bool
	Created []string
	Dropped []string
}

type Table

type Table struct {
	Pool   *pgxpool.Pool
	Parent string

	RetentionMonths int
}

func (*Table) DropExpired

func (t *Table) DropExpired(ctx context.Context, now time.Time) ([]string, error)

func (*Table) EnsureForward

func (t *Table) EnsureForward(ctx context.Context, now time.Time) ([]string, error)

func (*Table) Maintain

func (t *Table) Maintain(ctx context.Context, now time.Time) (Round, error)