wart

Documentation

Index

• Constants
• func CheckJobs(w *Wart)
• func CheckThreads(w *Wart)
• func IsEnabled(w *Wart) bool
• type EndpointMeta
• type JobMeta
• type SQLWrapper
  • func (sw *SQLWrapper) Close() error
  • func (sw *SQLWrapper) Exec(query string, args ...interface{}) otto.Value
  • func (sw *SQLWrapper) Ping() error
  • func (sw *SQLWrapper) Query(query string, args ...interface{}) []map[string]otto.Value
• type TaskInterface
• type ThreadMeta
• type Wart
  • func Create(configFile string, redisAddr string, redisPassword string, cluster string, ...) (*Wart, error)
  • func (w *Wart) Shutdown()

Constants

const CRASHED = "crashed"

CRASHED crashed

const DISABLED = "disabled"

DISABLED disabled

const ENABLED = "enabled"

ENABLED enabled

const ONLINE = "online"

ONLINE online

const RUNNING = "running"

RUNNING running

const STOPPED = "stopped"

STOPPED stopped

Functions

func CheckJobs

func CheckJobs(w *Wart)

CheckJobs Checks redis for any jobs that need scheduled.

func CheckThreads

func CheckThreads(w *Wart)

CheckThreads Checks threads in redis for any that need ran.

func IsEnabled

func IsEnabled(w *Wart) bool

IsEnabled Returns if the wart is enabled.

Types

type EndpointMeta

type EndpointMeta struct {
	Key     string
	Stopped bool
	// contains filtered or unexported fields
}

EndpointMeta represents an endpoint

type JobMeta

type JobMeta struct {
	Key     string
	Stopped bool
	// contains filtered or unexported fields
}

JobMeta Struct that represents a job.

type SQLWrapper

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

SQLWrapper wrapper struct

func (*SQLWrapper) Close

func (sw *SQLWrapper) Close() error

Close - library implementation of sql close

func (*SQLWrapper) Exec

func (sw *SQLWrapper) Exec(query string, args ...interface{}) otto.Value

Exec - library implementation of sql queries

func (*SQLWrapper) Ping

func (sw *SQLWrapper) Ping() error

Ping - library implementation of sql pings

func (*SQLWrapper) Query

func (sw *SQLWrapper) Query(query string, args ...interface{}) []map[string]otto.Value

Query - library implementation of sql queries

type TaskInterface

type TaskInterface interface {
	// contains filtered or unexported methods
}

TaskInterface Everything we do is a task. This the interface.

type ThreadMeta

type ThreadMeta struct {
	Key     string
	Stopped bool
	// contains filtered or unexported fields
}

ThreadMeta struct that represents a thread

type Wart

type Wart struct {
	RedisAddr     string
	RedisPassword string
	Cluster       string
	WartName      string
	ScriptList    string
	Client        *redis.Client
	Healthy       bool
	ThreadCount   int

	SecondsTillDead int
	VMStopChan      chan func()
	// contains filtered or unexported fields
}

Wart main structure for wart

func Create

func Create(configFile string, redisAddr string, redisPassword string, cluster string, wartName string, scriptList string, host bool, hostPort string, healthPort string) (*Wart, error)

Create Creates a wart

func (*Wart) Shutdown

func (w *Wart) Shutdown()

Shutdown Shutsdown the wart by safely stopping threads