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, colonyID string, generatorID string, ...) int
• func WaitForServerToDie(t *testing.T, s ServerInfo)
• type ColoniesServer
  • func CreateColoniesServer(db database.Database, port int, serverID string, tls bool, ...) *ColoniesServer
  • 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_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, colonyID 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,
	serverID string,
	tls bool,
	tlsPrivateKeyPath string,
	tlsCertPath string,
	thisNode cluster.Node,
	clusterConfig cluster.Config,
	etcdDataPath string,
	generatorPeriod int,
	cronPeriod int,
	exclusiveAssign bool) *ColoniesServer

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