storage

package

v0.0.0-...-5195419 Latest Latest Go to latest Published: Dec 30, 2021 License: MIT Imports: 14 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/icyxp/vistio

Documentation ¶

Index ¶

Constants
Variables
func ChunkID(ts time.Time) int64
type Appender
type Chunk
- func NewChunk(id int64) Chunk
type ChunkIterator
type Options
type Querier
type Storage
- func Open(path string, logger *zap.Logger, r prometheus.Registerer, opts *Options) (Storage, error)

Constants ¶

View Source

const ChunkLength = 5 * time.Minute

Variables ¶

View Source

var (
	ErrNotFound = errors.New("Not found")
	ErrDBClosed = errors.New("DB already closed")
)

View Source

var ErrAddToCompletedChunk = errors.New("Unabled to add a new snapshot into a completed chunk")

Functions ¶

func ChunkID ¶

func ChunkID(ts time.Time) int64

Types ¶

type Appender ¶

type Appender interface {
	Add(*model.Snapshot) error
}

type Chunk ¶

type Chunk interface {
	ID() int64
	SetCompleted(bool)
	IsCompleted() bool
	Len() int
	Clone() Chunk

	Add(*model.Snapshot) error

	Iterator() ChunkIterator

	Marshal() ([]byte, error)
	Unmarshal([]byte) error
}

func NewChunk ¶

func NewChunk(id int64) Chunk

type ChunkIterator ¶

type ChunkIterator interface {
	FindBestSnapshot(time.Time) *model.Snapshot
}

type Options ¶

type Options struct {
	Retention time.Duration
}

type Querier ¶

type Querier interface {
	GetChunk(int64) (Chunk, error)
	GetLatestSnapshot() (*model.Snapshot, error)
}

type Storage ¶

type Storage interface {
	Appender
	Querier
	Close() error
}

func Open ¶

func Open(path string, logger *zap.Logger, r prometheus.Registerer, opts *Options) (Storage, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
storagemock

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