mysql

Documentation

Index

• func TxDeadlock(err error) bool
• type MySQL
  • func New(host string, port int, user string, password string, dbname string) (MySQL, error)
  • func NewFromConfig(cfg *config.Monkey) (MySQL, error)
  • func (m MySQL) Check(term chaosmonkey.Termination, appCfg chaosmonkey.AppConfig, endHour int, ...) error
  • func (m MySQL) CheckWithDelay(term chaosmonkey.Termination, appCfg chaosmonkey.AppConfig, endHour int, ...) error
  • func (m MySQL) Close() error
  • func (m MySQL) Publish(date time.Time, sched *schedule.Schedule) error
  • func (m MySQL) PublishWithDelay(date time.Time, sched *schedule.Schedule, delay time.Duration) (err error)
  • func (m MySQL) Retrieve(date time.Time) (sched *schedule.Schedule, err error)

Functions

func TxDeadlock

func TxDeadlock(err error) bool

TxDeadlock returns true if the error is because of a transaction deadlock

Types

type MySQL

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

MySQL represents a MySQL-backed store for schedules and terminations

func New

func New(host string, port int, user string, password string, dbname string) (MySQL, error)

New createa a new MySQL

func NewFromConfig

func NewFromConfig(cfg *config.Monkey) (MySQL, error)

NewFromConfig creates a new MySQL taking config parameters from cfg

func (MySQL) Check

func (m MySQL) Check(term chaosmonkey.Termination, appCfg chaosmonkey.AppConfig, endHour int, loc *time.Location) error

Check checks if a termination is permitted and, if so, records the termination time on the server

func (MySQL) CheckWithDelay

func (m MySQL) CheckWithDelay(term chaosmonkey.Termination, appCfg chaosmonkey.AppConfig, endHour int, loc *time.Location, delay time.Duration) error

CheckWithDelay is the same as Check, but adds a delay between reading and writing to the database (used for testing only)

func (MySQL) Close

func (m MySQL) Close() error

Close closes the underlying sql.DB

func (MySQL) Publish

func (m MySQL) Publish(date time.Time, sched *schedule.Schedule) error

Publish publishes the schedule for the given date

func (MySQL) PublishWithDelay

func (m MySQL) PublishWithDelay(date time.Time, sched *schedule.Schedule, delay time.Duration) (err error)

PublishWithDelay publishes the schedule with a delay between checking the schedule exists and writing it. The delay is used only for testing race conditions

func (MySQL) Retrieve

func (m MySQL) Retrieve(date time.Time) (sched *schedule.Schedule, err error)

Retrieve retrieves the schedule for the given date