memory

package

v0.0.0-...-51f9457 Latest Latest Go to latest Published: Jul 9, 2021 License: Apache-2.0 Imports: 8 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/luci/luci-go

Documentation ¶

Overview ¶

Package memory implements in-memory Storage structures.

It is designed for testing, and hasn't been optimized for any productio use.

Index ¶

type Cache
- func (c *Cache) Get(ctx context.Context, key storage.CacheKey) ([]byte, bool)
- func (c *Cache) Put(ctx context.Context, key storage.CacheKey, val []byte, exp time.Duration)
type Storage

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Cache ¶

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

Cache is an in-memory storage.Cache implementation.

func (*Cache) Get ¶

func (c *Cache) Get(ctx context.Context, key storage.CacheKey) ([]byte, bool)

Get implements storage.Cache.

func (*Cache) Put ¶

func (c *Cache) Put(ctx context.Context, key storage.CacheKey, val []byte, exp time.Duration)

Put implements storage.Cache.

type Storage ¶

type Storage struct {
	// MaxGetCount, if not zero, is the maximum number of records to retrieve from
	// a single Get request.
	MaxGetCount int
	// contains filtered or unexported fields
}

Storage is an implementation of the storage.Storage interface that stores data in memory.

This is intended for testing, and not intended to be performant.

func (*Storage) Close ¶

func (s *Storage) Close()

Close implements storage.Storage.

func (*Storage) Count ¶

func (s *Storage) Count(project string, path types.StreamPath) (c int)

Count returns the number of log records for the given stream.

func (*Storage) Expunge ¶

func (s *Storage) Expunge(c context.Context, req storage.ExpungeRequest) error

Expunge implements storage.Storage.

func (*Storage) Get ¶

func (s *Storage) Get(c context.Context, req storage.GetRequest, cb storage.GetCallback) error

Get implements storage.Storage.

func (*Storage) Put ¶

func (s *Storage) Put(c context.Context, req storage.PutRequest) error

Put implements storage.Storage.

func (*Storage) PutEntries ¶

func (s *Storage) PutEntries(ctx context.Context, project string, path types.StreamPath, entries ...*logpb.LogEntry)

PutEntries is a convenience method for ingesting logpb.Entry's into this Storage object.

func (*Storage) ResetClose ¶

func (s *Storage) ResetClose()

ResetClose resets the storage instance, allowing it to be used another time. The data stored in this instance is not changed.

func (*Storage) SetErr ¶

func (s *Storage) SetErr(err error)

SetErr sets the storage's error value. If not nil, all operations will fail with this error.

func (*Storage) Tail ¶

func (s *Storage) Tail(c context.Context, project string, path types.StreamPath) (*storage.Entry, error)

Tail implements storage.Storage.

Source Files ¶

View all Source files

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