distributed

Documentation

Index

• type CacheOptions
• type DistributedCache
  • func NewDistributedCache(metrics *metrics.QuantumStorageMetrics, tracer tracing.Tracer, ...) (*DistributedCache, error)
  • func (dc *DistributedCache) Get(ctx context.Context, key string) ([]byte, error)
  • func (dc *DistributedCache) Set(ctx context.Context, key string, value []byte, ttl time.Duration) error

Types

type CacheOptions

type CacheOptions struct {
	Replication int
	TTL         time.Duration
	Consistency string
	Compression bool
}

type DistributedCache

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

func NewDistributedCache

func NewDistributedCache(
	metrics *metrics.QuantumStorageMetrics,
	tracer tracing.Tracer,
	natsConn *nats.Conn,
	options CacheOptions,
) (*DistributedCache, error)

func (*DistributedCache) Get

func (dc *DistributedCache) Get(
	ctx context.Context,
	key string,
) ([]byte, error)

func (*DistributedCache) Set

func (dc *DistributedCache) Set(
	ctx context.Context,
	key string,
	value []byte,
	ttl time.Duration,
) error