server

Documentation

Index

• Constants
• func VerifyFunctionSpec(funcSpec *core.FunctionSpec) error
• func VerifyWorkflowSpec(workflowSpec *core.WorkflowSpec) error
• func WaitForCluster(t *testing.T, cluster []ServerInfo)
• func WaitForProcessGraphs(t *testing.T, c *client.ColoniesClient, colonyName string, generatorID string, ...) int
• func WaitForServerToDie(t *testing.T, s ServerInfo)
• type ColoniesServer
  • func CreateColoniesServer(db database.Database, port int, tls bool, tlsPrivateKeyPath string, ...) *ColoniesServer
  • func PrepareTests(t *testing.T) (*client.ColoniesClient, *ColoniesServer, string, chan bool)
  • func (server *ColoniesServer) ServeForever() error
  • func (server *ColoniesServer) Shutdown()
• type ServerInfo
  • func StartCluster(t *testing.T, db database.Database, size int) []ServerInfo

Constants

const CRON_TRIGGER_PERIOD = 1000 // Period in milliseconds when cron is run

const EnableTLS = true

const GENERATOR_TRIGGER_PERIOD = 1000 // Period in milliseconds when generator is run

const Insecure = false

const MAX_COUNT = 100

const MAX_DAYS = 30

const MAX_LOG_COUNT = 500

const MAX_PRIORITY = 50000

const MIN_PRIORITY = -50000

const RELEASE_PERIOD = 1 // Period in seconds when processes are checked for max exec time or max wait time

const SkipTLSVerify = true

const TESTHOST = "localhost"

const TESTPORT = 28088

Functions

func VerifyFunctionSpec

func VerifyFunctionSpec(funcSpec *core.FunctionSpec) error

func VerifyWorkflowSpec

func VerifyWorkflowSpec(workflowSpec *core.WorkflowSpec) error

func WaitForCluster

func WaitForCluster(t *testing.T, cluster []ServerInfo)

func WaitForProcessGraphs

func WaitForProcessGraphs(t *testing.T, c *client.ColoniesClient, colonyName string, generatorID string, executorPrvKey string, threshold int) int

func WaitForServerToDie

func WaitForServerToDie(t *testing.T, s ServerInfo)

Types

type ColoniesServer

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

func CreateColoniesServer

func CreateColoniesServer(db database.Database,
	port int,
	tls bool,
	tlsPrivateKeyPath string,
	tlsCertPath string,
	thisNode cluster.Node,
	clusterConfig cluster.Config,
	etcdDataPath string,
	generatorPeriod int,
	cronPeriod int,
	exclusiveAssign bool,
	allowExecutorReregister bool,
	retention bool,
	retentionPolicy int64,
	retentionPeriod int) *ColoniesServer

func PrepareTests

func PrepareTests(t *testing.T) (*client.ColoniesClient, *ColoniesServer, string, chan bool)

func (*ColoniesServer) ServeForever

func (server *ColoniesServer) ServeForever() error

func (*ColoniesServer) Shutdown

func (server *ColoniesServer) Shutdown()

type ServerInfo

type ServerInfo struct {
	ServerID     string
	ServerPrvKey string
	Server       *ColoniesServer
	Node         cluster.Node
	Done         chan struct{}
}

func StartCluster

func StartCluster(t *testing.T, db database.Database, size int) []ServerInfo