aerospike

type ASClient struct {
	Logger           *logrus.Logger
	Client           *aerospike.Client
	WritePolicy      *aerospike.WritePolicy
	ReadPolicy       *aerospike.BasePolicy
	AccountNamespace config.AerospikeNamespace
}

type AerospikeClient interface {
	GetWriter() DbWriter
	GetReader() DbReader
}

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

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

type DbReader interface {
	ReadRecord(key *aerospike.Key) (record.Record, error)
	KeyExists(key string) (bool, *aerospike.Key, error)
}

type DbWriter interface {
	WriteRecord(key string, record record.Record) error
	WriteRecordWithASKey(key *aerospike.Key, record record.Record) error
}