Documentation
¶
Index ¶
- type Repository
- func (r *Repository) Delete(ctx context.Context, gatewayID ids.GatewayID, id ids.AuthID) error
- func (r *Repository) FindByAPIKeyHash(ctx context.Context, keyHash string) (*domain.Auth, error)
- func (r *Repository) FindByID(ctx context.Context, id ids.AuthID) (*domain.Auth, error)
- func (r *Repository) FindByIDs(ctx context.Context, gatewayID ids.GatewayID, authIDs []ids.AuthID) ([]*domain.Auth, error)
- func (r *Repository) FindEnabledByTypes(ctx context.Context, types []domain.Type) ([]*domain.Auth, error)
- func (r *Repository) List(ctx context.Context, filter domain.ListFilter) ([]*domain.Auth, int, error)
- func (r *Repository) ListEnabledByGatewayAndType(ctx context.Context, gatewayID ids.GatewayID, authType domain.Type) ([]*domain.Auth, error)
- func (r *Repository) Save(ctx context.Context, a *domain.Auth) error
- func (r *Repository) Update(ctx context.Context, a *domain.Auth) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Repository ¶
type Repository struct {
// contains filtered or unexported fields
}
func NewRepository ¶
func NewRepository(conn *database.Connection, appender outbox.Appender) *Repository
NewRepository builds the pgx auth repository from the shared connection. Each write commits its config-snapshot change marker in the same transaction via the injected outbox appender.
func (*Repository) FindByAPIKeyHash ¶
func (*Repository) FindEnabledByTypes ¶
func (*Repository) List ¶
func (r *Repository) List(ctx context.Context, filter domain.ListFilter) ([]*domain.Auth, int, error)
func (*Repository) ListEnabledByGatewayAndType ¶
Source Files
Click to show internal directories.
Click to hide internal directories.