repository

Documentation

Index

• Variables
• type RedisRepo
  • func NewRedisRepo(logger *slog.Logger, opts *redis.Options) *RedisRepo
  • func (r *RedisRepo) CheckConnection(ctx context.Context)
  • func (r *RedisRepo) Get(data string) (string, error)
  • func (r *RedisRepo) GetAllKeys(ctx context.Context) []string
  • func (r *RedisRepo) GetAllMessages(data string, ctx context.Context) ([]string, error)
  • func (r *RedisRepo) Insert(data string) error
  • func (r *RedisRepo) Remove(data string) error
• type Repository
• type SqliteRepo
  • func NewSqliteRepo(dsnUri string, logger *slog.Logger) *SqliteRepo
  • func (s *SqliteRepo) Get(data string) (string, error)
  • func (s *SqliteRepo) Insert(data string) error
  • func (s *SqliteRepo) Remove(data string) error

Variables

var (
	NoMessageError = errors.New("no messages in the queue")
)

Types

type RedisRepo

type RedisRepo struct {
	*redis.Client
	// contains filtered or unexported fields
}

func NewRedisRepo

func NewRedisRepo(logger *slog.Logger, opts *redis.Options) *RedisRepo

func (*RedisRepo) CheckConnection

func (r *RedisRepo) CheckConnection(ctx context.Context)

func (*RedisRepo) Get

func (r *RedisRepo) Get(data string) (string, error)

func (*RedisRepo) GetAllKeys

func (r *RedisRepo) GetAllKeys(ctx context.Context) []string

func (*RedisRepo) GetAllMessages

func (r *RedisRepo) GetAllMessages(data string, ctx context.Context) ([]string, error)

func (*RedisRepo) Insert

func (r *RedisRepo) Insert(data string) error

func (*RedisRepo) Remove

func (r *RedisRepo) Remove(data string) error

type Repository

type Repository interface {
	Insert(data string) error
	Remove(data string) error
	Get(data string) (string, error)
}

type SqliteRepo

type SqliteRepo struct {
	*sql.DB
	// contains filtered or unexported fields
}

func NewSqliteRepo

func NewSqliteRepo(dsnUri string, logger *slog.Logger) *SqliteRepo

func (*SqliteRepo) Get

func (s *SqliteRepo) Get(data string) (string, error)

func (*SqliteRepo) Insert

func (s *SqliteRepo) Insert(data string) error

func (*SqliteRepo) Remove

func (s *SqliteRepo) Remove(data string) error