adapters

Documentation

Index

• type CassandraShortUrlRepository
  • func NewCassandraShortUrlRepository(session *gocqlx.Session) *CassandraShortUrlRepository
  • func (r *CassandraShortUrlRepository) CreateShortUrl(_ context.Context, sURL *shorturl.ShortUrl) error
  • func (r *CassandraShortUrlRepository) DeleteShortUrl(_ context.Context, shortUrlId string) error
  • func (r *CassandraShortUrlRepository) GetShortUrl(_ context.Context, shortUrlId string) (*shorturl.ShortUrl, error)
• type KeyGrpc
  • func NewKeyGrpc(client kgs_grpc.KeyServiceClient) KeyGrpc
  • func (s KeyGrpc) DeleteKeys(ctx context.Context, keys []string) error
  • func (s KeyGrpc) GenerateKey(ctx context.Context) (string, error)
• type RedisCacheShortUrlRepository
  • func NewRedisCacheShortUrlRepository(client redis.UniversalClient) *RedisCacheShortUrlRepository
  • func (r *RedisCacheShortUrlRepository) AddShortUrlCache(ctx context.Context, sUrl *shorturl.ShortUrl) error
  • func (r *RedisCacheShortUrlRepository) GetShortUrlCache(ctx context.Context, shortUrlId string) (string, error)

Types

type CassandraShortUrlRepository

type CassandraShortUrlRepository struct {
	// contains filtered or unexported fields
}

func NewCassandraShortUrlRepository

func NewCassandraShortUrlRepository(session *gocqlx.Session) *CassandraShortUrlRepository

func (*CassandraShortUrlRepository) CreateShortUrl

func (r *CassandraShortUrlRepository) CreateShortUrl(_ context.Context, sURL *shorturl.ShortUrl) error

func (*CassandraShortUrlRepository) DeleteShortUrl

func (r *CassandraShortUrlRepository) DeleteShortUrl(_ context.Context, shortUrlId string) error

func (*CassandraShortUrlRepository) GetShortUrl

func (r *CassandraShortUrlRepository) GetShortUrl(_ context.Context, shortUrlId string) (*shorturl.ShortUrl, error)

type KeyGrpc

type KeyGrpc struct {
	// contains filtered or unexported fields
}

func NewKeyGrpc

func NewKeyGrpc(client kgs_grpc.KeyServiceClient) KeyGrpc

func (KeyGrpc) DeleteKeys

func (s KeyGrpc) DeleteKeys(ctx context.Context, keys []string) error

func (KeyGrpc) GenerateKey

func (s KeyGrpc) GenerateKey(ctx context.Context) (string, error)

return generated key

type RedisCacheShortUrlRepository

type RedisCacheShortUrlRepository struct {
	// contains filtered or unexported fields
}

func NewRedisCacheShortUrlRepository

func NewRedisCacheShortUrlRepository(client redis.UniversalClient) *RedisCacheShortUrlRepository

func (*RedisCacheShortUrlRepository) AddShortUrlCache

func (r *RedisCacheShortUrlRepository) AddShortUrlCache(ctx context.Context, sUrl *shorturl.ShortUrl) error

func (*RedisCacheShortUrlRepository) GetShortUrlCache

func (r *RedisCacheShortUrlRepository) GetShortUrlCache(ctx context.Context, shortUrlId string) (string, error)