Documentation
¶
Index ¶
- Constants
- type Node
- type PluginTask
- type PluginTaskPlatform
- type PluginTaskPlugin
- type PluginTaskStatus
- type Registry
- func (r *Registry) Add(ip string, connectedAt time.Time)
- func (r *Registry) AddWithNodeID(ip string, nodeID string, connectedAt time.Time)
- func (r *Registry) List() []Node
- func (r *Registry) Remove(ip string)
- func (r *Registry) RemoveWithNodeID(ip string, nodeID string)
- func (r *Registry) TotalCount() int
Constants ¶
View Source
const ( PluginStatusNodeTypeCPA = "cpa" PluginStatusNodeTypeHome = "home" PluginTaskOperationDelete = "delete" PluginTaskTargetAll = "all" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PluginTask ¶ added in v1.0.44
type PluginTask struct {
ID uint `json:"id"`
Operation string `json:"operation"`
PluginID string `json:"plugin_id"`
TargetNodeType string `json:"target_node_type,omitempty"`
TargetNodeID string `json:"target_node_id,omitempty"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type PluginTaskPlatform ¶ added in v1.0.44
type PluginTaskPlugin ¶ added in v1.0.44
type PluginTaskPlugin struct {
ID string `json:"id"`
Version string `json:"version,omitempty"`
ReleaseTag string `json:"release_tag,omitempty"`
Repository string `json:"repository,omitempty"`
InstallStatus string `json:"install_status"`
LoadStatus string `json:"load_status,omitempty"`
Path string `json:"path,omitempty"`
Skipped bool `json:"skipped,omitempty"`
Overwritten bool `json:"overwritten,omitempty"`
Error string `json:"error,omitempty"`
}
type PluginTaskStatus ¶ added in v1.0.44
type PluginTaskStatus struct {
SchemaVersion int `json:"schema_version"`
TaskID uint `json:"task_id,omitempty"`
NodeType string `json:"node_type,omitempty"`
Task string `json:"task"`
NodeID string `json:"node_id"`
ClientIP string `json:"client_ip,omitempty"`
Status string `json:"status"`
Phase string `json:"phase"`
OK bool `json:"ok"`
StartedAt time.Time `json:"started_at"`
FinishedAt time.Time `json:"finished_at,omitempty"`
UpdatedAt time.Time `json:"updated_at"`
Platform PluginTaskPlatform `json:"platform"`
Plugins []PluginTaskPlugin `json:"plugins"`
Error string `json:"error,omitempty"`
}
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
func GlobalRegistry ¶
func GlobalRegistry() *Registry
GlobalRegistry returns the shared node registry.
func (*Registry) AddWithNodeID ¶ added in v1.0.44
AddWithNodeID adds the value with an optional node id.
func (*Registry) RemoveWithNodeID ¶ added in v1.0.44
RemoveWithNodeID removes the value with an optional node id.
func (*Registry) TotalCount ¶
TotalCount returns the current number of active client connections.
Click to show internal directories.
Click to hide internal directories.