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 NewStorageMock() Storage

Variables

var ErrConflict = errors.New("source already registered")

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

var ErrNotFound = errors.New("source not registered")

Types

type Storage

type Storage interface {
	io.Closer
	Create(ctx context.Context, src model.Source) (err error)
	Read(ctx context.Context, srcId string) (src model.Source, err error)
	Update(ctx context.Context, src model.Source) (err error)
	Delete(ctx context.Context, srcId, groupId, userId string) (err error)
	List(ctx context.Context, filter model.Filter, limit uint32, cursor string, order model.Order) (page []string, err error)
	Count(ctx context.Context) (count int64, 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 NewStorageMock

func NewStorageMock() Storage