persist

Documentation

Overview

Package persist provides a persistence layer for the in-memory cache

Package persist provides a bootstrap for the in-memory cache

Package persist provides a persistence layer for the in-memory cache

Package persist provides a bootstrap for the in-memory cache

Package persist provides a persistence layer for the in-memory cache

Index

• Variables
• func DefaultDiskPath(configPath string, override string) string
• type Cacher
  • func FromEnv(backend string, path string, configPath string, reposOverride string) (Cacher, error)
  • func New(cfg Config) (Cacher, error)
  • func NewCloudSQL(cfg Config) (Cacher, error)
• type Config
• type Disk
  • func NewDisk(cfg Config) (*Disk, error)
  • func (d *Disk) DeleteOlderThan(key string, t time.Time) error
  • func (d *Disk) GetNewerThan(key string, t time.Time) *Thing
  • func (d *Disk) Initialize() error
  • func (d *Disk) Save() error
  • func (d *Disk) Set(key string, t *Thing) error
  • func (d *Disk) String() string
• type Memory
  • func NewMemory(cfg Config) (*Memory, error)
  • func (m *Memory) DeleteOlderThan(key string, t time.Time) error
  • func (m *Memory) GetNewerThan(key string, t time.Time) *Thing
  • func (m *Memory) Initialize() error
  • func (m *Memory) Save() error
  • func (m *Memory) Set(key string, t *Thing) error
  • func (m *Memory) String() string
• type MySQL
  • func NewMySQL(cfg Config) (*MySQL, error)
  • func (m *MySQL) DeleteOlderThan(key string, t time.Time) error
  • func (m *MySQL) GetNewerThan(key string, t time.Time) *Thing
  • func (m *MySQL) Initialize() error
  • func (m *MySQL) Save() error
  • func (m *MySQL) Set(key string, th *Thing) error
  • func (m *MySQL) String() string
• type Postgres
  • func NewPostgres(cfg Config) (*Postgres, error)
  • func (m *Postgres) DeleteOlderThan(key string, t time.Time) error
  • func (m *Postgres) GetNewerThan(key string, t time.Time) *Thing
  • func (m *Postgres) Initialize() error
  • func (m *Postgres) Save() error
  • func (m *Postgres) Set(key string, th *Thing) error
  • func (m *Postgres) String() string
• type Thing

Variables

var (
	// MaxSaveAge is the oldest allowable entry to persist
	MaxSaveAge = 30 * 24 * time.Hour
	// MaxLoadAge is the oldest allowable entry to load
	MaxLoadAge = 45 * 24 * time.Hour
)

Functions

func DefaultDiskPath

func DefaultDiskPath(configPath string, override string) string

Types

type Cacher

type Cacher interface {
	String() string

	Set(string, *Thing) error
	DeleteOlderThan(string, time.Time) error
	GetNewerThan(string, time.Time) *Thing

	Initialize() error
	Save() error
}

Cacher is the cache interface we support

func FromEnv

func FromEnv(backend string, path string, configPath string, reposOverride string) (Cacher, error)

FromEnv is shared magic between binaries

func New

func New(cfg Config) (Cacher, error)

func NewCloudSQL

func NewCloudSQL(cfg Config) (Cacher, error)

NewCloudSQL returns a new Google Cloud SQL store (MySQL)

type Config

type Config struct {
	Type string
	Path string
}

Config is cache configuration

type Disk

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

func NewDisk

func NewDisk(cfg Config) (*Disk, error)

NewDisk returns a new disk cache

func (*Disk) DeleteOlderThan

func (d *Disk) DeleteOlderThan(key string, t time.Time) error

DeleteOlderThan deletes a thing older than a timestamp

func (*Disk) GetNewerThan

func (d *Disk) GetNewerThan(key string, t time.Time) *Thing

GetNewerThan returns a thing older than a timestamp

func (*Disk) Initialize

func (d *Disk) Initialize() error

func (*Disk) Save

func (d *Disk) Save() error

func (*Disk) Set

func (d *Disk) Set(key string, t *Thing) error

Set stores a thing into memory

func (*Disk) String

func (d *Disk) String() string

type Memory

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

func NewMemory

func NewMemory(cfg Config) (*Memory, error)

NewMemory returns a new Memory cache

func (*Memory) DeleteOlderThan

func (m *Memory) DeleteOlderThan(key string, t time.Time) error

DeleteOlderThan deletes a thing older than a timestamp

func (*Memory) GetNewerThan

func (m *Memory) GetNewerThan(key string, t time.Time) *Thing

GetNewerThan returns a thing older than a timestamp

func (*Memory) Initialize

func (m *Memory) Initialize() error

func (*Memory) Save

func (m *Memory) Save() error

func (*Memory) Set

func (m *Memory) Set(key string, t *Thing) error

Set stores a thing into memory

func (*Memory) String

func (m *Memory) String() string

type MySQL

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

func NewMySQL

func NewMySQL(cfg Config) (*MySQL, error)

NewMySQL returns a new MySQL cache

func (*MySQL) DeleteOlderThan

func (m *MySQL) DeleteOlderThan(key string, t time.Time) error

DeleteOlderThan deletes a thing older than a timestamp

func (*MySQL) GetNewerThan

func (m *MySQL) GetNewerThan(key string, t time.Time) *Thing

GetNewerThan returns a Item older than a timestamp

func (*MySQL) Initialize

func (m *MySQL) Initialize() error

func (*MySQL) Save

func (m *MySQL) Save() error

func (*MySQL) Set

func (m *MySQL) Set(key string, th *Thing) error

Set stores a thing

func (*MySQL) String

func (m *MySQL) String() string

type Postgres

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

func NewPostgres

func NewPostgres(cfg Config) (*Postgres, error)

NewPostgres returns a new Postgres cache

func (*Postgres) DeleteOlderThan

func (m *Postgres) DeleteOlderThan(key string, t time.Time) error

DeleteOlderThan deletes a thing older than a timestamp

func (*Postgres) GetNewerThan

func (m *Postgres) GetNewerThan(key string, t time.Time) *Thing

GetNewerThan returns a Item older than a timestamp

func (*Postgres) Initialize

func (m *Postgres) Initialize() error

func (*Postgres) Save

func (m *Postgres) Save() error

func (*Postgres) Set

func (m *Postgres) Set(key string, th *Thing) error

Set stores a thing

func (*Postgres) String

func (m *Postgres) String() string

type Thing

type Thing struct {
	Created time.Time

	PullRequests        []*github.PullRequest
	Issues              []*github.Issue
	PullRequestComments []*github.PullRequestComment
	IssueComments       []*github.IssueComment
	Timeline            []*github.Timeline
	Reviews             []*github.PullRequestReview
	StringBool          map[string]bool
}