postgres

Documentation

Index

• type Postgres
  • func New(pgEndpoint string) (*Postgres, error)
  • func (p *Postgres) Create(tl *types.TaskStateLog, t *types.Task) error
  • func (p *Postgres) Fetch(taskID, projectID uint64) ([]*types.TaskStateLog, error)
  • func (p *Postgres) ProcessedTaskID(projectID uint64) (uint64, error)
  • func (p *Postgres) UpsertProcessedTask(projectID, taskID uint64) error

Types

type Postgres

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

func New

func New(pgEndpoint string) (*Postgres, error)

func (*Postgres) Create

func (p *Postgres) Create(tl *types.TaskStateLog, t *types.Task) error

func (*Postgres) Fetch

func (p *Postgres) Fetch(taskID, projectID uint64) ([]*types.TaskStateLog, error)

func (*Postgres) ProcessedTaskID

func (p *Postgres) ProcessedTaskID(projectID uint64) (uint64, error)

func (*Postgres) UpsertProcessedTask

func (p *Postgres) UpsertProcessedTask(projectID, taskID uint64) error