storage

package
v0.0.0-...-ef4fc8a Latest Latest
Warning

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

 Go to latest Published: Mar 11, 2024 License: MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StalePrefix = "STALE_"

	MappingKeyPrefix = "IDX_"
)

Variables

This section is empty.

Functions

func BadgerConnectionFactory 

func BadgerConnectionFactory(c t.AbstractConfigurationInterface) (types.Storer, error)

BadgerConnectionFactory function create new Badger instance

func EmbeddedOlricConnectionFactory 

func EmbeddedOlricConnectionFactory(configuration t.AbstractConfigurationInterface) (types.Storer, error)

EmbeddedOlricConnectionFactory function create new EmbeddedOlric instance

func EtcdConnectionFactory 

func EtcdConnectionFactory(c t.AbstractConfigurationInterface) (types.Storer, error)

EtcdConnectionFactory function create new Etcd instance

func NewStorage 

func NewStorage(configuration configurationtypes.AbstractConfigurationInterface) (types.Storer, error)

func NewStorages 

func NewStorages(configuration configurationtypes.AbstractConfigurationInterface) ([]types.Storer, error)

func NutsConnectionFactory 

func NutsConnectionFactory(c t.AbstractConfigurationInterface) (types.Storer, error)

NutsConnectionFactory function create new Nuts instance

func OlricConnectionFactory 

func OlricConnectionFactory(configuration t.AbstractConfigurationInterface) (types.Storer, error)

OlricConnectionFactory function create new Olric instance

func RedisConnectionFactory 

func RedisConnectionFactory(c t.AbstractConfigurationInterface) (types.Storer, error)

RedisConnectionFactory function create new Nuts instance

Types

type Badger 

type Badger struct {
	*badger.DB
	// contains filtered or unexported fields
}

Badger provider type

func (*Badger) Delete 

func (provider *Badger) Delete(key string)

Delete method will delete the response in Badger provider if exists corresponding to key param

func (*Badger) DeleteMany 

func (provider *Badger) DeleteMany(key string)

DeleteMany method will delete the responses in Badger provider if exists corresponding to the regex key param

func (*Badger) Get 

func (provider *Badger) Get(key string) []byte

Get method returns the populated response if exists, empty response then

func (*Badger) GetMultiLevel 

func (provider *Badger) GetMultiLevel(key string, req *http.Request, validator *rfc.Revalidator) (fresh *http.Response, stale *http.Response)

GetMultiLevel tries to load the key and check if one of linked keys is a fresh/stale candidate.

func (*Badger) Init 

func (provider *Badger) Init() error

Init method will

func (*Badger) ListKeys 

func (provider *Badger) ListKeys() []string

ListKeys method returns the list of existing keys

func (*Badger) MapKeys 

func (provider *Badger) MapKeys(prefix string) map[string]string

MapKeys method returns a map with the key and value

func (*Badger) Name 

func (provider *Badger) Name() string

Name returns the storer name

func (*Badger) Prefix 

func (provider *Badger) Prefix(key string, req *http.Request, validator *rfc.Revalidator) *http.Response

Prefix method returns the populated response if exists, empty response then

func (*Badger) Reset 

func (provider *Badger) Reset() error

Reset method will reset or close provider

func (*Badger) Set 

func (provider *Badger) Set(key string, value []byte, url t.URL, duration time.Duration) error

Set method will store the response in Badger provider

func (*Badger) SetMultiLevel 

func (provider *Badger) SetMultiLevel(baseKey, variedKey string, value []byte, variedHeaders http.Header, etag string, duration time.Duration) error

SetMultiLevel tries to store the key with the given value and update the mapping key to store metadata.

type EmbeddedOlric 

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

EmbeddedOlric provider type

func (*EmbeddedOlric) Delete 

func (provider *EmbeddedOlric) Delete(key string)

Delete method will delete the response in EmbeddedOlric provider if exists corresponding to key param

func (*EmbeddedOlric) DeleteMany 

func (provider *EmbeddedOlric) DeleteMany(key string)

DeleteMany method will delete the responses in EmbeddedOlric provider if exists corresponding to the regex key param

func (*EmbeddedOlric) Destruct 

func (provider *EmbeddedOlric) Destruct() error

Destruct method will reset or close provider

func (*EmbeddedOlric) Get 

func (provider *EmbeddedOlric) Get(key string) []byte

Get method returns the populated response if exists, empty response then

func (*EmbeddedOlric) GetDM 

func (provider *EmbeddedOlric) GetDM() olric.DMap

GetDM method returns the embbeded instance dm property

func (*EmbeddedOlric) GetMultiLevel 

func (provider *EmbeddedOlric) GetMultiLevel(key string, req *http.Request, validator *rfc.Revalidator) (fresh *http.Response, stale *http.Response)

GetMultiLevel tries to load the key and check if one of linked keys is a fresh/stale candidate.

func (*EmbeddedOlric) Init 

func (provider *EmbeddedOlric) Init() error

Init method will initialize EmbeddedOlric provider if needed

func (*EmbeddedOlric) ListKeys 

func (provider *EmbeddedOlric) ListKeys() []string

ListKeys method returns the list of existing keys

func (*EmbeddedOlric) MapKeys 

func (provider *EmbeddedOlric) MapKeys(prefix string) map[string]string

MapKeys method returns a map with the key and value

func (*EmbeddedOlric) Name 

func (provider *EmbeddedOlric) Name() string

Name returns the storer name

func (*EmbeddedOlric) Prefix 

func (provider *EmbeddedOlric) Prefix(key string, req *http.Request, validator *rfc.Revalidator) *http.Response

Prefix method returns the populated response if exists, empty response then

func (*EmbeddedOlric) Reset 

func (provider *EmbeddedOlric) Reset() error

Reset method will reset or close provider

func (*EmbeddedOlric) Set 

func (provider *EmbeddedOlric) Set(key string, value []byte, url t.URL, duration time.Duration) error

Set method will store the response in EmbeddedOlric provider

func (*EmbeddedOlric) SetMultiLevel 

func (provider *EmbeddedOlric) SetMultiLevel(baseKey, variedKey string, value []byte, variedHeaders http.Header, etag string, duration time.Duration) error

SetMultiLevel tries to store the key with the given value and update the mapping key to store metadata.

type Etcd 

type Etcd struct {
	*clientv3.Client
	// contains filtered or unexported fields
}

Etcd provider type

func (*Etcd) Delete 

func (provider *Etcd) Delete(key string)

Delete method will delete the response in Etcd provider if exists corresponding to key param

func (*Etcd) DeleteMany 

func (provider *Etcd) DeleteMany(key string)

DeleteMany method will delete the responses in Etcd provider if exists corresponding to the regex key param

func (*Etcd) Get 

func (provider *Etcd) Get(key string) (item []byte)

Get method returns the populated response if exists, empty response then

func (*Etcd) GetMultiLevel 

func (provider *Etcd) GetMultiLevel(key string, req *http.Request, validator *rfc.Revalidator) (fresh *http.Response, stale *http.Response)

GetMultiLevel tries to load the key and check if one of linked keys is a fresh/stale candidate.

func (*Etcd) Init 

func (provider *Etcd) Init() error

Init method will

func (*Etcd) ListKeys 

func (provider *Etcd) ListKeys() []string

ListKeys method returns the list of existing keys

func (*Etcd) MapKeys 

func (provider *Etcd) MapKeys(prefix string) map[string]string

MapKeys method returns the map of existing keys

func (*Etcd) Name 

func (provider *Etcd) Name() string

Name returns the storer name

func (*Etcd) Prefix 

func (provider *Etcd) Prefix(key string, req *http.Request, validator *rfc.Revalidator) *http.Response

Prefix method returns the populated response if exists, empty response then

func (*Etcd) Reconnect 

func (provider *Etcd) Reconnect()

func (*Etcd) Reset 

func (provider *Etcd) Reset() error

Reset method will reset or close provider

func (*Etcd) Set 

func (provider *Etcd) Set(key string, value []byte, url t.URL, duration time.Duration) error

Set method will store the response in Etcd provider

func (*Etcd) SetMultiLevel 

func (provider *Etcd) SetMultiLevel(baseKey, variedKey string, value []byte, variedHeaders http.Header, etag string, duration time.Duration) error

SetMultiLevel tries to store the key with the given value and update the mapping key to store metadata.

type Nuts 

type Nuts struct {
	*nutsdb.DB
	// contains filtered or unexported fields
}

Nuts provider type

func (*Nuts) Delete 

func (provider *Nuts) Delete(key string)

Delete method will delete the response in Nuts provider if exists corresponding to key param

func (*Nuts) DeleteMany 

func (provider *Nuts) DeleteMany(key string)

DeleteMany method will delete the responses in Nuts provider if exists corresponding to the regex key param

func (*Nuts) Get 

func (provider *Nuts) Get(key string) (item []byte)

Get method returns the populated response if exists, empty response then

func (*Nuts) GetMultiLevel 

func (provider *Nuts) GetMultiLevel(key string, req *http.Request, validator *rfc.Revalidator) (fresh *http.Response, stale *http.Response)

GetMultiLevel tries to load the key and check if one of linked keys is a fresh/stale candidate.

func (*Nuts) Init 

func (provider *Nuts) Init() error

Init method will

func (*Nuts) ListKeys 

func (provider *Nuts) ListKeys() []string

ListKeys method returns the list of existing keys

func (*Nuts) MapKeys 

func (provider *Nuts) MapKeys(prefix string) map[string]string

MapKeys method returns the map of existing keys

func (*Nuts) Name 

func (provider *Nuts) Name() string

Name returns the storer name

func (*Nuts) Prefix 

func (provider *Nuts) Prefix(key string, req *http.Request, validator *rfc.Revalidator) *http.Response

Prefix method returns the populated response if exists, empty response then

func (*Nuts) Reset 

func (provider *Nuts) Reset() error

Reset method will reset or close provider

func (*Nuts) Set 

func (provider *Nuts) Set(key string, value []byte, url t.URL, duration time.Duration) error

Set method will store the response in Nuts provider

func (*Nuts) SetMultiLevel 

func (provider *Nuts) SetMultiLevel(baseKey, variedKey string, value []byte, variedHeaders http.Header, etag string, duration time.Duration) error

SetMultiLevel tries to store the key with the given value and update the mapping key to store metadata.

type Olric 

type Olric struct {
	*olric.ClusterClient
	// contains filtered or unexported fields
}

Olric provider type

func (*Olric) Delete 

func (provider *Olric) Delete(key string)

Delete method will delete the response in Olric provider if exists corresponding to key param

func (*Olric) DeleteMany 

func (provider *Olric) DeleteMany(key string)

DeleteMany method will delete the responses in Olric provider if exists corresponding to the regex key param

func (*Olric) Get 

func (provider *Olric) Get(key string) []byte

Get method returns the populated response if exists, empty response then

func (*Olric) GetMultiLevel 

func (provider *Olric) GetMultiLevel(key string, req *http.Request, validator *rfc.Revalidator) (fresh *http.Response, stale *http.Response)

GetMultiLevel tries to load the key and check if one of linked keys is a fresh/stale candidate.

func (*Olric) Init 

func (provider *Olric) Init() error

Init method will initialize Olric provider if needed

func (*Olric) ListKeys 

func (provider *Olric) ListKeys() []string

ListKeys method returns the list of existing keys

func (*Olric) MapKeys 

func (provider *Olric) MapKeys(prefix string) map[string]string

MapKeys method returns the map of existing keys

func (*Olric) Name 

func (provider *Olric) Name() string

Name returns the storer name

func (*Olric) Prefix 

func (provider *Olric) Prefix(key string, req *http.Request, validator *rfc.Revalidator) *http.Response

Prefix method returns the populated response if exists, empty response then

func (*Olric) Reconnect 

func (provider *Olric) Reconnect()

func (*Olric) Reset 

func (provider *Olric) Reset() error

Reset method will reset or close provider

func (*Olric) Set 

func (provider *Olric) Set(key string, value []byte, url t.URL, duration time.Duration) error

Set method will store the response in Olric provider

func (*Olric) SetMultiLevel 

func (provider *Olric) SetMultiLevel(baseKey, variedKey string, value []byte, variedHeaders http.Header, etag string, duration time.Duration) error

SetMultiLevel tries to store the key with the given value and update the mapping key to store metadata.

type Redis 

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

Redis provider type

func (*Redis) Delete 

func (provider *Redis) Delete(key string)

Delete method will delete the response in Etcd provider if exists corresponding to key param

func (*Redis) DeleteMany 

func (provider *Redis) DeleteMany(key string)

DeleteMany method will delete the responses in Nuts provider if exists corresponding to the regex key param

func (*Redis) Get 

func (provider *Redis) Get(key string) []byte

Get method returns the populated response if exists, empty response then

func (*Redis) GetMultiLevel 

func (provider *Redis) GetMultiLevel(key string, req *http.Request, validator *rfc.Revalidator) (fresh *http.Response, stale *http.Response)

GetMultiLevel tries to load the key and check if one of linked keys is a fresh/stale candidate.

func (*Redis) Init 

func (provider *Redis) Init() error

Init method will

func (*Redis) ListKeys 

func (provider *Redis) ListKeys() []string

ListKeys method returns the list of existing keys

func (*Redis) MapKeys 

func (provider *Redis) MapKeys(prefix string) map[string]string

MapKeys method returns the list of existing keys

func (*Redis) Name 

func (provider *Redis) Name() string

Name returns the storer name

func (*Redis) Prefix 

func (provider *Redis) Prefix(key string, req *http.Request, validator *rfc.Revalidator) *http.Response

Prefix method returns the populated response if exists, empty response then

func (*Redis) Reconnect 

func (provider *Redis) Reconnect()

func (*Redis) Reset 

func (provider *Redis) Reset() error

Reset method will reset or close provider

func (*Redis) Set 

func (provider *Redis) Set(key string, value []byte, url t.URL, duration time.Duration) error

Set method will store the response in Etcd provider

func (*Redis) SetMultiLevel 

func (provider *Redis) SetMultiLevel(baseKey, variedKey string, value []byte, variedHeaders http.Header, etag string, duration time.Duration) error

SetMultiLevel tries to store the key with the given value and update the mapping key to store metadata.

type StorerInstanciator 

type StorerInstanciator func(configurationtypes.AbstractConfigurationInterface) (types.Storer, error)

func NewStorageFromName 

func NewStorageFromName(name string) (StorerInstanciator, error)

Source Files

View all Source files

Directories

Path Synopsis

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.