store

package

v1.2.4 Latest Latest Go to latest Published: Jan 13, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/umputun/secrets

Links

Open Source Insights

Documentation ¶

Overview ¶

Package store defines and implements data store for boltdb and in-memory

Index ¶

Variables
func Key(ts time.Time, key string) string
type Bolt
- func NewBolt(dbFile string, cleanupDuration time.Duration) (*Bolt, error)
type InMemory
- func NewInMemory(cleanupDuration time.Duration) *InMemory
type Message

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrLoadRejected = fmt.Errorf("message expired or deleted")
	ErrSaveRejected = fmt.Errorf("can't save message")
)

Error messages

Functions ¶

func Key ¶

func Key(ts time.Time, key string) string

Key makes store key with ts prefix

Types ¶

type Bolt ¶

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

Bolt implements store.Engine with boltdb

func NewBolt ¶

func NewBolt(dbFile string, cleanupDuration time.Duration) (*Bolt, error)

NewBolt makes persistent boltdb based store

func (*Bolt) IncErr ¶

func (s *Bolt) IncErr(key string) (count int, err error)

IncErr increments error count

func (*Bolt) Load ¶

func (s *Bolt) Load(key string) (result *Message, err error)

Load by key, removes on first access, checks expire

func (*Bolt) Remove ¶

func (s *Bolt) Remove(key string) (err error)

Remove by key

func (*Bolt) Save ¶

func (s *Bolt) Save(msg *Message) (err error)

Save with autogenerated ts-uuid as a key. ts prefix for bolt range query

type InMemory ¶

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

InMemory implements store.Interface with concurrent map

func NewInMemory ¶

func NewInMemory(cleanupDuration time.Duration) *InMemory

NewInMemory makes new store with max duration

func (*InMemory) IncErr ¶

func (s *InMemory) IncErr(key string) (count int, err error)

IncErr increments error count

func (*InMemory) Load ¶

func (s *InMemory) Load(key string) (result *Message, err error)

Load by key, removes on first access, checks expire

func (*InMemory) Remove ¶

func (s *InMemory) Remove(key string) (err error)

Remove by key

func (*InMemory) Save ¶

func (s *InMemory) Save(msg *Message) (err error)

Save to map with autogenerated uuid as a key

type Message ¶

type Message struct {
	Key     string
	Exp     time.Time
	Data    []byte
	PinHash string
	Errors  int
}

Message with key and exp. time

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL