cache

Documentation

Index

• Variables
• type PharosCache
  • func NewPharosCache(endpoint string, logger *zerolog.Logger) (*PharosCache, error)
  • func (rx *PharosCache) CheckConnected(ctx context.Context) error
  • func (rx *PharosCache) Close()
  • func (rx *PharosCache) Connect(ctx context.Context) error
  • func (rx PharosCache) Get(ctx context.Context, key string) ([]byte, error)
  • func (rx PharosCache) GetExpire(ctx context.Context, key string, ttl time.Duration) ([]byte, error)
  • func (rx PharosCache) GetExpireUnpack(ctx context.Context, key string, ttl time.Duration) ([]byte, error)
  • func (rx PharosCache) Pack(data []byte) []byte
  • func (rx PharosCache) ServiceName() string
  • func (rx PharosCache) SetExpire(ctx context.Context, key string, data []byte, ttl time.Duration) error
  • func (rx PharosCache) SetExpirePack(ctx context.Context, key string, data []byte, ttl time.Duration) error
  • func (rx PharosCache) UnPack(data []byte) ([]byte, error)
  • func (rx *PharosCache) UsedMemory(ctx context.Context) (string, string, string)
  • func (rx PharosCache) Version(ctx context.Context) string

Variables

var ErrKeyNotFound = errors.New("key not found")

Types

type PharosCache

type PharosCache struct {
	Endpoint string
	// contains filtered or unexported fields
}

func NewPharosCache

func NewPharosCache(endpoint string, logger *zerolog.Logger) (*PharosCache, error)

func (*PharosCache) CheckConnected

func (rx *PharosCache) CheckConnected(ctx context.Context) error

func (*PharosCache) Close

func (rx *PharosCache) Close()

func (*PharosCache) Connect

func (rx *PharosCache) Connect(ctx context.Context) error

func (PharosCache) Get

func (rx PharosCache) Get(ctx context.Context, key string) ([]byte, error)

func (PharosCache) GetExpire

func (rx PharosCache) GetExpire(ctx context.Context, key string, ttl time.Duration) ([]byte, error)

get key and expire

func (PharosCache) GetExpireUnpack

func (rx PharosCache) GetExpireUnpack(ctx context.Context, key string, ttl time.Duration) ([]byte, error)

func (PharosCache) Pack

func (rx PharosCache) Pack(data []byte) []byte

func (PharosCache) ServiceName

func (rx PharosCache) ServiceName() string

func (PharosCache) SetExpire

func (rx PharosCache) SetExpire(ctx context.Context, key string, data []byte, ttl time.Duration) error

set key and expire.

func (PharosCache) SetExpirePack

func (rx PharosCache) SetExpirePack(ctx context.Context, key string, data []byte, ttl time.Duration) error

func (PharosCache) UnPack

func (rx PharosCache) UnPack(data []byte) ([]byte, error)

func (*PharosCache) UsedMemory

func (rx *PharosCache) UsedMemory(ctx context.Context) (string, string, string)

retrieve memory usage

func (PharosCache) Version

func (rx PharosCache) Version(ctx context.Context) string