aerospike

Documentation

Overview

Package aerospike provides an aerospike implementation for GeneratorStore

Index

• type GeneratorStore
  • func (gs GeneratorStore) Add(_ context.Context, hfid int64, gName string) (bool, error)
  • func (gs GeneratorStore) InsertOrGet(_ context.Context, g hfid.Generator) (hfid.Generator, int64, error)
  • func (gs GeneratorStore) Upsert(_ context.Context, g hfid.Generator) error

Types

type GeneratorStore

type GeneratorStore struct {
	Client    *aero.Client
	Namespace string
	Set       string
}

GeneratorStore A Struct that wraps an Aerospike Client and implements the GeneratorStore interface provided by HFID. This implementation utilizes a single set with a bin for the generator's properties and another bin for the generator's associated HLL

func (GeneratorStore) Add

func (gs GeneratorStore) Add(_ context.Context, hfid int64, gName string) (bool, error)

Add Implemented using HLLAddOp command

func (GeneratorStore) InsertOrGet

func (gs GeneratorStore) InsertOrGet(_ context.Context, g hfid.Generator) (hfid.Generator, int64, error)

InsertOrGet Implemented using a single Operate command that creates the generator if it doesn't exist and reads the generator properties and the HyperLogLog count estimate.

func (GeneratorStore) Upsert

func (gs GeneratorStore) Upsert(_ context.Context, g hfid.Generator) error

Upsert Implemented using a single MapPutItemsOp command