storage

Documentation

Index

• Variables
• type Storage
  • func NewLocalCache(stor Storage, size int, ttl time.Duration) Storage
  • func NewStorage(ctx context.Context, cfgDb config.DbConfig) (s Storage, err error)
  • func NewStorageLogging(stor Storage, log *slog.Logger) Storage
  • func NewStorageMock() Storage

Variables

var ErrConflict = errors.New("channel with the same id is already present")

var ErrInternal = errors.New("internal failure")

var ErrNotFound = errors.New("channel not found")

Types

type Storage

type Storage interface {
	io.Closer
	Create(ctx context.Context, ch model.Channel) (err error)
	Read(ctx context.Context, link string) (ch model.Channel, err error)
	Update(ctx context.Context, link string, last time.Time) (err error)
	Delete(ctx context.Context, link string) (err error)
	GetPage(ctx context.Context, filter model.ChannelFilter, limit uint32, cursor string, order model.Order) (page []model.Channel, err error)
}

func NewLocalCache

func NewLocalCache(stor Storage, size int, ttl time.Duration) Storage

func NewStorage

func NewStorage(ctx context.Context, cfgDb config.DbConfig) (s Storage, err error)

func NewStorageLogging

func NewStorageLogging(stor Storage, log *slog.Logger) Storage

func NewStorageMock

func NewStorageMock() Storage