Versions in this module Expand all Collapse all v1 v1.0.0 May 14, 2024 Changes in this version + var ErrXGroupNotInitialized = errors.New("consumer group not initialized with XGROUP") + func ToValueMap(data interface{}) map[string]Value + func ToValueMapE(data interface{}) (map[string]Value, error) + type BytesValue struct + B []byte + func (bv BytesValue) ToAV() types.AttributeValue + type Client struct + func NewClient(service *dynamodb.Client) Client + func (c Client) Attributes(pk string, sk string, skN string) Client + func (c Client) CreatePayPerRequestTable() error + func (c Client) CreateProvisionedTable(readCapacity int64, writeCapacity int64) error + func (c Client) CreateTable(readCapacity int64, writeCapacity int64) error + func (c Client) DECR(key string) (after int64, err error) + func (c Client) DECRBY(key string, delta int64) (after int64, err error) + func (c Client) DEL(key string) (deletedFields []string, err error) + func (c Client) EXISTS(key string) (exists bool, err error) + func (c Client) EventuallyConsistent() Client + func (c Client) ExistsTable() (bool, error) + func (c Client) GEOADD(key string, members map[string]GLocation) (newlyAddedMembers map[string]GLocation, err error) + func (c Client) GEODIST(key string, member1, member2 string, unit GUnit) (distance float64, ok bool, err error) + func (c Client) GEOHASH(key string, members ...string) (geohashes map[string]string, err error) + func (c Client) GEOPOS(key string, members ...string) (locations map[string]GLocation, err error) + func (c Client) GEORADIUS(key string, center GLocation, radius float64, radiusUnit GUnit, count int32) (positions map[string]GLocation, err error) + func (c Client) GEORADIUSBYMEMBER(key string, member string, radius float64, radiusUnit GUnit, count int32) (positions map[string]GLocation, err error) + func (c Client) GET(key string) (val ReturnValue, err error) + func (c Client) GETSET(key string, value Value) (oldValue ReturnValue, err error) + func (c Client) HDEL(key string, fields ...string) (deletedFields []string, err error) + func (c Client) HEXISTS(key string, field string) (exists bool, err error) + func (c Client) HGET(key string, field string) (val ReturnValue, err error) + func (c Client) HGETALL(key string) (fieldValues map[string]ReturnValue, err error) + func (c Client) HINCRBY(key string, field string, delta int64) (after int64, err error) + func (c Client) HINCRBYFLOAT(key string, field string, delta float64) (after float64, err error) + func (c Client) HKEYS(key string) (keys []string, err error) + func (c Client) HLEN(key string) (count int32, err error) + func (c Client) HMGET(key string, fields ...string) (values map[string]ReturnValue, err error) + func (c Client) HMSET(key string, vFieldMap interface{}) (err error) + func (c Client) HSET(key string, vFieldMap interface{}) (newlySavedFields map[string]Value, err error) + func (c Client) HSETNX(key string, field string, value Value) (ok bool, err error) + func (c Client) HVALS(key string) (values []ReturnValue, err error) + func (c Client) INCR(key string) (after int64, err error) + func (c Client) INCRBY(key string, delta int64) (after int64, err error) + func (c Client) INCRBYFLOAT(key string, delta float64) (after float64, err error) + func (c Client) Index(indexName string) Client + func (c Client) LINDEX(key string, index int64) (element ReturnValue, err error) + func (c Client) LINSERT(key string, side LSide, vPivot, vElement interface{}) (newLength int64, done bool, err error) + func (c Client) LLEN(key string) (length int64, err error) + func (c Client) LPOP(key string) (element ReturnValue, err error) + func (c Client) LPUSH(key string, vElements ...interface{}) (newLength int64, err error) + func (c Client) LPUSHX(key string, vElements ...interface{}) (newLength int64, err error) + func (c Client) LRANGE(key string, start, stop int64) (elements []ReturnValue, err error) + func (c Client) LREM(key string, side LSide, vElement interface{}) (newLength int64, done bool, err error) + func (c Client) LSET(key string, index int64, element string) (ok bool, err error) + func (c Client) MGET(keys ...string) (values map[string]ReturnValue, err error) + func (c Client) MSET(vFieldMap interface{}) (err error) + func (c Client) MSETNX(vFieldMap interface{}) (ok bool, err error) + func (c Client) RPOP(key string) (element ReturnValue, err error) + func (c Client) RPOPLPUSH(sourceKey string, destinationKey string) (element ReturnValue, err error) + func (c Client) RPUSH(key string, vElements ...interface{}) (newLength int64, err error) + func (c Client) RPUSHX(key string, vElements ...interface{}) (newLength int64, err error) + func (c Client) SADD(key string, members ...string) (addedMembers []string, err error) + func (c Client) SCARD(key string) (count int32, err error) + func (c Client) SDIFF(key string, subtractKeys ...string) (members []string, err error) + func (c Client) SDIFFSTORE(destinationKey string, sourceKey string, subtractKeys ...string) (count int32, err error) + func (c Client) SET(key string, vValue interface{}, flags ...Flag) (ok bool, err error) + func (c Client) SETNX(key string, value Value) (ok bool, err error) + func (c Client) SINTER(key string, otherKeys ...string) (members []string, err error) + func (c Client) SINTERSTORE(destinationKey string, sourceKey string, otherKeys ...string) (count int32, err error) + func (c Client) SISMEMBER(key string, member string) (ok bool, err error) + func (c Client) SMEMBERS(key string) (members []string, err error) + func (c Client) SMOVE(sourceKey string, destinationKey string, member string) (ok bool, err error) + func (c Client) SPOP(key string, count int32) (members []string, err error) + func (c Client) SRANDMEMBER(key string, count int32) (members []string, err error) + func (c Client) SREM(key string, members ...string) (removedMembers []string, err error) + func (c Client) SUNION(keys ...string) (members []string, err error) + func (c Client) SUNIONSTORE(destinationKey string, sourceKeys ...string) (count int32, err error) + func (c Client) StronglyConsistent() Client + func (c Client) Table(tableName string) Client + func (c Client) TransactionActions(actions int) Client + func (c Client) XACK(key string, group string, ids ...XID) (acknowledgedIds []XID, err error) + func (c Client) XADD(key string, id XID, fields map[string]Value) (returnedID XID, err error) + func (c Client) XCLAIM(key string, group string, consumer string, lastDeliveredBefore time.Time, ...) (items []StreamItem, err error) + func (c Client) XDEL(key string, ids ...XID) (deletedItems []XID, err error) + func (c Client) XGROUP(key string, group string, start XID) (err error) + func (c Client) XLEN(key string, start, stop XID) (count int32, err error) + func (c Client) XPENDING(key string, group string, count int32) (pendingItems []PendingItem, err error) + func (c Client) XRANGE(key string, start, stop XID, count int32) (streamItems []StreamItem, err error) + func (c Client) XREAD(key string, from XID, count int32) (items []StreamItem, err error) + func (c Client) XREADGROUP(key string, group string, consumer string, option XReadOption, maxCount int32) (items []StreamItem, err error) + func (c Client) XREVRANGE(key string, end, start XID, count int32) (streamItems []StreamItem, err error) + func (c Client) XTRIM(key string, newCount int32) (deletedCount int32, err error) + func (c Client) ZADD(key string, membersWithScores map[string]float64, flags Flags) (addedMembers []string, err error) + func (c Client) ZCARD(key string) (count int32, err error) + func (c Client) ZCOUNT(key string, minScore, maxScore float64) (count int32, err error) + func (c Client) ZINCRBY(key string, member string, delta float64) (newScore float64, err error) + func (c Client) ZINTER(sourceKeys []string, aggregation ZAggregation, weights map[string]float64) (membersWithScores map[string]float64, err error) + func (c Client) ZINTERSTORE(destinationKey string, sourceKeys []string, aggregation ZAggregation, ...) (membersWithScores map[string]float64, err error) + func (c Client) ZLEXCOUNT(key string, min string, max string) (count int32, err error) + func (c Client) ZPOPMAX(key string, count int32) (membersWithScores map[string]float64, err error) + func (c Client) ZPOPMIN(key string, count int32) (membersWithScores map[string]float64, err error) + func (c Client) ZRANGE(key string, start, stop int32) (membersWithScores map[string]float64, err error) + func (c Client) ZRANGEBYLEX(key string, min, max string, offset, count int32) (membersWithScores map[string]float64, err error) + func (c Client) ZRANGEBYSCORE(key string, min, max float64, offset, count int32) (membersWithScores map[string]float64, err error) + func (c Client) ZRANK(key string, member string) (rank int32, found bool, err error) + func (c Client) ZREM(key string, members ...string) (removedMembers []string, err error) + func (c Client) ZREMRANGEBYLEX(key string, min, max string) (removedMembers []string, err error) + func (c Client) ZREMRANGEBYRANK(key string, start, stop int32) (removedMembers []string, err error) + func (c Client) ZREMRANGEBYSCORE(key string, min, max float64) (removedMembers []string, err error) + func (c Client) ZREVRANGE(key string, start, stop int32) (membersWithScores map[string]float64, err error) + func (c Client) ZREVRANGEBYLEX(key string, max, min string, offset, count int32) (membersWithScores map[string]float64, err error) + func (c Client) ZREVRANGEBYSCORE(key string, max, min float64, offset, count int32) (membersWithScores map[string]float64, err error) + func (c Client) ZREVRANK(key string, member string) (rank int32, found bool, err error) + func (c Client) ZSCORE(key string, member string) (score float64, found bool, err error) + func (c Client) ZUNION(sourceKeys []string, aggregation ZAggregation, weights map[string]float64) (membersWithScores map[string]float64, err error) + func (c Client) ZUNIONSTORE(destinationKey string, sourceKeys []string, aggregation ZAggregation, ...) (membersWithScores map[string]float64, err error) + type Flag string + const IfAlreadyExists + const IfNotExists + const None + const Unconditionally + type Flags []Flag + type FloatValue struct + F float64 + func (fv FloatValue) ToAV() types.AttributeValue + type GLocation struct + Lat float64 + Lon float64 + func (l GLocation) DistanceTo(other GLocation, unit GUnit) (distance float64) + func (l GLocation) Geohash() string + type GUnit float64 + const Feet + const Kilometers + const Meters + const Miles + func (from GUnit) To(to GUnit, d float64) float64 + type IntValue struct + I int64 + func (iv IntValue) ToAV() types.AttributeValue + type LSide string + const Left + const Right + type PendingItem struct + Consumer string + DeliveryCount int32 + ID XID + LastDelivered time.Time + type ReturnValue struct + func (rv ReturnValue) Bytes() []byte + func (rv ReturnValue) Empty() bool + func (rv ReturnValue) Equals(ov ReturnValue) bool + func (rv ReturnValue) Float() float64 + func (rv ReturnValue) Int() int64 + func (rv ReturnValue) Interface() interface{} + func (rv ReturnValue) Present() bool + func (rv ReturnValue) String() string + func (rv ReturnValue) ToAV() types.AttributeValue + type StreamItem struct + Fields map[string]ReturnValue + ID XID + type StringValue struct + S string + func (sv StringValue) ToAV() types.AttributeValue + type Value interface + ToAV func() types.AttributeValue + func ToValue(data interface{}) Value + func ToValueE(data interface{}) (value Value, err error) + func ToValues(data []interface{}) []Value + func ToValuesE(data []interface{}) ([]Value, error) + type XID string + const XAutoID + const XEnd + const XStart + func NewTimeXID(ts time.Time) XID + func NewXID(ts time.Time, seq uint64) XID + func (xid XID) First() XID + func (xid XID) Last() XID + func (xid XID) Next() XID + func (xid XID) Prev() XID + func (xid XID) Seq() uint64 + func (xid XID) String() string + func (xid XID) Time() time.Time + type XReadOption string + const XReadNew + const XReadNewAutoACK + const XReadPending + type ZAggregation string + const ZAggregationMax + const ZAggregationMin + const ZAggregationSum
Go to main page