Documentation
¶
Index ¶
- Constants
- Variables
- func AddHostDockerInternal(args []string) ([]string, error)
- func CheckBindOk(portsInUse map[string]string, addrs []string) error
- func CleanupEtcdRamDisk() error
- func CloudletPrometheusExists(ctx context.Context) bool
- func CrmServiceWait(key edgeproto.CloudletKey) error
- func EnsureProcessesByName(processName string, processArgs string) bool
- func GetCRMCmdArgs(cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, ...) ([]string, *map[string]string, error)
- func GetCloudletLog(ctx context.Context, key *edgeproto.CloudletKey) (string, error)
- func GetCloudletLogFile(filePrefix string) string
- func GetCloudletPrometheusCmdArgs() []string
- func GetCloudletPrometheusConfigHostFilePath() string
- func GetCloudletPrometheusDockerArgs(cloudlet *edgeproto.Cloudlet, cfgFile string) []string
- func GetCrmAccessKeyFile() string
- func GetCrmProc(cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, ...) (CrmProcess, []StartOp, error)
- func GetDummyPrivateKey() (*os.File, error)
- func GetLocalAccessKeyDir() string
- func GetLocalAccessKeyFile(filePrefix string, haRole HARole) string
- func GetPortsInUse() (map[string]string, error)
- func GetShepherdCmdArgs(cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig) ([]string, *map[string]string, error)
- func GetTypeString(p interface{}) string
- func KillProcessesByName(processName string, maxwait time.Duration, processArgs string, c chan string)
- func SetupInflux(dir string, ops ...InfluxOp) (string, error)
- func SplitAddr(addr string) (string, string)
- func StartCRMService(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) error
- func StartCRMServicesHA(ctx context.Context, cloudlet *edgeproto.Cloudlet, ...) error
- func StartCloudletPrometheus(ctx context.Context, remoteWriteAddr string, cloudlet *edgeproto.Cloudlet, ...) error
- func StartLocal(name, bin string, args, envs []string, logfile string) (*exec.Cmd, error)
- func StopCRMService(ctx context.Context, cloudlet *edgeproto.Cloudlet, haRole HARole, ...) error
- func StopCloudletPrometheus(ctx context.Context) error
- func StopFakeEnvoyExporters(ctx context.Context) error
- func StopLocal(cmd *exec.Cmd)
- func StopProcess(p Process, maxwait time.Duration, c chan string)
- func StopShepherdService(ctx context.Context, cloudlet *edgeproto.Cloudlet) error
- func WriteAllCAs(inputCAFile, outputCAFile string) error
- func WriteCloudletPromConfig(ctx context.Context, remoteWriteAddr string, promScrapeInterval *time.Duration, ...) error
- type AutoProv
- type CCRM
- type ClusterSvc
- type ColorWriter
- type Common
- type Controller
- func (p *Controller) ConnectAPI(timeout time.Duration) (*grpc.ClientConn, error)
- func (p *Controller) GetBindAddrs() []string
- func (p *Controller) GetExeName() string
- func (p *Controller) GetTlsFile() string
- func (p *Controller) LookupArgs() string
- func (p *Controller) StartLocal(logfile string, opts ...StartOp) error
- func (p *Controller) StopLocal()
- type Crm
- func (p *Crm) CrmProc() *Crm
- func (p *Crm) GetArgs(opts ...StartOp) []string
- func (p *Crm) GetBindAddrs() []string
- func (p *Crm) GetExeName() string
- func (p *Crm) LookupArgs() string
- func (p *Crm) LookupArgsWithHARole(HARole HARole) string
- func (p *Crm) StartLocal(logfile string, opts ...StartOp) error
- func (p *Crm) StopLocal()
- func (p *Crm) String(opts ...StartOp) string
- func (p *Crm) Wait() error
- type CrmProcess
- type CrmServiceOp
- type CrmServiceOptions
- type Dme
- func (p *Dme) ConnectAPI(timeout time.Duration) (*grpc.ClientConn, error)
- func (p *Dme) GetBindAddrs() []string
- func (p *Dme) GetExeName() string
- func (p *Dme) GetRestClient(timeout time.Duration) (*http.Client, error)
- func (p *Dme) LookupArgs() string
- func (p *Dme) StartLocal(logfile string, opts ...StartOp) error
- func (p *Dme) StopLocal()
- type DockerGeneric
- type DockerNetwork
- type EdgeTurn
- type ElasticSearch
- type Etcd
- type GetCrmProcFunc
- type HARole
- type Influx
- func (p *Influx) GetBindAddrs() []string
- func (p *Influx) GetClient() (influxclient.Client, error)
- func (p *Influx) GetExeName() string
- func (p *Influx) LookupArgs() string
- func (p *Influx) ResetData() error
- func (p *Influx) StartLocal(logfile string, opts ...StartOp) (reterr error)
- func (p *Influx) StopLocal()
- type InfluxOp
- type InfluxOptions
- type Jaeger
- type LocApiSim
- type LocalAuth
- type NginxProxy
- type NginxServerConfig
- type NodeCommon
- type NotifyRoot
- type Process
- type ProcessInfo
- type QosSesSrvSim
- type RedisCache
- type RedisClientCommon
- type Shepherd
- func (p *Shepherd) GetArgs(opts ...StartOp) []string
- func (p *Shepherd) GetBindAddrs() []string
- func (p *Shepherd) GetExeName() string
- func (p *Shepherd) LookupArgs() string
- func (p *Shepherd) StartLocal(logfile string, opts ...StartOp) error
- func (p *Shepherd) StopLocal()
- func (p *Shepherd) String(opts ...StartOp) string
- func (p *Shepherd) Wait()
- type StartOp
- type StartOptions
- type TLSCerts
- type Vault
- func (p *Vault) GetAppRole(region, name string, roleID, secretID *string, err *error)
- func (p *Vault) GetBindAddrs() []string
- func (p *Vault) GetExeName() string
- func (p *Vault) LookupArgs() string
- func (p *Vault) PutSecret(region, name, secret string, err *error)
- func (p *Vault) PutSecretsJson(SecretsPath, jsonFile string, err *error)
- func (p *Vault) Run(bin, args string, err *error) string
- func (p *Vault) RunWithInput(bin, args string, input io.Reader, err *error) string
- func (p *Vault) Setup(opts ...StartOp) error
- func (p *Vault) StartLocal(logfile string, opts ...StartOp) error
- func (p *Vault) StartLocalRoles() (*VaultRoles, error)
- func (p *Vault) StopLocal()
- type VaultData
- type VaultRegionRoles
- type VaultRoles
Constants ¶
const ( PrometheusContainer = "cloudletPrometheus" PrometheusImagePath = "prom/prometheus" PrometheusImageVersion = "v2.19.2" PrometheusRulesPrefix = "rulefile_" CloudletPrometheusPort = "9092" )
Variables ¶
var DefaultBindAddr = "127.0.0.1:8088"
var DefaultHttpAddr = "127.0.0.1:8086"
SsetupInflux sets up the InfluxDB dir and config file. The config file name is returned to be used when running InfluxDB. The passed in directory is where all the data and config file will be placed. Note that InfluxDB requires a config file, and does not accept configuration options as command line arguments.
var EtcdRamDiskSizeVar = "ETCD_RAMDISK_SIZEG"
var InfluxCredsFile = "/tmp/influx.json"
var LocalRedisPort = "6379"
var LocalRedisSentinelPort = "26379"
var MaxRamDiskSizeG = 3.0
var RamDisk = "ramdisk"
Functions ¶
func AddHostDockerInternal ¶
OS-specific function to add host.docker.internal mapping if needed, so that process from inside container can reach service running outside container.
func CleanupEtcdRamDisk ¶
func CleanupEtcdRamDisk() error
This should be called after etcd processes are stopped
func CrmServiceWait ¶
func CrmServiceWait(key edgeproto.CloudletKey) error
func EnsureProcessesByName ¶
func GetCRMCmdArgs ¶
func GetCRMCmdArgs(cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, haRole HARole, crmOps ...CrmServiceOp) ([]string, *map[string]string, error)
func GetCloudletLog ¶
Parses cloudlet logfile and fetches FatalLog output
func GetCloudletLogFile ¶
func GetCloudletPrometheusCmdArgs ¶
func GetCloudletPrometheusCmdArgs() []string
command line options for prometheus container
func GetCloudletPrometheusConfigHostFilePath ¶
func GetCloudletPrometheusConfigHostFilePath() string
func GetCloudletPrometheusDockerArgs ¶
base docker run args
func GetCrmAccessKeyFile ¶
func GetCrmAccessKeyFile() string
func GetCrmProc ¶
func GetCrmProc(cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, HARole HARole) (CrmProcess, []StartOp, error)
func GetDummyPrivateKey ¶
func GetLocalAccessKeyDir ¶
func GetLocalAccessKeyDir() string
func GetLocalAccessKeyFile ¶
func GetPortsInUse ¶
Get ports in use by the OS. Key is port, val is description of process. This pretty much ignores the discrepancy between ipv4 and ipv6, because this is only for local listeners which are all ipv4 right now.
func GetShepherdCmdArgs ¶
func GetTypeString ¶
func GetTypeString(p interface{}) string
func KillProcessesByName ¶
func KillProcessesByName(processName string, maxwait time.Duration, processArgs string, c chan string)
first tries to kill process with SIGINT, then waits up to maxwait time for it to die. After that point it kills with SIGKILL
func StartCRMService ¶
func StartCRMService(ctx context.Context, cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, haRole HARole, redisCfg *rediscache.RedisConfig, crmOps ...CrmServiceOp) error
func StartCRMServicesHA ¶
func StartCRMServicesHA(ctx context.Context, cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, redisCfg *rediscache.RedisConfig, crmOps ...CrmServiceOp) error
func StartCloudletPrometheus ¶
func StartCloudletPrometheus(ctx context.Context, remoteWriteAddr string, cloudlet *edgeproto.Cloudlet, settings *edgeproto.Settings) error
Starts prometheus container and connects it to the default ports
func StartLocal ¶
func StopCRMService ¶
func StopCRMService(ctx context.Context, cloudlet *edgeproto.Cloudlet, haRole HARole, crmOps ...CrmServiceOp) error
StopCRMService stops the crmserver on the specified cloudlet, or kills any crm process if the cloudlet specified is nil
func StopCloudletPrometheus ¶
func StopFakeEnvoyExporters ¶
func StopShepherdService ¶
func WriteAllCAs ¶
Types ¶
type AutoProv ¶
type AutoProv struct {
Common `yaml:",inline"`
NodeCommon `yaml:",inline"`
NotifyAddrs string
CtrlAddrs string
InfluxAddr string
Region string
// contains filtered or unexported fields
}
func (*AutoProv) GetBindAddrs ¶
func (*AutoProv) GetExeName ¶
func (*AutoProv) LookupArgs ¶
type CCRM ¶
type CCRM struct {
Common `yaml:",inline"`
NodeCommon `yaml:",inline"`
RedisClientCommon `yaml:",inline"`
Region string
APIAddr string
AppDNSRoot string
CloudletRegistryPath string
CloudletVMImagePath string
VersionTag string
ControllerApiAddr string
ControllerNotifyAddr string
ControllerPublicAccessApiAddr string
ControllerPublicNotifyAddr string
ThanosRecvAddr string
AnsibleListenAddr string
AnsiblePublicAddr string
EtcdAddrs string
FederationExternalAddr string
TestMode bool
DNSZone string
EnvoyWithCurlImage string
NginxWithCurlImage string
// contains filtered or unexported fields
}
func (*CCRM) GetBindAddrs ¶
func (*CCRM) GetExeName ¶
func (*CCRM) LookupArgs ¶
type ClusterSvc ¶
type ClusterSvc struct {
Common `yaml:",inline"`
NodeCommon `yaml:",inline"`
NotifyAddrs string
CtrlAddrs string
PromPorts string
InfluxDB string
Interval string
Region string
PluginRequired bool
// contains filtered or unexported fields
}
func (*ClusterSvc) GetBindAddrs ¶
func (p *ClusterSvc) GetBindAddrs() []string
func (*ClusterSvc) GetExeName ¶
func (p *ClusterSvc) GetExeName() string
func (*ClusterSvc) LookupArgs ¶
func (p *ClusterSvc) LookupArgs() string
func (*ClusterSvc) StartLocal ¶
func (p *ClusterSvc) StartLocal(logfile string, opts ...StartOp) error
func (*ClusterSvc) StopLocal ¶
func (p *ClusterSvc) StopLocal()
type ColorWriter ¶
func NewColorWriter ¶
func NewColorWriter(name string) *ColorWriter
type Common ¶
type Common struct {
Kind string
Name string
Hostname string
DockerImage string
EnvVars map[string]string
}
func (*Common) GetEnvVarsP ¶
func (*Common) GetHostname ¶
type Controller ¶
type Controller struct {
Common `yaml:",inline"`
NodeCommon `yaml:",inline"`
RedisClientCommon `yaml:",inline"`
EtcdAddrs string
ApiAddr string
HttpAddr string
NotifyAddr string
NotifyRootAddrs string
NotifyParentAddrs string
EdgeTurnAddr string
InfluxAddr string
Region string
TestMode bool
RegistryFQDN string
ArtifactoryFQDN string
VersionTag string
CheckpointInterval string
AppDNSRoot string
DNSZone string
PlatformServiceAddrs []string
// contains filtered or unexported fields
}
func (*Controller) ConnectAPI ¶
func (p *Controller) ConnectAPI(timeout time.Duration) (*grpc.ClientConn, error)
func (*Controller) GetBindAddrs ¶
func (p *Controller) GetBindAddrs() []string
func (*Controller) GetExeName ¶
func (p *Controller) GetExeName() string
func (*Controller) GetTlsFile ¶
func (p *Controller) GetTlsFile() string
func (*Controller) LookupArgs ¶
func (p *Controller) LookupArgs() string
func (*Controller) StartLocal ¶
func (p *Controller) StartLocal(logfile string, opts ...StartOp) error
func (*Controller) StopLocal ¶
func (p *Controller) StopLocal()
type Crm ¶
type Crm struct {
Common `yaml:",inline"`
NodeCommon `yaml:",inline"`
RedisClientCommon `yaml:",inline"`
NotifyAddrs string
NotifySrvAddr string
CloudletKey string
Platform string
Plugin string
PhysicalName string
TestMode bool
Span string
ContainerVersion string
VMImageVersion string
CloudletVMImagePath string
EnvoyWithCurlImage string
NginxWithCurlImage string
Region string
CommercialCerts bool
AppDNSRoot string
AnsiblePublicAddr string
CacheDir string
HARole HARole
// contains filtered or unexported fields
}
func (*Crm) GetBindAddrs ¶
func (*Crm) GetExeName ¶
func (*Crm) LookupArgs ¶
func (*Crm) LookupArgsWithHARole ¶
type CrmProcess ¶
type CrmServiceOp ¶
type CrmServiceOp func(options *CrmServiceOptions)
func WithExeName ¶
func WithExeName(name string) CrmServiceOp
func WithGetCrmProc ¶
func WithGetCrmProc(getCrmProc GetCrmProcFunc) CrmServiceOp
type CrmServiceOptions ¶
type CrmServiceOptions struct {
// contains filtered or unexported fields
}
func GetCrmServiceOptions ¶
func GetCrmServiceOptions(ops ...CrmServiceOp) *CrmServiceOptions
type Dme ¶
type Dme struct {
Common `yaml:",inline"`
NodeCommon `yaml:",inline"`
ApiAddr string
HttpAddr string
NotifyAddrs string
LocVerUrl string
TokSrvUrl string
QosPosUrl string
QosSesAddr string
Carrier string
CloudletKey string
CookieExpr string
Region string
// contains filtered or unexported fields
}
func (*Dme) ConnectAPI ¶
func (*Dme) GetBindAddrs ¶
func (*Dme) GetExeName ¶
func (*Dme) GetRestClient ¶
func (*Dme) LookupArgs ¶
type DockerGeneric ¶
type DockerGeneric struct {
Common `yaml:",inline"`
Links []string
DockerNetwork string
DockerEnvVars map[string]string
TLS TLSCerts
// contains filtered or unexported fields
}
func (*DockerGeneric) GetCmd ¶
func (p *DockerGeneric) GetCmd() *exec.Cmd
func (*DockerGeneric) GetExeName ¶
func (p *DockerGeneric) GetExeName() string
func (*DockerGeneric) GetRunArgs ¶
func (p *DockerGeneric) GetRunArgs() []string
func (*DockerGeneric) LookupArgs ¶
func (p *DockerGeneric) LookupArgs() string
func (*DockerGeneric) SetCmd ¶
func (p *DockerGeneric) SetCmd(cmd *exec.Cmd)
func (*DockerGeneric) StopLocal ¶
func (p *DockerGeneric) StopLocal()
type DockerNetwork ¶
type DockerNetwork struct {
Common `yaml:",inline"`
}
func (*DockerNetwork) Create ¶
func (d *DockerNetwork) Create() error
func (*DockerNetwork) Delete ¶
func (d *DockerNetwork) Delete() error
type EdgeTurn ¶
type EdgeTurn struct {
Common `yaml:",inline"`
NodeCommon `yaml:",inline"`
ListenAddr string
ProxyAddr string
Region string
TestMode bool
// contains filtered or unexported fields
}
func (*EdgeTurn) GetBindAddrs ¶
func (*EdgeTurn) GetExeName ¶
func (*EdgeTurn) LookupArgs ¶
type ElasticSearch ¶
type ElasticSearch struct {
DockerGeneric `yaml:",inline"`
Type string
Port string
}
func (*ElasticSearch) GetBindAddrs ¶
func (p *ElasticSearch) GetBindAddrs() []string
func (*ElasticSearch) StartElasticSearch ¶
func (p *ElasticSearch) StartElasticSearch(logfile string, opts ...StartOp) error
func (*ElasticSearch) StartKibana ¶
func (p *ElasticSearch) StartKibana(logfile string, opts ...StartOp) error
func (*ElasticSearch) StartLocal ¶
func (p *ElasticSearch) StartLocal(logfile string, opts ...StartOp) error
type Etcd ¶
type Etcd struct {
Common `yaml:",inline"`
DataDir string
PeerAddrs string
ClientAddrs string
InitialCluster string
// contains filtered or unexported fields
}
func (*Etcd) GetBindAddrs ¶
func (*Etcd) GetExeName ¶
func (*Etcd) LookupArgs ¶
type GetCrmProcFunc ¶
type GetCrmProcFunc func(cloudlet *edgeproto.Cloudlet, pfConfig *edgeproto.PlatformConfig, HARole HARole) (CrmProcess, []StartOp, error)
type HARole ¶
type HARole string
var HARoleAll HARole = "all"
var HARolePrimary HARole = "primary"
var HARoleSecondary HARole = "secondary"
type Influx ¶
type Influx struct {
Common `yaml:",inline"`
DataDir string
HttpAddr string
BindAddr string
Config string // set during Start
TLS TLSCerts
Auth LocalAuth
// contains filtered or unexported fields
}
func (*Influx) GetBindAddrs ¶
func (*Influx) GetExeName ¶
func (*Influx) LookupArgs ¶
func (*Influx) StartLocal ¶
type InfluxOp ¶
type InfluxOp func(opts *InfluxOptions)
func WithBindAddr ¶
func WithHttpAddr ¶
func WithServerCert ¶
func WithServerCertKey ¶
type InfluxOptions ¶
type InfluxOptions struct {
// DataDir is where all the data will be stored (plus config file)
DataDir string
// HttpAddr is the listener addr for clients
HttpAddr string
// BindAddr is the listener addr for clustering multiple instances
BindAddr string
// TLS server certificate
TlsCertfile string
// TLS server cert key
TlsCertKey string
// Authentication
Auth bool
}
func (*InfluxOptions) Apply ¶
func (s *InfluxOptions) Apply(ops ...InfluxOp)
func (*InfluxOptions) SetDefaults ¶
func (s *InfluxOptions) SetDefaults(dir string)
type LocApiSim ¶
type LocApiSim struct {
Common `yaml:",inline"`
Port int
Locfile string
Geofile string
Country string
// contains filtered or unexported fields
}
func (*LocApiSim) GetBindAddrs ¶
func (*LocApiSim) GetExeName ¶
func (*LocApiSim) LookupArgs ¶
func (*LocApiSim) StartLocal ¶
type NginxProxy ¶
type NginxProxy struct {
DockerGeneric `yaml:",inline"`
Servers []NginxServerConfig
}
func (*NginxProxy) GetBindAddrs ¶
func (p *NginxProxy) GetBindAddrs() []string
func (*NginxProxy) StartLocal ¶
func (p *NginxProxy) StartLocal(logfile string, opts ...StartOp) error
type NginxServerConfig ¶
type NodeCommon ¶
type NodeCommon struct {
TLS TLSCerts
VaultAddr string
UseVaultPki bool
DeploymentTag string
AccessApiAddr string
AccessKeyFile string
ValidDomains string
}
Common args for all nodeMgr processes
func (*NodeCommon) GetNodeMgrArgs ¶
func (p *NodeCommon) GetNodeMgrArgs() []string
type NotifyRoot ¶
type NotifyRoot struct {
Common `yaml:",inline"`
NodeCommon `yaml:",inline"`
NotifyAddr string
// contains filtered or unexported fields
}
func (*NotifyRoot) GetBindAddrs ¶
func (p *NotifyRoot) GetBindAddrs() []string
func (*NotifyRoot) GetExeName ¶
func (p *NotifyRoot) GetExeName() string
func (*NotifyRoot) LookupArgs ¶
func (p *NotifyRoot) LookupArgs() string
func (*NotifyRoot) StartLocal ¶
func (p *NotifyRoot) StartLocal(logfile string, opts ...StartOp) error
func (*NotifyRoot) StopLocal ¶
func (p *NotifyRoot) StopLocal()
type Process ¶
type Process interface {
// Get the name of the process
GetName() string
// Get the hostname of the process
GetHostname() string
// Get EnvVars
GetEnv() []string
// Start the process
StartLocal(logfile string, opts ...StartOp) error
// Stop the process
StopLocal()
// Get the exe name of the process binary
GetExeName() string
// Get lookup args that can be used to find the local process using pgrep
LookupArgs() string
// Get Addresses that process binds to
GetBindAddrs() []string
}
type ProcessInfo ¶
type ProcessInfo struct {
// contains filtered or unexported fields
}
type QosSesSrvSim ¶
type QosSesSrvSim struct {
Common `yaml:",inline"`
Port int
// contains filtered or unexported fields
}
func (*QosSesSrvSim) GetBindAddrs ¶
func (p *QosSesSrvSim) GetBindAddrs() []string
func (*QosSesSrvSim) GetExeName ¶
func (p *QosSesSrvSim) GetExeName() string
func (*QosSesSrvSim) LookupArgs ¶
func (p *QosSesSrvSim) LookupArgs() string
func (*QosSesSrvSim) StartLocal ¶
func (p *QosSesSrvSim) StartLocal(logfile string, opts ...StartOp) error
func (*QosSesSrvSim) StopLocal ¶
func (p *QosSesSrvSim) StopLocal()
type RedisCache ¶
type RedisCache struct {
Common `yaml:",inline"`
Type string
Port string
MasterPort string
// contains filtered or unexported fields
}
func (*RedisCache) GetBindAddrs ¶
func (p *RedisCache) GetBindAddrs() []string
func (*RedisCache) GetExeName ¶
func (p *RedisCache) GetExeName() string
func (*RedisCache) LookupArgs ¶
func (p *RedisCache) LookupArgs() string
func (*RedisCache) ResetData ¶
func (p *RedisCache) ResetData(logfile string) error
func (*RedisCache) StartLocal ¶
func (p *RedisCache) StartLocal(logfile string, opts ...StartOp) error
func (*RedisCache) StopLocal ¶
func (p *RedisCache) StopLocal()
type RedisClientCommon ¶
type RedisClientCommon struct {
RedisMasterName string
RedisSentinelAddrs string
RedisStandaloneAddr string
}
Common args for all redis clients
func (*RedisClientCommon) GetRedisClientArgs ¶
func (p *RedisClientCommon) GetRedisClientArgs() []string
type Shepherd ¶
type Shepherd struct {
Common `yaml:",inline"`
NodeCommon `yaml:",inline"`
NotifyAddrs string
Platform string
MetricsAddr string
PromTargetAddr string
PhysicalName string
CloudletKey string
Span string
Region string
AppDNSRoot string
ThanosRecvAddr string
// contains filtered or unexported fields
}
func StartShepherdService ¶
func (*Shepherd) GetBindAddrs ¶
func (*Shepherd) GetExeName ¶
func (*Shepherd) LookupArgs ¶
type StartOp ¶
type StartOp func(op *StartOptions)
func WithCleanStartup ¶
func WithCleanStartup() StartOp
func WithCustomExeName ¶
func WithExtraArgs ¶
func WithNoConfig ¶
func WithNoConfig() StartOp
func WithRolesFile ¶
type StartOptions ¶
type StartOptions struct {
Debug string
RolesFile string
CleanStartup bool
ExtraArgs []string
NoConfig bool
ExeName string
}
func (*StartOptions) ApplyStartOptions ¶
func (s *StartOptions) ApplyStartOptions(opts ...StartOp)
type TLSCerts ¶
type TLSCerts struct {
ServerCert string
ServerKey string
CACert string
ClientCert string
ApiCert string
ApiKey string
}
func (*TLSCerts) AddInternalPkiArgs ¶
type Vault ¶
type Vault struct {
Common `yaml:",inline"`
DmeSecret string
Regions string
VaultDatas []VaultData
ListenAddr string
RootToken string
CADir string
RunCACert string
PKIDomain string
DNSZone string
CloudflareAPIKey string
// contains filtered or unexported fields
}
func (*Vault) GetAppRole ¶
func (*Vault) GetBindAddrs ¶
func (*Vault) GetExeName ¶
func (*Vault) LookupArgs ¶
func (*Vault) PutSecretsJson ¶
func (*Vault) RunWithInput ¶
func (*Vault) StartLocalRoles ¶
func (p *Vault) StartLocalRoles() (*VaultRoles, error)
type VaultRegionRoles ¶
type VaultRegionRoles struct {
DmeRoleID string `json:"dmeroleid"`
DmeSecretID string `json:"dmesecretid"`
RotatorRoleID string `json:"rotatorroleid"`
RotatorSecretID string `json:"rotatorsecretid"`
CtrlRoleID string `json:"controllerroleid"`
CtrlSecretID string `json:"controllersecretid"`
ClusterSvcRoleID string `json:"clustersvcroleid"`
ClusterSvcSecretID string `json:"clustersvcsecretid"`
EdgeTurnRoleID string `json:"edgeturnroleid"`
EdgeTurnSecretID string `json:"edgeturnsecretid"`
AutoProvRoleID string `json:"autoprovroleid"`
AutoProvSecretID string `json:"autoprovsecretid"`
FrmRoleID string `json:"frmroleid"`
FrmSecretID string `json:"frmsecretid"`
}
type VaultRoles ¶
type VaultRoles struct {
NotifyRootRoleID string `json:"notifyrootroleid"`
NotifyRootSecretID string `json:"notifyrootsecretid"`
MCRoleID string `json:"mcroleid"`
MCSecretID string `json:"mcsecretid"`
RotatorRoleID string `json:"rotatorroleid"`
RotatorSecretID string `json:"rotatorsecretid"`
AlertMgrSidecarRoleID string `json:"alertmgrsidecarroleid"`
AlertMgrSidecarSecretID string `json:"alertmgrsidecarsecretid"`
RegionRoles map[string]*VaultRegionRoles
}
func (*VaultRoles) GetRegionRoles ¶
func (s *VaultRoles) GetRegionRoles(region string) *VaultRegionRoles
Source Files
¶
- cloudlet_services.go
- influxconf.go
- process.go
- process_autoprov.go
- process_ccrm.go
- process_clustersvc.go
- process_controller.go
- process_crm.go
- process_dme.go
- process_dockergeneric.go
- process_edgeturn.go
- process_elasticsearch.go
- process_etcd.go
- process_influx.go
- process_jaeger.go
- process_local.go
- process_locapisim.go
- process_nginx.go
- process_notifyroot.go
- process_qossessrvsim.go
- process_rediscache.go
- process_shepherd.go
- process_tlscerts.go
- process_vault.go