postgres

Documentation

Index

• func ConnectPostgres(ctx context.Context) (*pgxpool.Pool, error)
• func RunMigrations(ctx context.Context, dbUrl string) error
• type CommentRepository
  • func NewCommentRepository(db *pgxpool.Pool) *CommentRepository
  • func (r *CommentRepository) Create(ctx context.Context, comment *domain.Comment) error
  • func (r *CommentRepository) ListByTicket(ctx context.Context, ticketID uuid.UUID) ([]domain.Comment, error)
• type OrganizationRepository
  • func NewOrganizationRepository(db *pgxpool.Pool) *OrganizationRepository
  • func (r *OrganizationRepository) AddMember(ctx context.Context, orgID uuid.UUID, userID uuid.UUID, role string) error
  • func (r *OrganizationRepository) Create(ctx context.Context, org *domain.Organization) error
  • func (r *OrganizationRepository) GetByID(ctx context.Context, id uuid.UUID) (*domain.Organization, error)
  • func (r *OrganizationRepository) GetByShareToken(ctx context.Context, token string) (*domain.Organization, error)
  • func (r *OrganizationRepository) ListByUser(ctx context.Context, userID uuid.UUID) ([]domain.UserMembership, error)
  • func (r *OrganizationRepository) ListMembers(ctx context.Context, orgID uuid.UUID) ([]domain.Member, error)
  • func (r *OrganizationRepository) RemoveMember(ctx context.Context, orgID uuid.UUID, userID uuid.UUID) error
  • func (r *OrganizationRepository) Update(ctx context.Context, org *domain.Organization) error
  • func (r *OrganizationRepository) UpdateMemberRole(ctx context.Context, orgID uuid.UUID, userID uuid.UUID, role string) error
• type TicketRepository
  • func NewTicketRepository(db *pgxpool.Pool) *TicketRepository
  • func (r *TicketRepository) Create(ctx context.Context, ticket *domain.Ticket) error
  • func (r *TicketRepository) GetByID(ctx context.Context, id uuid.UUID) (*domain.Ticket, error)
  • func (r *TicketRepository) List(ctx context.Context, filter port.TicketFilter) ([]domain.Ticket, error)
  • func (r *TicketRepository) Update(ctx context.Context, ticket *domain.Ticket) error
• type UserRepository
  • func NewUserRepository(db *pgxpool.Pool) *UserRepository
  • func (r *UserRepository) Create(ctx context.Context, user *domain.User) error
  • func (r *UserRepository) GetByEmail(ctx context.Context, email string) (*domain.User, error)
  • func (r *UserRepository) GetByID(ctx context.Context, id uuid.UUID) (*domain.User, error)
  • func (r *UserRepository) Update(ctx context.Context, user *domain.User) error

Functions

func ConnectPostgres

func ConnectPostgres(ctx context.Context) (*pgxpool.Pool, error)

ConnectPostgres initializes the pgx connection pool.

func RunMigrations

func RunMigrations(ctx context.Context, dbUrl string) error

RunMigrations connects to the database and runs all pending migrations.

Types

type CommentRepository

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

func NewCommentRepository

func NewCommentRepository(db *pgxpool.Pool) *CommentRepository

func (*CommentRepository) Create

func (r *CommentRepository) Create(ctx context.Context, comment *domain.Comment) error

func (*CommentRepository) ListByTicket

func (r *CommentRepository) ListByTicket(ctx context.Context, ticketID uuid.UUID) ([]domain.Comment, error)

type OrganizationRepository

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

func NewOrganizationRepository

func NewOrganizationRepository(db *pgxpool.Pool) *OrganizationRepository

func (*OrganizationRepository) AddMember

func (r *OrganizationRepository) AddMember(ctx context.Context, orgID uuid.UUID, userID uuid.UUID, role string) error

func (*OrganizationRepository) Create

func (r *OrganizationRepository) Create(ctx context.Context, org *domain.Organization) error

func (*OrganizationRepository) GetByID

func (r *OrganizationRepository) GetByID(ctx context.Context, id uuid.UUID) (*domain.Organization, error)

func (*OrganizationRepository) GetByShareToken

func (r *OrganizationRepository) GetByShareToken(ctx context.Context, token string) (*domain.Organization, error)

func (*OrganizationRepository) ListByUser

func (r *OrganizationRepository) ListByUser(ctx context.Context, userID uuid.UUID) ([]domain.UserMembership, error)

func (*OrganizationRepository) ListMembers

func (r *OrganizationRepository) ListMembers(ctx context.Context, orgID uuid.UUID) ([]domain.Member, error)

func (*OrganizationRepository) RemoveMember

func (r *OrganizationRepository) RemoveMember(ctx context.Context, orgID uuid.UUID, userID uuid.UUID) error

func (*OrganizationRepository) Update

func (r *OrganizationRepository) Update(ctx context.Context, org *domain.Organization) error

func (*OrganizationRepository) UpdateMemberRole

func (r *OrganizationRepository) UpdateMemberRole(ctx context.Context, orgID uuid.UUID, userID uuid.UUID, role string) error

type TicketRepository

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

func NewTicketRepository

func NewTicketRepository(db *pgxpool.Pool) *TicketRepository

func (*TicketRepository) Create

func (r *TicketRepository) Create(ctx context.Context, ticket *domain.Ticket) error

func (*TicketRepository) GetByID

func (r *TicketRepository) GetByID(ctx context.Context, id uuid.UUID) (*domain.Ticket, error)

func (*TicketRepository) List

func (r *TicketRepository) List(ctx context.Context, filter port.TicketFilter) ([]domain.Ticket, error)

func (*TicketRepository) Update

func (r *TicketRepository) Update(ctx context.Context, ticket *domain.Ticket) error

type UserRepository

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

func NewUserRepository

func NewUserRepository(db *pgxpool.Pool) *UserRepository

func (*UserRepository) Create

func (r *UserRepository) Create(ctx context.Context, user *domain.User) error

func (*UserRepository) GetByEmail

func (r *UserRepository) GetByEmail(ctx context.Context, email string) (*domain.User, error)

func (*UserRepository) GetByID

func (r *UserRepository) GetByID(ctx context.Context, id uuid.UUID) (*domain.User, error)

func (*UserRepository) Update

func (r *UserRepository) Update(ctx context.Context, user *domain.User) error