storage

Documentation

Index

• Constants
• Variables
• type Driver
• type ElasticSearch
  • func NewElasticSearchStorage(url string, prefix string) *ElasticSearch
  • func (es *ElasticSearch) GetLatest() (*executor.Result, error)
  • func (es *ElasticSearch) Persist(r *executor.Result) error
• type FileSystem
  • func NewFileSytemStorage(destination string, group string) (*FileSystem, error)
  • func (fs *FileSystem) GetLatest() (*executor.Result, error)
  • func (fs *FileSystem) Persist(r *executor.Result) error
• type Storage
  • func New(group string, driver string, destination string) (Storage, error)

Constants

const FileSystemStorageExtension string = ".bench"

FileSystemStorageExtension specifies the extension for stored files

Variables

var ErrInvalidStorageDriver = errors.New("storage driver missing or unknown")

ErrInvalidStorageDriver when a unknown driver is specified

Types

type Driver

type Driver string

Driver is used to queue asynchronous requests by a delegate middleware

const (
	FileSystemDriver    Driver = "file"
	ElasticSearchDriver Driver = "elastic"
)

Storage drivers

type ElasticSearch

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

ElasticSearch struct representation

func NewElasticSearchStorage

func NewElasticSearchStorage(url string, prefix string) *ElasticSearch

NewElasticSearchStorage driver

func (*ElasticSearch) GetLatest

func (es *ElasticSearch) GetLatest() (*executor.Result, error)

GetLatest stored results

func (*ElasticSearch) Persist

func (es *ElasticSearch) Persist(r *executor.Result) error

Persist results

type FileSystem

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

FileSystem struct representation

func NewFileSytemStorage

func NewFileSytemStorage(destination string, group string) (*FileSystem, error)

NewFileSytemStorage driver

func (*FileSystem) GetLatest

func (fs *FileSystem) GetLatest() (*executor.Result, error)

GetLatest stored results

func (*FileSystem) Persist

func (fs *FileSystem) Persist(r *executor.Result) error

Persist results

type Storage

type Storage interface {
	GetLatest() (*executor.Result, error)
	Persist(r *executor.Result) error
}

Storage represents a storage driver

func New

func New(group string, driver string, destination string) (Storage, error)

New returns new driver instance dependening on selected driver