postgres

package

Go to main page

Versions in this module

v0

v0.6.2

Jul 2, 2023

Changes in this version

type Resource

+ Title string

type ResourceCols

+ Title string

type ServiceUserRepository

+ func (s ServiceUserRepository) GetByID(ctx context.Context, id string) (serviceuser.ServiceUser, error)

+ func (s ServiceUserRepository) GetByIDs(ctx context.Context, ids []string) ([]serviceuser.ServiceUser, error)

v0.6.1

Jun 28, 2023

v0.6.0

Jun 27, 2023

Changes in this version

+ const TABLE_FLOWS

+ const TABLE_GROUPS

+ const TABLE_INVITATIONS

+ const TABLE_METASCHEMA

+ const TABLE_NAMESPACES

+ const TABLE_ORGANIZATIONS

+ const TABLE_PERMISSIONS

+ const TABLE_POLICIES

+ const TABLE_PROJECTS

+ const TABLE_RELATIONS

+ const TABLE_RESOURCES

+ const TABLE_ROLES

+ const TABLE_SERVICEUSER

+ const TABLE_SERVICEUSERCREDENTIALS

+ const TABLE_SESSIONS

+ const TABLE_USERS

+ var ErrCheckViolation = errors.New("check constraint violation")

+ var ErrDuplicateKey = errors.New("duplicate key")

+ var ErrForeignKeyViolation = errors.New("foreign key violation")

+ var ErrInvalidID = errors.New("invalid id")

+ var ErrInvalidSlug = fmt.Errorf("invalid slug")

+ var ErrInvalidTextRepresentation = errors.New("invalid input syntax type")

+ type Config struct

+ ConnMaxLifeTime time.Duration

+ Driver string

+ MaxIdleConns int

+ MaxOpenConns int

+ MaxQueryTimeout time.Duration

+ URL string

+ type Flow struct

+ CreatedAt time.Time

+ Email string

+ ExpiresAt time.Time

+ ID uuid.UUID

+ Metadata []byte

+ Method string

+ Nonce string

+ type FlowRepository struct

+ Now func() time.Time

+ func NewFlowRepository(logger log.Logger, dbc *db.Client) *FlowRepository

+ func (s *FlowRepository) Delete(ctx context.Context, id uuid.UUID) error

+ func (s *FlowRepository) DeleteExpiredFlows(ctx context.Context) error

+ func (s *FlowRepository) Get(ctx context.Context, id uuid.UUID) (*authenticate.Flow, error)

+ func (s *FlowRepository) Set(ctx context.Context, flow *authenticate.Flow) error

+ type Group struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ ID string

+ Metadata []byte

+ Name string

+ OrgID string

+ State sql.NullString

+ Title sql.NullString

+ UpdatedAt time.Time

+ type GroupRepository struct

+ func NewGroupRepository(dbc *db.Client) *GroupRepository

+ func (r GroupRepository) Create(ctx context.Context, grp group.Group) (group.Group, error)

+ func (r GroupRepository) Delete(ctx context.Context, id string) error

+ func (r GroupRepository) GetByID(ctx context.Context, id string) (group.Group, error)

+ func (r GroupRepository) GetByIDs(ctx context.Context, groupIDs []string, flt group.Filter) ([]group.Group, error)

+ func (r GroupRepository) List(ctx context.Context, flt group.Filter) ([]group.Group, error)

+ func (r GroupRepository) ListGroupRelations(ctx context.Context, objectId string, subject_type string, role string) ([]relation.Relation, error)

+ func (r GroupRepository) SetState(ctx context.Context, id string, state group.State) error

+ func (r GroupRepository) UpdateByID(ctx context.Context, grp group.Group) (group.Group, error)

+ type Invitation struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID uuid.UUID

+ Metadata []byte

+ OrgID string

+ UserID string

+ type InvitationRepository struct

+ Now func() time.Time

+ func NewInvitationRepository(logger log.Logger, dbc *db.Client) *InvitationRepository

+ func (s *InvitationRepository) Delete(ctx context.Context, id uuid.UUID) error

+ func (s *InvitationRepository) GarbageCollect(ctx context.Context) error

+ func (s *InvitationRepository) Get(ctx context.Context, id uuid.UUID) (invitation.Invitation, error)

+ func (s *InvitationRepository) List(ctx context.Context, flt invitation.Filter) ([]invitation.Invitation, error)

+ func (s *InvitationRepository) ListByUser(ctx context.Context, id string) ([]invitation.Invitation, error)

+ func (s *InvitationRepository) Set(ctx context.Context, invite invitation.Invitation) error

+ type MetaSchema struct

+ CreatedAt time.Time

+ ID string

+ Name string

+ Schema string

+ UpdatedAt time.Time

+ type MetaSchemaRepository struct

+ func NewMetaSchemaRepository(logger log.Logger, dbc *db.Client) *MetaSchemaRepository

+ func (m MetaSchemaRepository) Create(ctx context.Context, mschema metaschema.MetaSchema) (metaschema.MetaSchema, error)

+ func (m MetaSchemaRepository) Delete(ctx context.Context, id string) (string, error)

+ func (m MetaSchemaRepository) Get(ctx context.Context, id string) (metaschema.MetaSchema, error)

+ func (m MetaSchemaRepository) List(ctx context.Context) ([]metaschema.MetaSchema, error)

+ func (m MetaSchemaRepository) MigrateDefaults(ctx context.Context) error

+ func (m MetaSchemaRepository) Update(ctx context.Context, id string, mschema metaschema.MetaSchema) (metaschema.MetaSchema, error)

+ type Namespace struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ ID string

+ Metadata []byte

+ Name string

+ UpdatedAt time.Time

+ type NamespaceRepository struct

+ func NewNamespaceRepository(dbc *db.Client) *NamespaceRepository

+ func (r NamespaceRepository) Get(ctx context.Context, id string) (namespace.Namespace, error)

+ func (r NamespaceRepository) List(ctx context.Context) ([]namespace.Namespace, error)

+ func (r NamespaceRepository) Update(ctx context.Context, ns namespace.Namespace) (namespace.Namespace, error)

+ func (r NamespaceRepository) Upsert(ctx context.Context, ns namespace.Namespace) (namespace.Namespace, error)

+ type Organization struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ ID string

+ Metadata []byte

+ Name string

+ State sql.NullString

+ Title sql.NullString

+ UpdatedAt time.Time

+ type OrganizationRepository struct

+ func NewOrganizationRepository(dbc *db.Client) *OrganizationRepository

+ func (r OrganizationRepository) Create(ctx context.Context, org organization.Organization) (organization.Organization, error)

+ func (r OrganizationRepository) Delete(ctx context.Context, id string) error

+ func (r OrganizationRepository) GetByID(ctx context.Context, id string) (organization.Organization, error)

+ func (r OrganizationRepository) GetByIDs(ctx context.Context, ids []string) ([]organization.Organization, error)

+ func (r OrganizationRepository) GetByName(ctx context.Context, name string) (organization.Organization, error)

+ func (r OrganizationRepository) List(ctx context.Context, flt organization.Filter) ([]organization.Organization, error)

+ func (r OrganizationRepository) SetState(ctx context.Context, id string, state organization.State) error

+ func (r OrganizationRepository) UpdateByID(ctx context.Context, org organization.Organization) (organization.Organization, error)

+ func (r OrganizationRepository) UpdateByName(ctx context.Context, org organization.Organization) (organization.Organization, error)

+ type Permission struct

+ CreatedAt time.Time

+ ID string

+ Metadata []byte

+ Name string

+ Namespace Namespace

+ NamespaceID string

+ Slug string

+ UpdatedAt time.Time

+ type PermissionRepository struct

+ func NewPermissionRepository(dbc *db.Client) *PermissionRepository

+ func (r PermissionRepository) Delete(ctx context.Context, id string) error

+ func (r PermissionRepository) Get(ctx context.Context, id string) (permission.Permission, error)

+ func (r PermissionRepository) GetBySlug(ctx context.Context, slug string) (permission.Permission, error)

+ func (r PermissionRepository) List(ctx context.Context, flt permission.Filter) ([]permission.Permission, error)

+ func (r PermissionRepository) Update(ctx context.Context, act permission.Permission) (permission.Permission, error)

+ func (r PermissionRepository) Upsert(ctx context.Context, perm permission.Permission) (permission.Permission, error)

+ type Policy struct

+ CreatedAt time.Time

+ ID string

+ Metadata []byte

+ PrincipalID string

+ PrincipalType string

+ ResourceID string

+ ResourceType string

+ Role Role

+ RoleID string

+ UpdatedAt time.Time

+ type PolicyCols struct

+ CreatedAt time.Time

+ ID string

+ Metadata []byte

+ PrincipalID string

+ PrincipalType string

+ ResourceID string

+ ResourceType string

+ RoleID string

+ UpdatedAt time.Time

+ type PolicyRepository struct

+ func NewPolicyRepository(dbc *db.Client) *PolicyRepository

+ func (r PolicyRepository) Delete(ctx context.Context, id string) error

+ func (r PolicyRepository) Get(ctx context.Context, id string) (policy.Policy, error)

+ func (r PolicyRepository) List(ctx context.Context, flt policy.Filter) ([]policy.Policy, error)

+ func (r PolicyRepository) Update(ctx context.Context, toUpdate policy.Policy) (string, error)

+ func (r PolicyRepository) Upsert(ctx context.Context, pol policy.Policy) (string, error)

+ type Project struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ ID string

+ Metadata []byte

+ Name string

+ OrgID string

+ State sql.NullString

+ Title sql.NullString

+ UpdatedAt time.Time

+ type ProjectRepository struct

+ func NewProjectRepository(dbc *db.Client) *ProjectRepository

+ func (r ProjectRepository) Create(ctx context.Context, prj project.Project) (project.Project, error)

+ func (r ProjectRepository) Delete(ctx context.Context, id string) error

+ func (r ProjectRepository) GetByID(ctx context.Context, id string) (project.Project, error)

+ func (r ProjectRepository) GetByIDs(ctx context.Context, ids []string) ([]project.Project, error)

+ func (r ProjectRepository) GetByName(ctx context.Context, name string) (project.Project, error)

+ func (r ProjectRepository) List(ctx context.Context, flt project.Filter) ([]project.Project, error)

+ func (r ProjectRepository) SetState(ctx context.Context, id string, state project.State) error

+ func (r ProjectRepository) UpdateByID(ctx context.Context, prj project.Project) (project.Project, error)

+ func (r ProjectRepository) UpdateByName(ctx context.Context, prj project.Project) (project.Project, error)

+ type Relation struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ ID string

+ ObjectID string

+ ObjectNamespace Namespace

+ ObjectNamespaceID string

+ RelationName string

+ SubjectID string

+ SubjectNamespace Namespace

+ SubjectNamespaceID string

+ SubjectSubRelationID sql.NullString

+ UpdatedAt time.Time

+ type RelationRepository struct

+ func NewRelationRepository(dbc *db.Client) *RelationRepository

+ func (r RelationRepository) DeleteByID(ctx context.Context, id string) error

+ func (r RelationRepository) Get(ctx context.Context, id string) (relation.Relation, error)

+ func (r RelationRepository) GetByFields(ctx context.Context, rel relation.Relation) ([]relation.Relation, error)

+ func (r RelationRepository) List(ctx context.Context) ([]relation.Relation, error)

+ func (r RelationRepository) ListByFields(ctx context.Context, rel relation.Relation) ([]relation.Relation, error)

+ func (r RelationRepository) Upsert(ctx context.Context, relationToCreate relation.Relation) (relation.Relation, error)

+ type Resource struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ ID string

+ Metadata []byte

+ Name string

+ Namespace Namespace

+ NamespaceID string

+ PrincipalID sql.NullString

+ PrincipalType sql.NullString

+ Project Project

+ ProjectID string

+ URN string

+ UpdatedAt time.Time

+ type ResourceCols struct

+ CreatedAt time.Time

+ ID string

+ Metadata []byte

+ Name string

+ NamespaceID string

+ PrincipalID sql.NullString

+ PrincipalType sql.NullString

+ ProjectID string

+ URN string

+ UpdatedAt time.Time

+ type ResourceRepository struct

+ func NewResourceRepository(dbc *db.Client) *ResourceRepository

+ func (r ResourceRepository) Create(ctx context.Context, res resource.Resource) (resource.Resource, error)

+ func (r ResourceRepository) Delete(ctx context.Context, id string) error

+ func (r ResourceRepository) GetByID(ctx context.Context, id string) (resource.Resource, error)

+ func (r ResourceRepository) GetByNamespace(ctx context.Context, name string, ns string) (resource.Resource, error)

+ func (r ResourceRepository) GetByURN(ctx context.Context, urn string) (resource.Resource, error)

+ func (r ResourceRepository) List(ctx context.Context, flt resource.Filter) ([]resource.Resource, error)

+ func (r ResourceRepository) Update(ctx context.Context, res resource.Resource) (resource.Resource, error)

+ type Role struct

+ CreatedAt time.Time

+ ID string

+ Metadata []byte

+ Name string

+ OrgID string

+ Permissions []byte

+ State string

+ UpdatedAt time.Time

+ type RoleRepository struct

+ func NewRoleRepository(dbc *db.Client) *RoleRepository

+ func (r RoleRepository) Delete(ctx context.Context, id string) error

+ func (r RoleRepository) Get(ctx context.Context, id string) (role.Role, error)

+ func (r RoleRepository) GetByName(ctx context.Context, orgID, name string) (role.Role, error)

+ func (r RoleRepository) List(ctx context.Context, flt role.Filter) ([]role.Role, error)

+ func (r RoleRepository) Update(ctx context.Context, rl role.Role) (string, error)

+ func (r RoleRepository) Upsert(ctx context.Context, rl role.Role) (string, error)

+ type ServiceUser struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ ID string

+ Metadata []byte

+ OrgID string

+ State sql.NullString

+ Title sql.NullString

+ UpdatedAt time.Time

+ type ServiceUserCredential struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ ID string

+ Metadata []byte

+ PublicKey []byte

+ SecretHash sql.NullString

+ ServiceUserID string

+ Title sql.NullString

+ UpdatedAt time.Time

+ type ServiceUserCredentialRepository struct

+ func NewServiceUserCredentialRepository(dbc *db.Client) *ServiceUserCredentialRepository

+ func (s ServiceUserCredentialRepository) Create(ctx context.Context, credential serviceuser.Credential) (serviceuser.Credential, error)

+ func (s ServiceUserCredentialRepository) Delete(ctx context.Context, id string) error

+ func (s ServiceUserCredentialRepository) Get(ctx context.Context, id string) (serviceuser.Credential, error)

+ func (s ServiceUserCredentialRepository) List(ctx context.Context, flt serviceuser.Filter) ([]serviceuser.Credential, error)

+ type ServiceUserRepository struct

+ func NewServiceUserRepository(dbc *db.Client) *ServiceUserRepository

+ func (s ServiceUserRepository) Create(ctx context.Context, serviceUser serviceuser.ServiceUser) (serviceuser.ServiceUser, error)

+ func (s ServiceUserRepository) Delete(ctx context.Context, id string) error

+ func (s ServiceUserRepository) Get(ctx context.Context, id string) (serviceuser.ServiceUser, error)

+ func (s ServiceUserRepository) List(ctx context.Context, flt serviceuser.Filter) ([]serviceuser.ServiceUser, error)

+ type Session struct

+ AuthenticatedAt time.Time

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID uuid.UUID

+ Metadata []byte

+ UserID uuid.UUID

+ type SessionRepository struct

+ Now func() time.Time

+ func NewSessionRepository(logger log.Logger, dbc *db.Client) *SessionRepository

+ func (s *SessionRepository) Delete(ctx context.Context, id uuid.UUID) error

+ func (s *SessionRepository) DeleteExpiredSessions(ctx context.Context) error

+ func (s *SessionRepository) Get(ctx context.Context, id uuid.UUID) (*shieldsession.Session, error)

+ func (s *SessionRepository) Set(ctx context.Context, session *shieldsession.Session) error

+ func (s *SessionRepository) UpdateValidity(ctx context.Context, id uuid.UUID, validity time.Duration) error

+ type User struct

+ CreatedAt time.Time

+ DeletedAt sql.NullTime

+ Email string

+ ID string

+ Metadata []byte

+ Name string

+ State sql.NullString

+ Title sql.NullString

+ UpdatedAt time.Time

+ type UserRepository struct

+ func NewUserRepository(dbc *db.Client) *UserRepository

+ func (r UserRepository) Create(ctx context.Context, usr user.User) (user.User, error)

+ func (r UserRepository) Delete(ctx context.Context, id string) error

+ func (r UserRepository) GetByEmail(ctx context.Context, email string) (user.User, error)

+ func (r UserRepository) GetByID(ctx context.Context, id string) (user.User, error)

+ func (r UserRepository) GetByIDs(ctx context.Context, userIDs []string) ([]user.User, error)

+ func (r UserRepository) GetByName(ctx context.Context, name string) (user.User, error)

+ func (r UserRepository) List(ctx context.Context, flt user.Filter) ([]user.User, error)

+ func (r UserRepository) SetState(ctx context.Context, id string, state user.State) error

+ func (r UserRepository) UpdateByEmail(ctx context.Context, usr user.User) (user.User, error)

+ func (r UserRepository) UpdateByID(ctx context.Context, usr user.User) (user.User, error)

+ func (r UserRepository) UpdateByName(ctx context.Context, usr user.User) (user.User, error)

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