postgresql

Documentation

Index

• Variables
• type Store
  • func New(pool *pgxpool.Pool) *Store
  • func (s *Store) Append(ctx context.Context, p *group.Process) error
  • func (s *Store) Load(ctx context.Context, gt group.Type, pid group.PID) (*group.Process, error)
  • func (s *Store) Remove(ctx context.Context, pid group.PID) error
  • func (s *Store) Save(ctx context.Context, p *group.Process) error

Variables

var (
	ErrNoAffectedRows = errors.New("no affected rows")
)

Types

type Store

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

func New

func New(pool *pgxpool.Pool) *Store

func (*Store) Append

func (s *Store) Append(ctx context.Context, p *group.Process) error

func (*Store) Load

func (s *Store) Load(ctx context.Context, gt group.Type, pid group.PID) (*group.Process, error)

func (*Store) Remove

func (s *Store) Remove(ctx context.Context, pid group.PID) error

func (*Store) Save

func (s *Store) Save(ctx context.Context, p *group.Process) error