server

Documentation

Index

• Constants
• 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 EnableTLS = true

const Insecure = false

const MAX_COUNT = 100

const SkipTLSVerify = true

const TESTHOST = "localhost"

const TESTPORT = 28088

const TIMEOUT_CRON_TRIGGER_INTERVALL = 1

const TIMEOUT_GENERATOR_TRIGGER_INTERVALL = 1

const TIMEOUT_RELEASE_INTERVALL = 1

Functions

func WaitForCluster

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

func WaitForProcessGraphs

func WaitForProcessGraphs(t *testing.T, c *client.ColoniesClient, colonyID string, generatorID string, runtimePrvKey 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) *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