kv

Documentation

Index

• type IKV
  • func New(ctx context.Context, config broker.Config) (IKV, error)
  • func NewNats(ctx context.Context, conn *natsclient.Client) (IKV, error)
  • func NewRedis(client *redispkg.Client) IKV
• type Nats
  • func (n *Nats) Delete(ctx context.Context, key string, fields ...string) error
  • func (n *Nats) Load(ctx context.Context, key string) (map[string]string, error)
  • func (n *Nats) Store(ctx context.Context, key string, field string, attrs string) error
• type Redis
  • func (r *Redis) Delete(ctx context.Context, key string, fields ...string) error
  • func (r *Redis) Load(ctx context.Context, key string) (map[string]string, error)
  • func (r *Redis) Store(ctx context.Context, key string, field string, attrs string) error

Types

type IKV

type IKV interface {
	Store(ctx context.Context, key string, field string, attrs string) error
	Load(ctx context.Context, key string) (map[string]string, error)
	Delete(ctx context.Context, key string, fields ...string) error
}

IKV interface

func New

func New(ctx context.Context, config broker.Config) (IKV, error)

New KV

func NewNats

func NewNats(ctx context.Context, conn *natsclient.Client) (IKV, error)

NewNats returns NATS kv client

func NewRedis

func NewRedis(client *redispkg.Client) IKV

NewRedis returns redis kv client

type Nats

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

Nats ...

func (*Nats) Delete

func (n *Nats) Delete(ctx context.Context, key string, fields ...string) error

Delete values for a key

func (*Nats) Load

func (n *Nats) Load(ctx context.Context, key string) (map[string]string, error)

Load values for a key

func (*Nats) Store

func (n *Nats) Store(ctx context.Context, key string, field string, attrs string) error

Store key with values

type Redis

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

Redis ...

func (*Redis) Delete

func (r *Redis) Delete(ctx context.Context, key string, fields ...string) error

Delete values for a key

func (*Redis) Load

func (r *Redis) Load(ctx context.Context, key string) (map[string]string, error)

Load values for a key

func (*Redis) Store

func (r *Redis) Store(ctx context.Context, key string, field string, attrs string) error

Store key with values