manager

Documentation

Index

• Constants
• func NewJobManager(lg *zap.Logger, cfg *config.Config, certMgr CertManager, idMgr *id.IDManager, ...) *jobManager
• type CertManager
• type Job
• type JobManager

Constants

const (
	Capture jobType = iota
	Replay
)

Functions

func NewJobManager

func NewJobManager(lg *zap.Logger, cfg *config.Config, certMgr CertManager, idMgr *id.IDManager, hsHandler backend.HandshakeHandler) *jobManager

Types

type CertManager

type CertManager interface {
	SQLTLS() *tls.Config
}

type Job

type Job interface {
	Type() jobType
	String() string
	MarshalJSON() ([]byte, error)
	SetProgress(progress float64, endTime time.Time, done bool, err error)
	IsRunning() bool
}

type JobManager

type JobManager interface {
	StartCapture(capture.CaptureConfig) error
	StartReplay(replay.ReplayConfig) error
	GetCapture() capture.Capture
	Stop() string
	Jobs() string
	Close()
}