v1

package
v0.0.1-dev-f695ecd Latest Latest
Warning

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

 Go to latest Published: May 9, 2025 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Tokens = "tokens"
	Logout = "logout"
)
View Source 
const (
	Healths                   = "healths"
	HealthRepairingCollection = "repairing"

	AscSort  = `columns: ["_time"], desc: false`
	DescSort = `columns: ["_time"], desc: true`
)
View Source 
const (
	Nodes             = "nodes"
	DataCenterHelpUrl = "https://www.bigstack.co/contact-us"
)
View Source 
const (
	RoleControl          = "control"
	RoleCompute          = "compute"
	RoleStorage          = "storage"
	RoleControlConverged = "control-converged"
	RoleModerator        = "moderator"
	RoleEdgeCore         = "edge-core"
)
View Source 
const (
	ISO8601  = "2006-01-02T15:04:05"
	ISO8601Z = "2006-01-02T15:04:05+00:00"
	RFC3339  = time.RFC3339
	RFC3339Z = "2006-01-02T15:04:05Z07:00"
)
View Source 
const (
	Tunings         = "tunings"
	TuningRecordTTL = 3600
)
View Source 
const (
	ApiDoc = "api-doc"
)
View Source 
const (
	DataCenters = "datacenters"
)
View Source 
const (
	Grafana = "grafana"
)
View Source 
const (
	Integrations = "integrations"
)
View Source 
const (
	Me = "me"
)
View Source 
const (
	NetBlockDeviceCode = "43"
)
View Source 
const (
	NetMajorInterface = "eth0"
)
View Source 
const (
	OpenSearch = "opensearch"
)
View Source 
const (
	RadosGatewayPort = 8888
)
View Source 
const (
	RegionAuto = "auto"
)
View Source 
const (
	Services = "services"
)
View Source 
const (
	Settings = "settings"
)
View Source 
const (
	Triggers = "triggers"
)

Variables

View Source 
var (
	DefaultKeycloakRealm       = "master"
	DefaultIdpSamlMetadataPath = fmt.Sprintf("/auth/realms/%s/protocol/saml/descriptor", DefaultKeycloakRealm)
	DefaultSpSamlMetadataPath  = "/saml/metadata"
	DefaultApiServerKey        = "/var/www/certs/server.key"
	DefaultApiServerCert       = "/var/www/certs/server.cert"
	DefaultIdentifierFormat    = "urn:oasis:names:tc:SAML:2.0:nameid-format:persistent"

	DefaultAdminProject     = "admin"
	DefaultOidcClientId     = "cube-cos-api"
	DefaultOidcClientSecret = ""
	DefaultOidcClientOpts   = gocloak.Client{
		ClientID:                  gocloak.StringP(DefaultOidcClientId),
		Protocol:                  gocloak.StringP("openid-connect"),
		PublicClient:              gocloak.BoolP(false),
		ClientAuthenticatorType:   gocloak.StringP("client-secret"),
		StandardFlowEnabled:       gocloak.BoolP(true),
		DirectAccessGrantsEnabled: gocloak.BoolP(true),
		Attributes: &map[string]string{
			"access.token.lifespan": "7200",
		},
	}

	DefaultNodeToken    = ""
	RedirectUrl         = ""
	RedirectPath        = ""
	DefaultRedirectPath = "/home"
)
View Source 
var (
	HostID                   string
	Hostname                 string
	DataCenterName           string
	DataCenterVersion        string
	DataCenterNumericVersion string
	DataCenterVip            string
	ListenIp                 string
	ListenAddr               string
	ListenPort               int
	AdvertiseIp              string
	AdvertiseAddr            string
	AdvertisePort            int
	ManagementNet            string
	ManagementIp             string
	StorageNet               string
	StorageIP                string
	IsHaEnabled              bool
	IsGpuEnabled             bool
	NodeMetadata             map[string]string

	UpdateNodes = sync.Mutex{}
)
View Source 
var (
	CurrentRole string
	Roles       = []string{RoleControlConverged, RoleControl, RoleCompute, RoleStorage, RoleModerator, RoleEdgeCore}

	ControlRole          = newControlRole()
	ComputeRole          = newComputeRole()
	StorageRole          = newStorageRole()
	ControlConvergedRole = newControlConvergedRole()
	ModeratorRole        = newModeratorRole()
	EdgeCoreRole         = newEdgeCoreRole()

	AllRoles = []*Role{
		ControlRole,
		ComputeRole,
		StorageRole,
		ControlConvergedRole,
		ModeratorRole,
		EdgeCoreRole,
	}

	AllGeneralRoles = []*Role{
		ControlRole,
		ComputeRole,
		StorageRole,
		ControlConvergedRole,
	}

	ControlRoles = []*Role{
		ControlRole,
		ControlConvergedRole,
	}

	ComputeRoles = []*Role{
		ComputeRole,
		ControlConvergedRole,
		EdgeCoreRole,
	}
)
View Source 
var (
	Day                  = 24 * time.Hour
	LocalTimeZone        = "+00:00"
	LocalTimeZoneSeconds = 0
	LocalTimeFixedZone   = time.FixedZone("", LocalTimeZoneSeconds)
)
View Source 
var (
	CreateRecordIfNotExist = options.Update().SetUpsert(true)
)
View Source 
var (
	SerialNumber = ""
)
View Source 
var (
	ServiceDiscoveryIdentity = ""
)

Functions

func CapturePanic 

func CapturePanic()

func CheckTuningSpec 

func CheckTuningSpec(tuning Tuning) error

func GenNodeAuth 

func GenNodeAuth() map[string]string

func GenNodeToken 

func GenNodeToken(hostname string) string

func GenerateNodeHashByMacAddr 

func GenerateNodeHashByMacAddr() (string, error)

func GetActiveNodeMap 

func GetActiveNodeMap() map[string]Node

func GetCloudRoles 

func GetCloudRoles() []string

func GetDiscoveredServices 

func GetDiscoveredServices() ([]*registry.Service, error)

func GetEdgeRoles 

func GetEdgeRoles() []string

func GetEmailRecipients 

func GetEmailRecipients() ([]email.Recipient, error)

func GetLocalTunings 

func GetLocalTunings() *sync.Map

func GetMacAddr 

func GetMacAddr(interfaceName string) (string, error)

func GetRadosGatewayUrl 

func GetRadosGatewayUrl() string

func GetSlackChannels 

func GetSlackChannels() ([]slack.ApiChannel, error)

func GetSystemSerial 

func GetSystemSerial(file string) (string, error)

func GetTuningSpecs 

func GetTuningSpecs() *sync.Map

func HostnameNodeMap 

func HostnameNodeMap() (map[string]Node, error)

func IsCloudRole 

func IsCloudRole(role string) bool

func IsEdgeRole 

func IsEdgeRole(role string) bool

func IsLocalNode 

func IsLocalNode(hostname string) bool

func RepairCollection 

func RepairCollection() string

func SetLocalTuning 

func SetLocalTuning(tuning Tuning)

func SetNodeDetails 

func SetNodeDetails(nodesWithDetails []Node)

func SetTuningSpec 

func SetTuningSpec(name string, spec *TuningSpec)

func SettingsDB 

func SettingsDB() string

func ShouldIHandleTheTuning 

func ShouldIHandleTheTuning(name string) bool

func SyncRoleNodes 

func SyncRoleNodes()

func TimPastRFC3339 

func TimPastRFC3339(duration time.Duration) string

func TimeISO8601Z 

func TimeISO8601Z(t time.Time) string

func TimeLocal 

func TimeLocal() string

func TimeLocalISO8601 

func TimeLocalISO8601(t time.Time) string

func TimeLocalRFC3339 

func TimeLocalRFC3339(t time.Time) string

func TimeNowRFC3339 

func TimeNowRFC3339() string

func TimeNowRFC3339Z 

func TimeNowRFC3339Z() string

func TimePastRFC3339Z 

func TimePastRFC3339Z(duration time.Duration) string

func TimeRFC3339 

func TimeRFC3339(duration time.Duration) string

func TimeRFC3339Z 

func TimeRFC3339Z(t time.Time) string

func TimeUTC 

func TimeUTC(t time.Time) string

func TitlePrefixCollection 

func TitlePrefixCollection() string

func ToLowerInPlace 

func ToLowerInPlace(ss []string)

func TuningCollection 

func TuningCollection(name string) string

func TuningDB 

func TuningDB() string

func TuningReqCollection 

func TuningReqCollection() string

Types

type Additional 

type Additional struct {
	HelpUrl           string `json:"helpUrl,omitempty" bson:"helpUrl"`
	V1ApiDocUrl       string `json:"v1ApiDoc,omitempty" bson:"v1ApiDoc"`
	NodeLicenseStatus `json:"nodeLicenseStatus" bson:"nodeLicenseStatus"`
}

type BlockDevice 

type BlockDevice struct {
	Serial       string             `json:"serial"`
	Name         string             `json:"device" yaml:"device" bson:"device"`
	Type         string             `json:"type" yaml:"type" bson:"type"`
	SizeMiB      float64            `json:"sizeMiB" yaml:"sizeMiB" bson:"sizeMiB"`
	Availability string             `json:"availability" yaml:"availability" bson:"availability"`
	Status       status.BlockDevice `json:"status" yaml:"status" bson:"status"`
}

type BlockDeviceStatus 

type BlockDeviceStatus struct {
	State  string `json:"state" bson:"state"`
	Remark string `json:"remark" bson:"remark"`
}

type Dashboard 

type Dashboard struct {
	Link    string `json:"link"`
	Enabled bool   `json:"enabled"`
}

type DataCenter 

type DataCenter struct {
	Type        string   `json:"type" bson:"type"`
	Id          string   `json:"id,omitempty" bson:"id"`
	Name        string   `json:"name" bson:"name"`
	Roles       []string `json:"roles" bson:"roles"`
	Version     string   `json:"version" bson:"version"`
	VirtualIp   string   `json:"virtualIp" bson:"virtualIp"`
	IsLocal     bool     `json:"isLocal" bson:"isLocal"`
	IsHaEnabled bool     `json:"isHaEnabled" bson:"isHaEnabled"`
	UtcTimeZone string   `json:"utcTimeZone,omitempty" bson:"utcTimeZone"`
	Additional  `json:"additional" bson:"additional"`
}

type Error 

type Error struct {
	Type        string   `json:"type"`
	Reason      string   `json:"reason"`
	Nodes       []string `json:"nodes"`
	Description string   `json:"description"`
	Details     string   `json:"details"`
	Log         string   `json:"log"`
}

type Health 

type Health struct {
	Category string        `json:"category"`
	Service  string        `json:"service"`
	Status   status.Health `json:"status,omitempty" yaml:"status,omitempty" bson:"status,omitempty"`
	Modules  []Module      `json:"modules"`
}

type HealthCheck 

type HealthCheck struct {
	Time   string `json:"time"`
	Status string `json:"status"`
	*Error `json:"error,omitempty"`
}

func (*HealthCheck) IsNg 

func (h *HealthCheck) IsNg() bool

type Host 

type Host struct {
	Role string `json:"role,omitzero"`
	Name string `json:"name"`
	Ip   string `json:"ip,omitzero"`
}

func (*Host) GetNode 

func (h *Host) GetNode() *Node

type Integration 

type Integration struct {
	Name                    string `json:"name"`
	IsHeaderShortcutEnabled bool   `json:"isHeaderShortcutEnabled"`
	Description             string `json:"description"`
	IsBuiltIn               bool   `json:"isBuiltIn"`
	Url                     string `json:"url"`
}

type Label 

type Label struct {
	Key   string `json:"key" yaml:"key"`
	Value string `json:"value" yaml:"value"`
}

type Limit 

type Limit struct {
	Number      int    `json:"number"`
	Description string `json:"description"`
}

type ListTuningOptions 

type ListTuningOptions struct {
	AllNodes bool
}

type Module 

type Module struct {
	Name         string         `json:"name" bson:"name"`
	Status       *status.Health `json:"status,omitempty" bson:"status,omitempty"`
	IsRepairable bool           `json:"-" bson:"isRepairable"`
	Description  string         `json:"description,omitempty" bson:"description"`
}

func (*Module) InitOkStatus 

func (m *Module) InitOkStatus()

func (*Module) SetRepairingStatus 

func (m *Module) SetRepairingStatus()

func (*Module) SetUnhealthyStatus 

func (m *Module) SetUnhealthyStatus()

type NetworkInterface 

type NetworkInterface struct {
	Label       string `json:"label" yaml:"label" bson:"label"`
	BusIdSlaves string `json:"busIdSlaves" yaml:"busIdSlaves" bson:"busIdSlaves"`
	Driver      string `json:"driver" yaml:"driver" bson:"driver"`
	State       string `json:"state" yaml:"state" bson:"state"`
	Speed       string `json:"speed" yaml:"speed" bson:"speed"`
}

type Node 

type Node struct {
	Id                string             `json:"id" yaml:"id"`
	SerialNumber      string             `json:"serialNumber" yaml:"serialNumber"`
	DataCenter        string             `json:"dataCenter" yaml:"dataCenter"`
	Hostname          string             `json:"hostname" yaml:"hostname"`
	Role              string             `json:"role" yaml:"role"`
	Protocol          string             `json:"protocol,omitempty" yaml:"protocol,omitempty" bson:"protocol,omitempty"`
	Address           string             `json:"address" yaml:"address"`
	Ip                string             `json:"ip" yaml:"ip"`
	ManagementIP      string             `json:"managementIP" yaml:"managementIP"`
	StorageIP         string             `json:"storageIP" yaml:"storageIP"`
	License           license.Options    `json:"license" yaml:"license,omitempty" bson:"license,omitempty"`
	Status            string             `json:"status" yaml:"status"`
	CpuSpec           string             `json:"cpuSpec" yaml:"cpuSpec" bson:"cpuSpec"`
	NetworkInterfaces []NetworkInterface `json:"networkInterfaces" yaml:"networkInterfaces" bson:"networkInterfaces"`
	BlockDevices      []BlockDevice      `json:"blockDevices" yaml:"blockDevices" bson:"blockDevices"`
	Vcpu              metric.Compute     `json:"vcpu" yaml:"vcpu" bson:"vcpu"`
	Memory            metric.Space       `json:"memory" yaml:"memory" bson:"memory"`
	Storage           metric.Space       `json:"storage" yaml:"storage" bson:"storage"`
	UptimeSeconds     float64            `json:"uptimeSeconds" yaml:"uptimeSeconds" bson:"uptimeSeconds"`
	Labels            map[string]string  `json:"labels,omitempty" yaml:"labels,omitempty" bson:"labels,omitempty"`
}

func GetControlNodes 

func GetControlNodes() ([]Node, error)

func GetNodeByHostname 

func GetNodeByHostname(hostname string) (*Node, error)

func GetNodesByRole 

func GetNodesByRole(roleName string) ([]Node, error)

func GetNodesFromRoles 

func GetNodesFromRoles() []Node

func GetOneOfControllerNode 

func GetOneOfControllerNode() (*Node, error)

func GetPeerControlNodes 

func GetPeerControlNodes() ([]Node, error)

func ListNodes 

func ListNodes() []Node

func (*Node) CreateSupportFileUrl 

func (n *Node) CreateSupportFileUrl(file support.File) string

func (*Node) DeleteModuleRepairingTaskUrl 

func (n *Node) DeleteModuleRepairingTaskUrl(module string) string

func (*Node) DeleteRepairingTaskUrl 

func (n *Node) DeleteRepairingTaskUrl() string

func (*Node) DownloadSupportFileUrl 

func (n *Node) DownloadSupportFileUrl(setname, filename string) string

func (*Node) GenUrl 

func (n *Node) GenUrl() string

func (*Node) GetMetricUrl 

func (n *Node) GetMetricUrl(metric, view string) string

func (*Node) GetNodeUrl 

func (n *Node) GetNodeUrl() string

func (*Node) GetSettingUrl 

func (n *Node) GetSettingUrl(path string) string

func (*Node) GetSupportFileUrl 

func (n *Node) GetSupportFileUrl() string

func (*Node) GetTuningUrl 

func (n *Node) GetTuningUrl() string

func (*Node) IsDown 

func (n *Node) IsDown() bool

func (*Node) IsLicenseExpired 

func (n *Node) IsLicenseExpired() bool

func (*Node) IsLocal 

func (n *Node) IsLocal() bool

func (*Node) IsUnlicensed 

func (n *Node) IsUnlicensed() bool

func (*Node) MatchHardwareSerial 

func (n *Node) MatchHardwareSerial(hardwareSerials []string) bool

func (*Node) PatchSettingTaskUrl 

func (n *Node) PatchSettingTaskUrl(setting setting.Options) string

func (*Node) PatchSupportFileTaskUrl 

func (n *Node) PatchSupportFileTaskUrl(file support.File) string

func (*Node) PatchTriggerTaskUrl 

func (n *Node) PatchTriggerTaskUrl(trigger trigger.ApiOptions) string

func (*Node) PatchTuningTaskUrl 

func (n *Node) PatchTuningTaskUrl(tuning Tuning) string

func (*Node) PatchTuningUrl 

func (n *Node) PatchTuningUrl(tuning Tuning) string

type NodeLicenseStatus 

type NodeLicenseStatus struct {
	Valid     int `json:"valid" bson:"valid"`
	Expired   int `json:"expired" bson:"expired"`
	Unlicense int `json:"unlicense" bson:"unlicense"`
}

type Page 

type Page struct {
	Total          int64 `json:"total"`
	Number         int   `json:"number"`
	Size           int   `json:"size"`
	TotalItemCount int64 `json:"totalItemCount"`
}

func (Page) IsRequired 

func (p Page) IsRequired() bool

type Period 

type Period struct {
	Start string
	Stop  string
	Past  string
}

func (*Period) InBetween 

func (p *Period) InBetween(timeAt string) bool

type RawBlockDevice 

type RawBlockDevice struct {
	Type        string   `json:"type"`
	Serial      string   `json:"serial"`
	Name        string   `json:"name"`
	Size        string   `json:"size"`
	Rota        bool     `json:"rota"`
	MountPoints []string `json:"mountpoints"`
}

func (*RawBlockDevice) IsBlock 

func (r *RawBlockDevice) IsBlock() bool

func (*RawBlockDevice) IsPartition 

func (r *RawBlockDevice) IsPartition() bool

func (*RawBlockDevice) NoMountPoints 

func (r *RawBlockDevice) NoMountPoints() bool

type RawNetworkInterface 

type RawNetworkInterface struct {
	Label       string `json:"label" yaml:"label" bson:"label"`
	BusIdSlaves string `json:"busid" yaml:"busid" bson:"busid"`
	Driver      string `json:"driver" yaml:"driver" bson:"driver"`
	State       string `json:"state" yaml:"state" bson:"state"`
	Speed       string `json:"speed" yaml:"speed" bson:"speed"`
}

type RawTuningLimitation 

type RawTuningLimitation struct {
	Type    string `json:"type"`
	Default string `json:"default"`
	Min     string `json:"min,omitempty"`
	Max     string `json:"max,omitempty"`
	Regex   string `json:"regex,omitempty"`
}

type RawTuningSpec 

type RawTuningSpec struct {
	Name        string              `json:"name"`
	Description string              `json:"description"`
	Limitation  RawTuningLimitation `json:"limitation"`
}

type ReairingInfo 

type ReairingInfo struct {
	Node    string `json:"node"`
	Fixing  string `json:"fixing"`
	Service string `json:"service"`
	Pid     string `json:"pid"`
	Elaps   string `json:"elaps"`
}

type Role 

type Role struct {
	Name  string `json:"name" bson:"name"`
	Hosts []Host `json:"hosts" bson:"hosts"`
	Nodes []Node `json:"-"`
}

func GetComputeRole 

func GetComputeRole() *Role

func GetControlConvergeRole 

func GetControlConvergeRole() *Role

func GetControlRole 

func GetControlRole() *Role

func GetControlRoles 

func GetControlRoles() []*Role

func GetEdgeCoreRole 

func GetEdgeCoreRole() *Role

func GetModeratorRole 

func GetModeratorRole() *Role

func GetRole 

func GetRole(name string) *Role

func GetRolesToHandleTuning 

func GetRolesToHandleTuning(tuningName string) ([]*Role, bool)

func GetStorageRole 

func GetStorageRole() *Role

func (*Role) IsNodeEmpty 

func (r *Role) IsNodeEmpty() bool

type Selector 

type Selector struct {
	Enabled bool              `json:"enabled" yaml:"enabled"`
	Labels  map[string]string `json:"labels" yaml:"labels"`
}

type Service 

type Service struct {
	Name               string         `json:"name" bson:"name"`
	Category           string         `json:"category" bson:"category"`
	Status             *status.Health `json:"status,omitempty" bson:"status,omitempty"`
	Modules            []Module       `json:"modules" bson:"modules"`
	IsInternalViewOnly bool           `json:"-" bson:"isInternalViewOnly"`
}

func (*Service) ConvergeUnhealthyStatus 

func (s *Service) ConvergeUnhealthyStatus(moduleName string)

func (*Service) CopyModuleEmptyStruct 

func (s *Service) CopyModuleEmptyStruct() Service

func (*Service) InitOkStatus 

func (s *Service) InitOkStatus()

func (*Service) IsStatusOk 

func (s *Service) IsStatusOk() bool

func (*Service) SetRepairingStatus 

func (s *Service) SetRepairingStatus(repairingInfo ReairingInfo)

type Setting 

type Setting struct {
	TitlePrefix string        `json:"titlePrefix" bson:"titlePrefix"`
	Email       email.Options `json:"email" bson:"email"`
	Slack       slack.Options `json:"slack" bson:"slack"`
}

type TitlePrefix 

type TitlePrefix struct {
	Value string `json:"value" bson:"value"`
}

type Tuning 

type Tuning struct {
	Id          string           `json:"id,omitempty" yaml:"-" bson:"id"`
	Name        string           `json:"name" yaml:"name" bson:"name"`
	Value       any              `json:"value" yaml:"value" bson:"value"`
	Description string           `json:"description" yaml:"-" bson:"-"`
	Enabled     bool             `json:"enabled" yaml:"enabled" bson:"enabled"`
	IsModified  bool             `json:"isModified" yaml:"-" bson:"-"`
	Limitation  TuningLimitation `json:"limitation" yaml:"-" bson:"-"`

	*Node  `json:"node,omitempty" yaml:"-" bson:"-"`
	Hosts  []Host         `json:"hosts" yaml:"-" bson:"-"`
	Roles  []Role         `json:"roles,omitempty" yaml:"-" bson:"-"`
	Status *status.Tuning `json:"status,omitempty" yaml:"-" bson:"status,omitempty"`
}

func GetLocalTuning 

func GetLocalTuning(name string) Tuning

func ListLocalTunings 

func ListLocalTunings() []Tuning

func (*Tuning) Bytes 

func (t *Tuning) Bytes() ([]byte, error)

func (*Tuning) CopyAndOverrideHost 

func (t *Tuning) CopyAndOverrideHost(node Node) Tuning

func (*Tuning) GenTaskUpdate 

func (t *Tuning) GenTaskUpdate() Tuning

func (*Tuning) GenerateId 

func (t *Tuning) GenerateId() string

func (*Tuning) IncludeHost 

func (t *Tuning) IncludeHost(hostname string) bool

func (*Tuning) IncludeHosts 

func (t *Tuning) IncludeHosts(hosts []string) bool

func (*Tuning) InitHosts 

func (t *Tuning) InitHosts(hosts []string)

func (*Tuning) InitOkStatus 

func (t *Tuning) InitOkStatus()

func (*Tuning) InitResetStatus 

func (t *Tuning) InitResetStatus()

func (*Tuning) InitStatus 

func (t *Tuning) InitStatus(current, desired string)

func (*Tuning) InitUpdateStatus 

func (t *Tuning) InitUpdateStatus()

func (*Tuning) JoinHosts 

func (t *Tuning) JoinHosts() string

func (*Tuning) SearchKey 

func (t *Tuning) SearchKey() string

func (*Tuning) SetCompleted 

func (t *Tuning) SetCompleted()

func (*Tuning) SetDesired 

func (t *Tuning) SetDesired(status string)

func (*Tuning) SetError 

func (t *Tuning) SetError()

func (*Tuning) SetNodeInfo 

func (t *Tuning) SetNodeInfo(role, address string)

func (*Tuning) SetUpdated 

func (t *Tuning) SetUpdated()

func (*Tuning) SetUpdating 

func (t *Tuning) SetUpdating()

func (*Tuning) StrValue 

func (t *Tuning) StrValue() string

type TuningLimitation 

type TuningLimitation struct {
	Type    string `json:"type"`
	Default any    `json:"default"`
	Min     *int   `json:"min,omitempty"`
	Max     *int   `json:"max,omitempty"`
	Regex   string `json:"regex,omitempty"`
}

type TuningPolicy 

type TuningPolicy struct {
	Name    string   `json:"name" yaml:"name"`
	Version string   `json:"version" yaml:"version"`
	Enabled bool     `json:"enabled" yaml:"enabled"`
	Tunings []Tuning `json:"tunings" yaml:"tunings"`
}

func (*TuningPolicy) AppendTuning 

func (t *TuningPolicy) AppendTuning(tuning Tuning)

func (*TuningPolicy) AppendTunings 

func (t *TuningPolicy) AppendTunings(tunings []Tuning)

func (*TuningPolicy) DeleteTuning 

func (t *TuningPolicy) DeleteTuning(name string)

func (*TuningPolicy) HasMatchedTuning 

func (t *TuningPolicy) HasMatchedTuning(tuning Tuning) bool

func (*TuningPolicy) UpdateOrAppendTuning 

func (t *TuningPolicy) UpdateOrAppendTuning(tuning Tuning)

type TuningReset 

type TuningReset struct {
	Hosts []string `json:"hosts"`
}

type TuningSpec 

type TuningSpec struct {
	Name        string           `json:"name"`
	Description string           `json:"description"`
	Limitation  TuningLimitation `json:"limitation"`
	Roles       []*Role          `json:"roles"`
	Selector    `json:"-"`
}

func GetTuningSpec 

func GetTuningSpec(name string) (*TuningSpec, error)

func ListTuningSpecs 

func ListTuningSpecs() []TuningSpec

func (*TuningSpec) IsInLimitedRange 

func (t *TuningSpec) IsInLimitedRange(value int) bool

type TuningToggle 

type TuningToggle struct {
	Enable bool     `json:"enable"`
	Hosts  []string `json:"hosts"`
}

type TuningUpdate 

type TuningUpdate struct {
	Value   any      `json:"value"`
	Enabled bool     `json:"enabled"`
	Hosts   []string `json:"hosts"`
}

type User 

type User struct {
	Name     string `json:"name"`
	Password string `json:"password"`
}

func (User) IsNameEmpty 

func (u User) IsNameEmpty() bool

func (User) IsPasswordEmpty 

func (u User) IsPasswordEmpty() bool

Source Files

View all Source files

Directories

Path Synopsis

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.