capepg

Documentation

Index

• Variables
• type CapePg
  • func New(pool Pool) *CapePg
  • func (c *CapePg) AuditLog() db.AuditLogDB
  • func (c *CapePg) Config() db.ConfigDB
  • func (c *CapePg) Contributors() db.ContributorDB
  • func (c *CapePg) OrgPolicyDB() db.OrgPolicyDB
  • func (c *CapePg) Projects() db.ProjectsDB
  • func (c *CapePg) Recoveries() db.RecoveryDB
  • func (c *CapePg) Roles() db.RoleDB
  • func (c *CapePg) Secrets() db.SecretDB
  • func (c *CapePg) Session() db.SessionDB
  • func (c *CapePg) Suggestions() db.SuggestionsDB
  • func (c *CapePg) Tokens() db.TokensDB
  • func (c *CapePg) Users() db.UserDB
• type PgAudit
  • func (p PgAudit) Add(ctx context.Context, event auditModels.Event) error
  • func (p PgAudit) Query(ctx context.Context, options db.QueryAuditLogOptions) ([]auditModels.Event, error)
• type Pool

Variables

var (
	ErrGenericDBError = fmt.Errorf("generic db error")
)

Types

type CapePg

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

CapePg is a postgresql implementation of the cape database interface

func New

func New(pool Pool) *CapePg

func (*CapePg) AuditLog

func (c *CapePg) AuditLog() db.AuditLogDB

func (*CapePg) Config

func (c *CapePg) Config() db.ConfigDB

func (*CapePg) Contributors

func (c *CapePg) Contributors() db.ContributorDB

func (*CapePg) OrgPolicyDB

func (c *CapePg) OrgPolicyDB() db.OrgPolicyDB

func (*CapePg) Projects

func (c *CapePg) Projects() db.ProjectsDB

func (*CapePg) Recoveries

func (c *CapePg) Recoveries() db.RecoveryDB

func (*CapePg) Roles

func (c *CapePg) Roles() db.RoleDB

func (*CapePg) Secrets

func (c *CapePg) Secrets() db.SecretDB

func (*CapePg) Session

func (c *CapePg) Session() db.SessionDB

func (*CapePg) Suggestions

func (c *CapePg) Suggestions() db.SuggestionsDB

func (*CapePg) Tokens

func (c *CapePg) Tokens() db.TokensDB

func (*CapePg) Users

func (c *CapePg) Users() db.UserDB

type PgAudit

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

func (PgAudit) Add

func (p PgAudit) Add(ctx context.Context, event auditModels.Event) error

func (PgAudit) Query

func (p PgAudit) Query(ctx context.Context, options db.QueryAuditLogOptions) ([]auditModels.Event, error)

type Pool

type Pool interface {
	Exec(_ context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)
	Query(_ context.Context, sql string, args ...interface{}) (pgx.Rows, error)
	QueryRow(_ context.Context, sql string, args ...interface{}) pgx.Row
}