repository

Documentation

Index

• type ConnectionPoolRepository
  • func NewConnectionPoolRepository(db *pgxpool.Pool) ConnectionPoolRepository
• type RoleRepository
  • func NewRoleRepository(db *pgxpool.Pool) RoleRepository
• type ScriptRepository
  • func NewScriptRepository(db *pgxpool.Pool) ScriptRepository
• type TopicRepository
  • func NewTopicRepository(db *pgxpool.Pool) TopicRepository
• type UserRepository
  • func NewUserRepository(db *pgxpool.Pool) UserRepository

Types

type ConnectionPoolRepository

type ConnectionPoolRepository interface {
	Save(ctx context.Context, logger *zap.Logger, connection models.ConnectionPool) error
	FindById(ctx context.Context, logger *zap.Logger, id int) (*models.ConnectionPool, error)
	FindAll(ctx context.Context, logger *zap.Logger) ([]models.ConnectionPool, error)
	Delete(ctx context.Context, logger *zap.Logger, id int) error
}

func NewConnectionPoolRepository

func NewConnectionPoolRepository(db *pgxpool.Pool) ConnectionPoolRepository

type RoleRepository

type RoleRepository interface {
	Save(ctx context.Context, logger *zap.Logger, role models.Role) error
	FindById(ctx context.Context, logger *zap.Logger, roleName string) (*models.Role, error)
	FindAll(ctx context.Context, logger *zap.Logger) ([]models.Role, error)
	Delete(ctx context.Context, logger *zap.Logger, roleName string) error
}

func NewRoleRepository

func NewRoleRepository(db *pgxpool.Pool) RoleRepository

type ScriptRepository

type ScriptRepository interface {
	Save(ctx context.Context, logger *zap.Logger, script models.Script) error
	FindById(ctx context.Context, logger *zap.Logger, id int) (*models.Script, error)
	FindAll(ctx context.Context, logger *zap.Logger) ([]models.Script, error)
	Delete(ctx context.Context, logger *zap.Logger, id int) error
}

func NewScriptRepository

func NewScriptRepository(db *pgxpool.Pool) ScriptRepository

type TopicRepository

type TopicRepository interface {
	Save(ctx context.Context, logger *zap.Logger, topic models.Topic) error
	FindById(ctx context.Context, logger *zap.Logger, topicName string) (*models.Topic, error)
	FindAll(ctx context.Context, logger *zap.Logger) ([]models.Topic, error)
	Delete(ctx context.Context, logger *zap.Logger, topicName string) error
}

func NewTopicRepository

func NewTopicRepository(db *pgxpool.Pool) TopicRepository

type UserRepository

type UserRepository interface {
	Save(ctx context.Context, logger *zap.Logger, user models.User) error
	FindById(ctx context.Context, logger *zap.Logger, username string) (*models.User, error)
	FindAll(ctx context.Context, logger *zap.Logger) ([]models.User, error)
	Delete(ctx context.Context, logger *zap.Logger, username string) error
}

func NewUserRepository

func NewUserRepository(db *pgxpool.Pool) UserRepository