rediswritekey

Documentation

Index

• type DB
  • func New(adapter redis.Adapter, managerAdapter manager.Manager) DB
  • func (r *DB) CreateNewWriteKey(ctx context.Context, writeKey *proto_source.NewSourceEvent, ...) error
  • func (r *DB) IsWriteKeyValid(ctx context.Context, writeKey string, expirationTime uint) (bool, error)

Types

type DB

type DB struct {
	ManagerAdapter manager.Manager
	// contains filtered or unexported fields
}

func New

func New(adapter redis.Adapter, managerAdapter manager.Manager) DB

New is Constructor redis DB.

func (*DB) CreateNewWriteKey

func (r *DB) CreateNewWriteKey(ctx context.Context, writeKey *proto_source.NewSourceEvent, expirationTime uint) error

func (*DB) IsWriteKeyValid

func (r *DB) IsWriteKeyValid(ctx context.Context, writeKey string, expirationTime uint) (bool, error)