asgard

Documentation

Overview

Package asgard contains shared code that is used to create an aws/netflixoss style architecture (including lamp and migration)

Index

• func Connect(source, target string)
• func ConnectEveryEureka(name string)
• func Create(servicename, packagename string, regions, count int, dependencies ...string) string
• func CreateChannels() (*chan gotocol.Message, *map[string]chan gotocol.Message, ...)
• func CreateEureka()
• func Exit()
• func Reload(arch string) string
• func Run(rootservice string, ServiceNames map[int]string, ServiceIndex int)
• func SendToName(name string, msg gotocol.Message)
• func ShutdownEureka()
• func ShutdownNodes()
• func StartNode(name string, dependencies ...string)
• type ConnDes

Functions

func Connect

func Connect(source, target string)

Connect tells a source node how to connect to a target node directly by name, only used when Eureka can't be used

func ConnectEveryEureka

func ConnectEveryEureka(name string)

ConnectEveryEureka service in every region

func Create

func Create(servicename, packagename string, regions, count int, dependencies ...string) string

Create a tier and specify any dependencies, return the full name of the last node created

func CreateChannels

func CreateChannels() (*chan gotocol.Message, *map[string]chan gotocol.Message, *map[string]chan gotocol.Message)

CreateChannels makes the maps of channels

func CreateEureka

func CreateEureka()

CreateEureka service registries in each zone

func Exit

func Exit()

func Reload

func Reload(arch string) string

Reload the network from a file

func Run

func Run(rootservice string, ServiceNames map[int]string, ServiceIndex int)

Run architecture for a while then shut down

func SendToName

func SendToName(name string, msg gotocol.Message)

SendToName sends a message directly to a name via asgard, only used during setup

func ShutdownEureka

func ShutdownEureka()

ShutdownEureka shuts down the Eureka service registries and wait for them to go away

func ShutdownNodes

func ShutdownNodes()

ShutdownNodes - shut down the nodes and wait for them to go away

func StartNode

func StartNode(name string, dependencies ...string)

StartNode starts a node using the named package, and connect it to any dependencies

Types

type ConnDes

type ConnDes struct {
	A_name string
	B_name string
}