constellation

Documentation

Index

• Variables
• func API_ConnectToExisting(w http.ResponseWriter, req *http.Request)
• func API_GetConfig(w http.ResponseWriter, req *http.Request)
• func API_GetLogs(w http.ResponseWriter, req *http.Request)
• func API_Reset(w http.ResponseWriter, req *http.Request)
• func API_Restart(w http.ResponseWriter, req *http.Request)
• func CheckConstellationToken(req *http.Request) error
• func CloseNATSClient()
• func ConstellationAPIDevices(w http.ResponseWriter, req *http.Request)
• func DeviceBlock(w http.ResponseWriter, req *http.Request)
• func DeviceCreate(w http.ResponseWriter, req *http.Request)
• func DeviceList(w http.ResponseWriter, req *http.Request)
• func ExportConfigToYAML(overwriteConfig utils.ConstellationConfig, outputPath string) error
• func GetAllLightHouses() ([]utils.ConstellationDevice, error)
• func GetBlockedDevices() ([]utils.ConstellationDevice, error)
• func GetCertFingerprint(certPath string) (string, error)
• func GetDeviceConfigForSync(nickname, deviceName string) ([]byte, error)
• func GetDeviceConfigManualSync(w http.ResponseWriter, req *http.Request)
• func GetDeviceConfigSync(w http.ResponseWriter, req *http.Request)
• func GetDeviceIp(device string) string
• func GetNATSCredentials(isMaster bool) (string, string, error)
• func Init()
• func InitConfig()
• func InitDNS()
• func InitNATSClient()
• func IsClientConnected() bool
• func MasterNATSClientRouter()
• func PublishNATSMessage(topic string, payload string)
• func ResetNebula() error
• func RestartNebula()
• func SendNATSMessage(topic string, payload string) (string, error)
• func SlaveConfigSync(newConfig string) (bool, error)
• func SlaveNATSClientRouter()
• func StartNATS()
• func StopNATS()
• func TriggerClientResync() error
• type DeviceBlockRequestJSON
• type DeviceCreateRequestJSON
• type DeviceResyncRequest

Variables

var (
	ProcessMux            sync.Mutex
	ConstellationInitLock sync.Mutex
)

var APIKey = ""

var CachedDeviceNames = map[string]string{}

var CachedDevices = map[string]utils.ConstellationDevice{}

var DNSBlacklist = map[string]bool{}

var DNSStarted = false

var DeviceName = ""

var MASTERPWD = utils.GenerateRandomString(24)

var MASTERUSER = "SERVERUSER"

var NATSClientTopic = ""

var NebulaDefaultConfig utils.NebulaConfig

var NebulaFailedStarting = false

var NebulaStarted = false

Functions

func API_ConnectToExisting

func API_ConnectToExisting(w http.ResponseWriter, req *http.Request)

func API_GetConfig

func API_GetConfig(w http.ResponseWriter, req *http.Request)

func API_GetLogs

func API_GetLogs(w http.ResponseWriter, req *http.Request)

func API_Reset

func API_Reset(w http.ResponseWriter, req *http.Request)

func API_Restart

func API_Restart(w http.ResponseWriter, req *http.Request)

func CheckConstellationToken

func CheckConstellationToken(req *http.Request) error

TODO: Cache this

func CloseNATSClient

func CloseNATSClient()

func ConstellationAPIDevices

func ConstellationAPIDevices(w http.ResponseWriter, req *http.Request)

func DeviceBlock

func DeviceBlock(w http.ResponseWriter, req *http.Request)

func DeviceCreate

func DeviceCreate(w http.ResponseWriter, req *http.Request)

func DeviceList

func DeviceList(w http.ResponseWriter, req *http.Request)

func ExportConfigToYAML

func ExportConfigToYAML(overwriteConfig utils.ConstellationConfig, outputPath string) error

func GetAllLightHouses

func GetAllLightHouses() ([]utils.ConstellationDevice, error)

func GetBlockedDevices

func GetBlockedDevices() ([]utils.ConstellationDevice, error)

func GetCertFingerprint

func GetCertFingerprint(certPath string) (string, error)

func GetDeviceConfigForSync

func GetDeviceConfigForSync(nickname, deviceName string) ([]byte, error)

func GetDeviceConfigManualSync

func GetDeviceConfigManualSync(w http.ResponseWriter, req *http.Request)

func GetDeviceConfigSync

func GetDeviceConfigSync(w http.ResponseWriter, req *http.Request)

func GetDeviceIp

func GetDeviceIp(device string) string

func GetNATSCredentials

func GetNATSCredentials(isMaster bool) (string, string, error)

func Init

func Init()

func InitConfig

func InitConfig()

func InitDNS

func InitDNS()

func InitNATSClient

func InitNATSClient()

func IsClientConnected

func IsClientConnected() bool

func MasterNATSClientRouter

func MasterNATSClientRouter()

func PublishNATSMessage

func PublishNATSMessage(topic string, payload string)

func ResetNebula

func ResetNebula() error

func RestartNebula

func RestartNebula()

func SendNATSMessage

func SendNATSMessage(topic string, payload string) (string, error)

func SlaveConfigSync

func SlaveConfigSync(newConfig string) (bool, error)

func SlaveNATSClientRouter

func SlaveNATSClientRouter()

func StartNATS

func StartNATS()

func StopNATS

func StopNATS()

func TriggerClientResync

func TriggerClientResync() error

Types

type DeviceBlockRequestJSON

type DeviceBlockRequestJSON struct {
	Nickname   string `json:"nickname",validate:"required,min=3,max=32,alphanum"`
	DeviceName string `json:"deviceName",validate:"required,min=3,max=32,alphanum"`
	Block      bool   `json:"block",omitempty`
}

type DeviceCreateRequestJSON

type DeviceCreateRequestJSON struct {
	DeviceName string `json:"deviceName",validate:"required,min=3,max=32,alphanum"`
	IP         string `json:"ip",validate:"required,ipv4"`
	PublicKey  string `json:"publicKey",omitempty`

	// for devices only
	Nickname string `json:"nickname",validate:"max=32,alphanum",omitempty`

	// for lighthouse only
	IsLighthouse   bool   `json:"isLighthouse",omitempty`
	IsRelay        bool   `json:"isRelay",omitempty`
	PublicHostname string `json:"PublicHostname",omitempty`
	Port           string `json:"port",omitempty`
}

type DeviceResyncRequest

type DeviceResyncRequest struct {
	Nickname   string `json:"nickname",validate:"required,min=3,max=32,alphanum"`
	DeviceName string `json:"deviceName",validate:"required,min=3,max=32,alphanum"`
}