replay

package
v0.2.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 22, 2015 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Dir string `toml:"dir"`
}

func NewConfig

func NewConfig() Config

func (Config) Validate

func (c Config) Validate() error

type RecordingInfo

type RecordingInfo struct {
	ID      string
	Type    kapacitor.TaskType `json:",omitempty"`
	Size    int64              `json:",omitempty"`
	Created time.Time          `json:",omitempty"`
	Error   string             `json:",omitempty"`
}

type Service

type Service struct {
	TaskStore interface {
		Load(name string) (*kapacitor.Task, error)
	}
	HTTPDService interface {
		AddRoutes([]httpd.Route) error
		DelRoutes([]httpd.Route)
	}
	InfluxDBService interface {
		NewClient() (*client.Client, error)
	}
	TaskMaster interface {
		NewFork(name string, dbrps []kapacitor.DBRP) (*kapacitor.Edge, error)
		DelFork(name string)
		New() *kapacitor.TaskMaster
		Stream(name string) (kapacitor.StreamCollector, error)
	}
	// contains filtered or unexported fields
}

Handles recording, starting, and waiting on replays

func NewService

func NewService(conf Config, l *log.Logger) *Service

Create a new replay master.

func (*Service) Close

func (r *Service) Close() error

func (*Service) Delete

func (r *Service) Delete(id string)

func (*Service) FindBatchRecording

func (r *Service) FindBatchRecording(id string) ([]io.ReadCloser, error)

func (*Service) FindStreamRecording

func (r *Service) FindStreamRecording(id string) (io.ReadCloser, error)

func (*Service) GetRecordings

func (r *Service) GetRecordings(rids []string) ([]RecordingInfo, error)

func (*Service) Open

func (r *Service) Open() error

Jump to

Keyboard shortcuts

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