Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

storage

package module

Go to main page

Versions in this module

v0

v0.2.0

Oct 13, 2026

Changes in this version

type BlobStore

+ Open func(ctx context.Context, ref xfile.Ref) (io.ReadCloser, xfile.Info, error)

v0.1.0

Oct 12, 2026

Changes in this version

+ func AssertFencedMutex(inst Instance) (action.FencedMutex, error)

+ func AssertIdempotencyStore(inst Instance) (action.IdempotencyStore, error)

+ func AssertJournal(inst Instance) (action.Journal, error)

+ func AssertKV(inst Instance) (action.CacheLayer[any], error)

+ func AssertMutex(inst Instance) (action.Mutex, error)

+ func AssertRateLimiter(inst Instance) (action.RateLimiter, error)

+ func AssertTxRunner(inst Instance) (action.TxRunner, error)

+ func BadRequest(msg string) error

+ func BadRequestf(format string, args ...any) error

+ func Conflict(msg string) error

+ func Conflictf(format string, args ...any) error

+ func Internal(msg string) error

+ func Internalf(format string, args ...any) error

+ func NotFound(msg string) error

+ func NotFoundf(format string, args ...any) error

+ func ParseDuration(s string, def time.Duration) (time.Duration, error)

+ func TooManyRequests(msg string) error

+ func Unavailable(msg string, cause error) error

+ func Unavailablef(cause error, format string, args ...any) error

+ type Backend interface

+ Kind func() Kind

+ Name func() string

+ Open func(opts map[string]string) (Instance, error)

+ type BlobStore interface

+ Delete func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) (data []byte, hit bool, err error)

+ Put func(ctx context.Context, key string, data []byte) error

+ func AssertBlob(inst Instance) (BlobStore, error)

+ type Declaration struct

+ Backend string

+ Kind Kind

+ Name string

+ Options map[string]string

+ Position Position

+ func (d Declaration) Open(reg *Registry) (Instance, error)

+ type Instance interface

+ Close func() error

+ Kind func() Kind

+ type Kind string

+ const KindBlob

+ const KindFencedLock

+ const KindIdem

+ const KindJournal

+ const KindKV

+ const KindLock

+ const KindRateLimit

+ const KindTx

+ func AllKinds() []Kind

+ func (k Kind) KernelInterface() string

+ type Position struct

+ File string

+ Line int

+ func (p Position) String() string

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Close(ctx context.Context) error

+ func (r *Registry) Lookup(name string, kind Kind) (Backend, bool)

+ func (r *Registry) LookupKind(name string) []Backend

+ func (r *Registry) MustRegister(b Backend)

+ func (r *Registry) Names() []string

+ func (r *Registry) Register(b Backend) error