pgsql

package
v0.0.0-...-804652f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 7, 2020 License: AGPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StringToOriginArray

func StringToOriginArray(s []string) ([]types.Origin, error)

func ToEntity

func ToEntity(x *PGEntity) (*types.Entity, error)

func ToMember

func ToMember(x *PGMember) *types.Member

func ToOriginArray

func ToOriginArray(p pgtype.EnumArray) ([]types.Origin, error)

func ToPGOriginArray

func ToPGOriginArray(x []types.Origin) (*pgtype.EnumArray, error)

Types

type Database

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

func New

func New(dbc *config.DB) (*Database, error)

New creates a new postgres SQL database connection

func (*Database) AddCensus

func (d *Database) AddCensus(entityID, censusID []byte, targetID uuid.UUID, info *types.CensusInfo) error

func (*Database) AddEntity

func (d *Database) AddEntity(entityID []byte, info *types.EntityInfo) error

func (*Database) AddMember

func (d *Database) AddMember(entityID []byte, pubKey []byte, info *types.MemberInfo) (uuid.UUID, error)

func (*Database) AddMemberBulk

func (d *Database) AddMemberBulk(entityID []byte, members []types.Member) error

func (*Database) AddTarget

func (d *Database) AddTarget(entityID []byte, target *types.Target) (uuid.UUID, error)

func (*Database) AddUser

func (d *Database) AddUser(user *types.User) error

func (*Database) Census

func (d *Database) Census(entityID, censusID []byte) (*types.Census, error)

func (*Database) Close

func (d *Database) Close() error

func (*Database) CountCensus

func (d *Database) CountCensus(entityID []byte) (int, error)

func (*Database) CountMembers

func (d *Database) CountMembers(entityID []byte) (int, error)

func (*Database) CountTargets

func (d *Database) CountTargets(entityID []byte) (int, error)

func (*Database) CreateMembersWithTokens

func (d *Database) CreateMembersWithTokens(entityID []byte, tokens []uuid.UUID) error

func (*Database) DeleteMember

func (d *Database) DeleteMember(entityID []byte, memberID uuid.UUID) error

func (*Database) DumpClaims

func (d *Database) DumpClaims(entityID []byte) ([][]byte, error)

func (*Database) Entity

func (d *Database) Entity(entityID []byte) (*types.Entity, error)

func (*Database) EntityHas

func (d *Database) EntityHas(entityID []byte, memberID uuid.UUID) bool

func (*Database) EntityOrigins

func (d *Database) EntityOrigins(entityID []byte) ([]types.Origin, error)

func (*Database) ImportMembers

func (d *Database) ImportMembers(entityID []byte, info []types.MemberInfo) error

func (*Database) ListCensus

func (d *Database) ListCensus(entityID []byte) ([]types.Census, error)

func (*Database) ListMembers

func (d *Database) ListMembers(entityID []byte, filter *types.ListOptions) ([]types.Member, error)

func (*Database) ListTargets

func (d *Database) ListTargets(entityID []byte) ([]types.Target, error)

func (*Database) Member

func (d *Database) Member(entityID []byte, memberID uuid.UUID) (*types.Member, error)

func (*Database) MemberPubKey

func (d *Database) MemberPubKey(entityID, pubKey []byte) (*types.Member, error)

func (*Database) MembersTokensEmails

func (d *Database) MembersTokensEmails(entityID []byte) ([]types.Member, error)

func (*Database) Migrate

func (d *Database) Migrate(source migrate.MigrationSource, dir migrate.MigrationDirection) (int, error)

func (*Database) MigrateStatus

func (d *Database) MigrateStatus() (string, error)

func (*Database) Ping

func (d *Database) Ping() error

func (*Database) Target

func (d *Database) Target(entityID []byte, targetID uuid.UUID) (*types.Target, error)

func (*Database) TargetMembers

func (d *Database) TargetMembers(entityID []byte, targetID uuid.UUID) ([]types.Member, error)

func (*Database) UpdateMember

func (d *Database) UpdateMember(entityID []byte, memberID uuid.UUID, info *types.MemberInfo) error

func (*Database) User

func (d *Database) User(pubKey []byte) (*types.User, error)

type PGEntity

type PGEntity struct {
	types.Entity
	CensusManagersAddresses pgtype.ByteaArray `json:"censusManagersAddresses" db:"pg_census_managers_addresses"`
	Origins                 pgtype.EnumArray  `db:"origins"`
}

func ToPGEntity

func ToPGEntity(x *types.Entity) (*PGEntity, error)

type PGMember

type PGMember struct {
	types.Member
	CustomFields pgtype.JSONB `json:"customFields" db:"pg_custom_fields"`
}

func ToPGMember

func ToPGMember(x *types.Member) (*PGMember, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL