storage

package
v2.2.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 17, 2017 License: MIT Imports: 12 Imported by: 137

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FormatBool 

func FormatBool(value bool) string

FormatBool does what its name suggests

func FormatBytes 

func FormatBytes(value []byte) string

FormatBytes does what its name suggests

func FormatFloat32 

func FormatFloat32(value float32) string

FormatFloat32 does what its name suggests

func FormatFloat64 

func FormatFloat64(value float64) string

FormatFloat64 does what its name suggests

func FormatInt32 

func FormatInt32(value int32) string

FormatInt32 does what its name suggests

func FormatInt64 

func FormatInt64(value int64) string

FormatInt64 does what its name suggests

func FormatUint32 

func FormatUint32(value uint32) string

FormatUint32 does what its name suggests

func FormatUint64 

func FormatUint64(value uint64) string

FormatUint64 does what its name suggests

func ParseBool 

func ParseBool(val string) (bool, error)

ParseBool does what its name suggests

func ParseBytes 

func ParseBytes(val string) ([]byte, error)

ParseBytes does what its name suggests

func ParseFloat32 

func ParseFloat32(val string) (float32, error)

ParseFloat32 does what its name suggests

func ParseFloat64 

func ParseFloat64(val string) (float64, error)

ParseFloat64 does what its name suggests

func ParseInt32 

func ParseInt32(val string) (int32, error)

ParseInt32 does what its name suggests

func ParseInt64 

func ParseInt64(val string) (int64, error)

ParseInt64 does what its name suggests

func ParseUint32 

func ParseUint32(val string) (uint32, error)

ParseUint32 does what its name suggests

func ParseUint64 

func ParseUint64(val string) (uint64, error)

ParseUint64 does what its name suggests

Types

type ChangedFielder 

type ChangedFielder interface {
	ChangedFields() []string
}

ChangedFielder interface is used to see what fields to update

type ListOptions 

type ListOptions struct {
	Limit  int
	Offset int
}

ListOptions are options for all list commands

type RedisKVStore 

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

RedisKVStore stores arbitrary data in Redis

func NewRedisKVStore 

func NewRedisKVStore(client *redis.Client, prefix string) *RedisKVStore

NewRedisKVStore creates a new RedisKVStore

func (*RedisKVStore) Create 

func (s *RedisKVStore) Create(key string, value string) error

Create a new record, prepending the prefix to the key if necessary

func (*RedisKVStore) Delete 

func (s *RedisKVStore) Delete(key string) error

Delete an existing record, prepending the prefix to the key if necessary

func (*RedisKVStore) Get 

func (s *RedisKVStore) Get(key string) (string, error)

Get one result, prepending the prefix to the key if necessary

func (*RedisKVStore) GetAll 

func (s *RedisKVStore) GetAll(keys []string, options *ListOptions) (map[string]string, error)

GetAll returns all results for the given keys, prepending the prefix to the keys if necessary

func (*RedisKVStore) List 

func (s *RedisKVStore) List(selector string, options *ListOptions) (map[string]string, error)

List all results matching the selector, prepending the prefix to the selector if necessary

func (*RedisKVStore) Update 

func (s *RedisKVStore) Update(key string, value string) error

Update an existing record, prepending the prefix to the key if necessary

type RedisMapStore 

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

RedisMapStore stores structs as HMaps in Redis

func NewRedisMapStore 

func NewRedisMapStore(client *redis.Client, prefix string) *RedisMapStore

NewRedisMapStore returns a new RedisMapStore that talks to the given Redis client and respects the given prefix

func (*RedisMapStore) Create 

func (s *RedisMapStore) Create(key string, value interface{}, properties ...string) error

Create a new record, prepending the prefix to the key if necessary, optionally setting only the given properties

func (*RedisMapStore) Delete 

func (s *RedisMapStore) Delete(key string) error

Delete an existing record, prepending the prefix to the key if necessary

func (*RedisMapStore) Get 

func (s *RedisMapStore) Get(key string) (interface{}, error)

Get one result, prepending the prefix to the key if necessary

func (*RedisMapStore) GetAll 

func (s *RedisMapStore) GetAll(keys []string, options *ListOptions) ([]interface{}, error)

GetAll returns all results for the given keys, prepending the prefix to the keys if necessary

func (*RedisMapStore) GetFields 

func (s *RedisMapStore) GetFields(key string, fields ...string) (interface{}, error)

GetFields for a record, prepending the prefix to the key if necessary

func (*RedisMapStore) List 

func (s *RedisMapStore) List(selector string, options *ListOptions) ([]interface{}, error)

List all results matching the selector, prepending the prefix to the selector if necessary

func (*RedisMapStore) SetBase 

func (s *RedisMapStore) SetBase(base interface{}, tagName string)

SetBase sets the base struct for automatically encoding and decoding to and from Redis format

func (*RedisMapStore) SetDecoder 

func (s *RedisMapStore) SetDecoder(decoder StringStringMapDecoder)

SetDecoder sets the decoder to convert structs from Redis format

func (*RedisMapStore) SetEncoder 

func (s *RedisMapStore) SetEncoder(encoder StringStringMapEncoder)

SetEncoder sets the encoder to convert structs to Redis format

func (*RedisMapStore) Update 

func (s *RedisMapStore) Update(key string, value interface{}, properties ...string) error

Update an existing record, prepending the prefix to the key if necessary, optionally setting only the given properties

type RedisSetStore 

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

RedisSetStore stores sets in Redis

func NewRedisSetStore 

func NewRedisSetStore(client *redis.Client, prefix string) *RedisSetStore

NewRedisSetStore creates a new RedisSetStore

func (*RedisSetStore) Add 

func (s *RedisSetStore) Add(key string, values ...string) error

Add one or more values to the set, prepending the prefix to the key if necessary

func (*RedisSetStore) Contains 

func (s *RedisSetStore) Contains(key string, value string) (res bool, err error)

Contains returns wheter the set contains a given value, prepending the prefix to the key if necessary

func (*RedisSetStore) Delete 

func (s *RedisSetStore) Delete(key string) error

Delete the entire set

func (*RedisSetStore) Get 

func (s *RedisSetStore) Get(key string) (res []string, err error)

Get one result, prepending the prefix to the key if necessary

func (*RedisSetStore) GetAll 

func (s *RedisSetStore) GetAll(keys []string, options *ListOptions) (map[string][]string, error)

GetAll returns all results for the given keys, prepending the prefix to the keys if necessary

func (*RedisSetStore) List 

func (s *RedisSetStore) List(selector string, options *ListOptions) (map[string][]string, error)

List all results matching the selector, prepending the prefix to the selector if necessary

func (*RedisSetStore) Remove 

func (s *RedisSetStore) Remove(key string, values ...string) error

Remove one or more values from the set, prepending the prefix to the key if necessary

type StringStringMapDecoder 

type StringStringMapDecoder func(input map[string]string) (interface{}, error)

StringStringMapDecoder is used to decode a map[string]string to a struct

type StringStringMapEncoder 

type StringStringMapEncoder func(input interface{}, properties ...string) (map[string]string, error)

StringStringMapEncoder encodes the given properties of the input to a map[string]string for storage in Redis

type Time 

type Time struct {
	time.Time
}

Time is a wrapper around time.Time that marshals and unmarshals to the time.RFC3339Nano format

func (Time) MarshalText 

func (t Time) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface

func (*Time) UnmarshalText 

func (t *Time) UnmarshalText(in []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.