replay

Documentation

Index

• type Config
  • func NewConfig() Config
  • func (c Config) Validate() error
• type RecordingInfo
• type Service
  • func NewService(conf Config, l *log.Logger) *Service
  • func (r *Service) Close() error
  • func (r *Service) Delete(id string)
  • func (r *Service) FindBatchRecording(id string) ([]io.ReadCloser, error)
  • func (r *Service) FindStreamRecording(id string) (io.ReadCloser, error)
  • func (r *Service) GetRecordings(rids []string) ([]RecordingInfo, error)
  • func (r *Service) Open() error

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