constellation

package
v0.21.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 27, 2026 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CachedDeviceNames = map[string]string{}
View Source 
var CachedDevices = map[string]utils.ConstellationDevice{}
View Source 
var DNSBlacklist = map[string]bool{}
View Source 
var DNSStarted = false
View Source 
var NATSClientTopic = ""
View Source 
var NebulaDefaultConfig utils.NebulaConfig
View Source 
var NebulaHasStarted = false
View Source 
var NebulaStarted = false
View Source 
var (
	ProcessMux sync.Mutex
)

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_GetNextIP added in v0.21.0 

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

func API_NewConstellation added in v0.21.0 

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

func API_Ping added in v0.16.0 

func API_Ping(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 AdjustDNS added in v0.19.0 

func AdjustDNS(logBuffer *lumberjack.Logger) error

func CheckConstellationToken added in v0.16.0 

func CheckConstellationToken(req *http.Request) error

TODO: Cache this

func ClientConnectToJS added in v0.21.0 

func ClientConnectToJS() error

func ClientHeartbeatInit added in v0.21.0 

func ClientHeartbeatInit()

func CloseNATSClient added in v0.16.0 

func CloseNATSClient()

func ConstellationAPIDevices 

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

func ConstellationConnected added in v0.21.0 

func ConstellationConnected() bool

func DeviceBlock 

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

func DeviceCreate_API added in v0.21.0 

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

func DeviceEdit_API added in v0.21.0 

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

func DeviceList 

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

func DevicePing added in v0.19.0 

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

func DevicePublicList added in v0.19.0 

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

func ExportDefaultConfigToYAML added in v0.21.0 

func ExportDefaultConfigToYAML(outputPath string) error

func ExportLighthouseFromDB added in v0.21.0 

func ExportLighthouseFromDB() error

func GetAllDevices added in v0.21.0 

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

func GetAllDevicesEvenBlocked added in v0.21.0 

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

func GetAllLightHouses 

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

func GetAllLighthouseIPFromTempConfig added in v0.21.0 

func GetAllLighthouseIPFromTempConfig() ([]string, error)

func GetAllTunneledRoutes added in v0.21.0 

func GetAllTunneledRoutes() []utils.ProxyRouteConfig

func GetCertFingerprint 

func GetCertFingerprint(certPath string) (string, error)

func GetClusterIPs added in v0.21.0 

func GetClusterIPs() ([]*url.URL, error)

func GetConfigAttribute added in v0.18.0 

func GetConfigAttribute(configPath string, attr string) (string, error)

func GetCurrentDevice added in v0.21.0 

func GetCurrentDevice() (utils.ConstellationDevice, error)

func GetCurrentDeviceAPIKey added in v0.21.0 

func GetCurrentDeviceAPIKey() (string, error)

func GetCurrentDeviceHostname added in v0.21.0 

func GetCurrentDeviceHostname() (string, error)

func GetCurrentDeviceIP added in v0.21.0 

func GetCurrentDeviceIP() (string, error)

func GetCurrentDeviceIsExitNode added in v0.21.0 

func GetCurrentDeviceIsExitNode() (bool, error)

func GetCurrentDeviceIsLoadbalancer added in v0.21.0 

func GetCurrentDeviceIsLoadbalancer() (bool, error)

func GetCurrentDeviceIsRelay added in v0.21.0 

func GetCurrentDeviceIsRelay() (bool, error)

func GetCurrentDeviceName added in v0.21.0 

func GetCurrentDeviceName() (string, error)

func GetDefaultHostnames added in v0.21.0 

func GetDefaultHostnames() []string

func GetDeviceIp added in v0.16.0 

func GetDeviceIp(device string) string

func GetLocalTunnelCache added in v0.21.0 

func GetLocalTunnelCache() []utils.ConstellationTunnel

func GetNATSCredentials added in v0.16.0 

func GetNATSCredentials() (string, string, error)

func GetNextAvailableIP added in v0.21.0 

func GetNextAvailableIP(cidr string) string

GetNextAvailableIP fetches all used IPs from the database and returns the next available IP in the given CIDR range

func Init 

func Init()

func InitConfig 

func InitConfig()

func InitDNS 

func InitDNS()

func InitHostname added in v0.21.0 

func InitHostname()

func InitNATSClient added in v0.16.0 

func InitNATSClient() error

func InitPingLighthouses added in v0.19.0 

func InitPingLighthouses()

func IsClientConnected added in v0.16.0 

func IsClientConnected() bool

func IsConstellationIP added in v0.21.0 

func IsConstellationIP(ip string) bool

func IsTunneled added in v0.21.0 

func IsTunneled(route utils.ProxyRouteConfig) bool

func MakeSyncPayload added in v0.16.0 

func MakeSyncPayload(rawPayload string) string

func MasterNATSClientRouter added in v0.16.0 

func MasterNATSClientRouter()

func PingLighthouses added in v0.19.0 

func PingLighthouses()

func PingNATSClient added in v0.16.0 

func PingNATSClient() bool

func PublicDeviceListNATS added in v0.21.0 

func PublicDeviceListNATS(m *nats.Msg)

func PublishNATSMessage added in v0.16.0 

func PublishNATSMessage(topic string, payload string) error

func ReceiveSyncPayload added in v0.16.0 

func ReceiveSyncPayload(rawPayload string) bool

func ResetNebula 

func ResetNebula() error

func RestartNebula 

func RestartNebula()

func SendNATSMessage added in v0.16.0 

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

func SendNATSMessageAllReply added in v0.21.0 

func SendNATSMessageAllReply(topic string, payload string, timeout time.Duration, callback func(response string)) error

func SendNewDBSyncMessage added in v0.21.0 

func SendNewDBSyncMessage()

func SendRequestSyncMessage added in v0.21.0 

func SendRequestSyncMessage()

func StartNATS added in v0.16.0 

func StartNATS()

func StopHeartbeat added in v0.21.0 

func StopHeartbeat()

func StopNATS added in v0.16.0 

func StopNATS()

func SyncNATSClientRouter added in v0.21.0 

func SyncNATSClientRouter(nc *nats.Conn)

func TunnelList added in v0.21.0 

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

func UpdateFirewallBlockedClients added in v0.19.0 

func UpdateFirewallBlockedClients() error

func UpdateLocalTunnelCache added in v0.21.0 

func UpdateLocalTunnelCache()

func ValidateStaticHosts added in v0.19.0 

func ValidateStaticHosts(logBuffer *lumberjack.Logger) 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`
	Invisible bool   `json:"invisible",omitempty`

	// for lighthouse only
	IsLighthouse   bool   `json:"isLighthouse",omitempty`
	CosmosNode     int    `json:"cosmosNode",omitempty`
	IsRelay        bool   `json:"isRelay",omitempty`
	IsLoadBalancer bool   `json:"isLoadBalancer",omitempty`
	IsExitNode     bool   `json:"isExitNode",omitempty`
	PublicHostname string `json:"PublicHostname",omitempty`
	Port           string `json:"port",omitempty`

	// internal
	APIKey string `json:"-"`
}

func DeviceCreate 

func DeviceCreate(request DeviceCreateRequestJSON) (string, string, string, DeviceCreateRequestJSON, error)

type DeviceEditRequestJSON added in v0.21.0 

type DeviceEditRequestJSON struct {
	IsLighthouse   bool `json:"isLighthouse"`
	IsRelay        bool `json:"isRelay"`
	IsExitNode     bool `json:"isExitNode"`
	IsLoadBalancer bool `json:"isLoadBalancer"`
}

type NodeHeartbeat added in v0.21.0 

type NodeHeartbeat struct {
	DeviceName   string
	IP           string
	IsRelay      bool
	IsLighthouse bool
	IsExitNode   bool
	CosmosNode   int
	Tunnels      []utils.ProxyRouteConfig
}

type PublicDeviceInfo added in v0.19.0 

type PublicDeviceInfo struct {
	DeviceID       string `json:"id"`
	DeviceName     string `json:"name"`
	User           string `json:"user"`
	IP             string `json:"ip"`
	IsLighthouse   bool   `json:"isLighthouse"`
	CosmosNode     int    `json:"cosmosNode"`
	IsRelay        bool   `json:"isRelay"`
	IsExitNode     bool   `json:"isExitNode"`
	PublicHostname string `json:"publicHostname"`
	Port           string `json:"port"`
}

PublicDeviceInfo represents the limited device information exposed to the public API

type SyncDNSPayload added in v0.21.0 

type SyncDNSPayload struct {
	DNSPort                 string                        `json:"dnsPort"`
	DNSFallback             string                        `json:"dnsFallback"`
	DNSBlockBlacklist       bool                          `json:"dnsBlockBlacklist"`
	DNSAdditionalBlocklists []string                      `json:"dnsAdditionalBlocklists"`
	CustomDNSEntries        []utils.ConstellationDNSEntry `json:"customDNSEntries"`
}

type SyncPayload added in v0.16.0 

type SyncPayload struct {
	Database       string         `json:"database"`
	AuthPrivateKey string         `json:"authPrivateKey"`
	AuthPublicKey  string         `json:"authPublicKey"`
	CART           string         `json:"caCrt"`
	CAKey          string         `json:"caKey"`
	DNS            SyncDNSPayload `json:"dns"`
	LastEdited     int64          `json:"lastEdited"`
}

type SyncRequestPayload added in v0.21.0 

type SyncRequestPayload struct {
	EditedAt int64 `json:"editedAt"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.