commoncmd

package
v3.0.0-beta10 Latest Latest
Warning

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

 Go to latest Published: Dec 12, 2025 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Overview

Package commoncmd provides utilities and shared functionality to facilitate operations related to managing remotes objects, nodes, and logs for omcmd and oxcmd.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrClientRequest = errors.New("client request")

	ErrClientStatusCode = errors.New("client request unexpected status code")

	ErrEventKindUnexpected = errors.New("unexpected event kind")

	ErrFetchFile = errors.New("fetch file")

	ErrFlagInvalid = errors.New("invalid command flag")

	ErrInstallFile = errors.New("install file")

	ErrPrint = errors.New("print")
)
View Source 
var (
	GroupIDOrchestratedActions = "orchestrated actions"
	GroupIDQuery               = "query"
	GroupIDSubsystems          = "subsystems"
)
View Source 
var (
	ErrCmdDaemonAuth = errors.New("command daemon auth")
)

Functions

func APIKeywordItemsToRaw 

func APIKeywordItemsToRaw(items api.KeywordItems) rawconfig.T

func AnySingleNode 

func AnySingleNode(selector string, c *client.T) (string, error)

func ColorizeINI 

func ColorizeINI(b []byte) []byte

func DataFromConfigFile 

func DataFromConfigFile(fpath string) ([]byte, error)

func DataFromConfigURI 

func DataFromConfigURI(u uri.T) ([]byte, error)

func DataFromStdin 

func DataFromStdin() ([]byte, error)

func DataFromTemplate 

func DataFromTemplate(template string) ([]byte, error)

func DeprecatedFlagDownTo 

func DeprecatedFlagDownTo(flags *pflag.FlagSet, p *string)

func DeprecatedFlagSubsets 

func DeprecatedFlagSubsets(flags *pflag.FlagSet, p *string)

func DeprecatedFlagTags 

func DeprecatedFlagTags(flags *pflag.FlagSet, p *string)

func DeprecatedFlagUpTo 

func DeprecatedFlagUpTo(flags *pflag.FlagSet, p *string)

func Doc 

func Doc(w io.Writer, items api.KeywordDefinitionItems, kind naming.Kind, driver, kw string, depth int) error

func FlagCPUProfile 

func FlagCPUProfile(flags *pflag.FlagSet, p *string)

func FlagCollectorApp 

func FlagCollectorApp(flags *pflag.FlagSet, p *string)

func FlagCollectorPassword 

func FlagCollectorPassword(flags *pflag.FlagSet, p *string)

func FlagCollectorUser 

func FlagCollectorUser(flags *pflag.FlagSet, p *string)

func FlagColor 

func FlagColor(flags *pflag.FlagSet, p *string)

func FlagComplianceAttach 

func FlagComplianceAttach(flags *pflag.FlagSet, p *bool)

func FlagComplianceForce 

func FlagComplianceForce(flags *pflag.FlagSet, p *bool)

func FlagConfirm 

func FlagConfirm(flags *pflag.FlagSet, p *bool)

func FlagCreateConfig 

func FlagCreateConfig(flags *pflag.FlagSet, p *string)

func FlagCreateEnv 

func FlagCreateEnv(flags *pflag.FlagSet, p *[]string)

func FlagCreateForce 

func FlagCreateForce(flags *pflag.FlagSet, p *bool)

func FlagCreateNamespace 

func FlagCreateNamespace(flags *pflag.FlagSet, p *string)

func FlagCreateRestore 

func FlagCreateRestore(flags *pflag.FlagSet, p *bool)

func FlagCron 

func FlagCron(flags *pflag.FlagSet, p *bool)

func FlagDaemonHeartbeatFilter 

func FlagDaemonHeartbeatFilter(flags *pflag.FlagSet, p *string)

func FlagDaemonHeartbeatName 

func FlagDaemonHeartbeatName(flags *pflag.FlagSet, p *string)

func FlagDaemonListenerName 

func FlagDaemonListenerName(flags *pflag.FlagSet, p *string)

func FlagDaemonLogLevel 

func FlagDaemonLogLevel(flags *pflag.FlagSet, p *string)

func FlagDepth 

func FlagDepth(flags *pflag.FlagSet, p *int)

func FlagDevRoles 

func FlagDevRoles(flags *pflag.FlagSet, p *string)

func FlagDisableRollback 

func FlagDisableRollback(flags *pflag.FlagSet, p *bool)

func FlagDiscard 

func FlagDiscard(flags *pflag.FlagSet, p *bool)

func FlagDriver 

func FlagDriver(flags *pflag.FlagSet, p *string)

func FlagDryRun 

func FlagDryRun(flags *pflag.FlagSet, p *bool)

func FlagDuration 

func FlagDuration(flags *pflag.FlagSet, p *time.Duration)

func FlagEnv 

func FlagEnv(flags *pflag.FlagSet, p *[]string)

func FlagEval 

func FlagEval(flags *pflag.FlagSet, p *bool)

func FlagEventFilters 

func FlagEventFilters(flags *pflag.FlagSet, p *[]string)

func FlagEventLimit 

func FlagEventLimit(flags *pflag.FlagSet, p *uint64)

func FlagEventOutput 

func FlagEventOutput(flags *pflag.FlagSet, p *string)

func FlagEventTemplate 

func FlagEventTemplate(flags *pflag.FlagSet, p *string)

func FlagForce 

func FlagForce(flags *pflag.FlagSet, p *bool)

func FlagFrom 

func FlagFrom(flags *pflag.FlagSet, p *string)

func FlagImpersonate 

func FlagImpersonate(flags *pflag.FlagSet, p *string)

func FlagKey 

func FlagKey(flags *pflag.FlagSet, p *string)

func FlagKeyName 

func FlagKeyName(flags *pflag.FlagSet, p *string)

func FlagKeyTo 

func FlagKeyTo(flags *pflag.FlagSet, p *string)

func FlagKeyValue 

func FlagKeyValue(flags *pflag.FlagSet, p *string)

func FlagKeyword 

func FlagKeyword(flags *pflag.FlagSet, p *string)

func FlagKeywordOps 

func FlagKeywordOps(flags *pflag.FlagSet, p *[]string)

func FlagKeywords 

func FlagKeywords(flags *pflag.FlagSet, p *[]string)

func FlagLeader 

func FlagLeader(flags *pflag.FlagSet, p *bool)

func FlagLive 

func FlagLive(flags *pflag.FlagSet, p *bool)

func FlagLocal 

func FlagLocal(flags *pflag.FlagSet, p *bool)

func FlagMaster 

func FlagMaster(flags *pflag.FlagSet, p *bool)

func FlagMatch 

func FlagMatch(flags *pflag.FlagSet, p *string)

func FlagModule 

func FlagModule(flags *pflag.FlagSet, p *string)

func FlagModuleset 

func FlagModuleset(flags *pflag.FlagSet, p *string)

func FlagMoveTo 

func FlagMoveTo(flags *pflag.FlagSet, p *string)

func FlagNetworkStatusExtended 

func FlagNetworkStatusExtended(flags *pflag.FlagSet, p *bool)

func FlagNetworkStatusName 

func FlagNetworkStatusName(flags *pflag.FlagSet, p *string)

func FlagNoLock 

func FlagNoLock(flags *pflag.FlagSet, p *bool)

func FlagNodeSelector 

func FlagNodeSelector(flags *pflag.FlagSet, p *string)

func FlagNodeSelectorFilter 

func FlagNodeSelectorFilter(flags *pflag.FlagSet, p *string)

func FlagNodeSelectorOrAll 

func FlagNodeSelectorOrAll(flags *pflag.FlagSet, p *string)

func FlagNodeSelectorOrLocalhost 

func FlagNodeSelectorOrLocalhost(flags *pflag.FlagSet, p *string)

func FlagObjectSelector 

func FlagObjectSelector(flags *pflag.FlagSet, p *string)

func FlagOutput 

func FlagOutput(flags *pflag.FlagSet, p *string)

func FlagOutputSections 

func FlagOutputSections(flags *pflag.FlagSet, p *string)

func FlagPeerSelectorFilter 

func FlagPeerSelectorFilter(flags *pflag.FlagSet, p *string)

func FlagPoolName 

func FlagPoolName(flags *pflag.FlagSet, p *string)

func FlagPoolStatusExtended 

func FlagPoolStatusExtended(flags *pflag.FlagSet, p *bool)

func FlagProvision 

func FlagProvision(flags *pflag.FlagSet, p *bool)

func FlagRID 

func FlagRID(flags *pflag.FlagSet, p *string)

func FlagRecover 

func FlagRecover(flags *pflag.FlagSet, p *bool)

func FlagRefresh 

func FlagRefresh(flags *pflag.FlagSet, p *bool)

func FlagRelay 

func FlagRelay(flags *pflag.FlagSet, p *string)

func FlagRoles 

func FlagRoles(flags *pflag.FlagSet, p *[]string)

func FlagRuleset 

func FlagRuleset(flags *pflag.FlagSet, p *string)

func FlagSections 

func FlagSections(flags *pflag.FlagSet, p *[]string)

func FlagSlave 

func FlagSlave(flags *pflag.FlagSet, p *[]string)

func FlagSlaves 

func FlagSlaves(flags *pflag.FlagSet, p *bool)

func FlagStateOnly 

func FlagStateOnly(flags *pflag.FlagSet, p *bool)

func FlagSubset 

func FlagSubset(flags *pflag.FlagSet, p *string)

func FlagSwitchTo 

func FlagSwitchTo(flags *pflag.FlagSet, p *string)

func FlagTag 

func FlagTag(flags *pflag.FlagSet, p *string)

func FlagTarget 

func FlagTarget(flags *pflag.FlagSet, p *[]string)

func FlagTime 

func FlagTime(flags *pflag.FlagSet, p *time.Duration)

func FlagTo 

func FlagTo(flags *pflag.FlagSet, p *string)

func FlagUpdateDelete 

func FlagUpdateDelete(flags *pflag.FlagSet, p *[]string)

func FlagUpdateSet 

func FlagUpdateSet(flags *pflag.FlagSet, p *[]string)

func FlagUpdateUnset 

func FlagUpdateUnset(flags *pflag.FlagSet, p *[]string)

func FlagWait 

func FlagWait(flags *pflag.FlagSet, p *bool)

func FlagWaitLock 

func FlagWaitLock(flags *pflag.FlagSet, p *time.Duration)

func FlagWatch 

func FlagWatch(flags *pflag.FlagSet, p *bool)

func FlagsAsync 

func FlagsAsync(flags *pflag.FlagSet, p *OptsAsync)

func FlagsEncap 

func FlagsEncap(flags *pflag.FlagSet, p *OptsEncap)

func FlagsLock 

func FlagsLock(flags *pflag.FlagSet, p *OptsLock)

func FlagsLogs 

func FlagsLogs(flags *pflag.FlagSet, p *OptsLogs)

func FlagsResourceSelector 

func FlagsResourceSelector(flags *pflag.FlagSet, p *OptsResourceSelector)

func FlagsTo 

func FlagsTo(flags *pflag.FlagSet, p *OptTo)

func HiddenFlagDisableRollback 

func HiddenFlagDisableRollback(flags *pflag.FlagSet, p *bool)

func HiddenFlagForce 

func HiddenFlagForce(flags *pflag.FlagSet, p *bool)

func HiddenFlagLeader 

func HiddenFlagLeader(flags *pflag.FlagSet, p *bool)

func HiddenFlagMaster 

func HiddenFlagMaster(flags *pflag.FlagSet, p *bool)

func HiddenFlagNoLock 

func HiddenFlagNoLock(flags *pflag.FlagSet, p *bool)

func HiddenFlagNodeSelector 

func HiddenFlagNodeSelector(flags *pflag.FlagSet, p *string)

func HiddenFlagObjectSelector 

func HiddenFlagObjectSelector(flags *pflag.FlagSet, p *string)

func HiddenFlagRID 

func HiddenFlagRID(flags *pflag.FlagSet, p *string)

func HiddenFlagSlave 

func HiddenFlagSlave(flags *pflag.FlagSet, p *[]string)

func HiddenFlagSlaves 

func HiddenFlagSlaves(flags *pflag.FlagSet, p *bool)

func HiddenFlagSubset 

func HiddenFlagSubset(flags *pflag.FlagSet, p *string)

func HiddenFlagTag 

func HiddenFlagTag(flags *pflag.FlagSet, p *string)

func HiddenFlagTo 

func HiddenFlagTo(flags *pflag.FlagSet, p *string)

func HiddenFlagWaitLock 

func HiddenFlagWaitLock(flags *pflag.FlagSet, p *time.Duration)

func HiddenFlagsEncap 

func HiddenFlagsEncap(flags *pflag.FlagSet, p *OptsEncap)

func HiddenFlagsLock 

func HiddenFlagsLock(flags *pflag.FlagSet, p *OptsLock)

func HiddenFlagsResourceSelector 

func HiddenFlagsResourceSelector(flags *pflag.FlagSet, p *OptsResourceSelector)

func HiddenFlagsTo 

func HiddenFlagsTo(flags *pflag.FlagSet, p *OptTo)

func InstanceStatusUpdatedWaiter 

func InstanceStatusUpdatedWaiter(ctx context.Context, paths naming.Paths) (func(), error)

func KeywordStoreFromAPI 

func KeywordStoreFromAPI(items api.KeywordDefinitionItems) (store keywords.Store)

func MergeSelector 

func MergeSelector(selector string, subsysSelector string, kind string, defaultSelector string) string

func NewCmdAnyConfigUpdate 

func NewCmdAnyConfigUpdate() *cobra.Command

func NewCmdClusterAbort 

func NewCmdClusterAbort() *cobra.Command

func NewCmdClusterFreeze 

func NewCmdClusterFreeze() *cobra.Command

func NewCmdClusterLogs 

func NewCmdClusterLogs() *cobra.Command

func NewCmdClusterSSHTrust 

func NewCmdClusterSSHTrust() *cobra.Command

func NewCmdClusterStatus 

func NewCmdClusterStatus() *cobra.Command

func NewCmdClusterThaw 

func NewCmdClusterThaw() *cobra.Command

func NewCmdClusterUnfreeze 

func NewCmdClusterUnfreeze() *cobra.Command

func NewCmdDaemon 

func NewCmdDaemon() *cobra.Command

func NewCmdDaemonAuth 

func NewCmdDaemonAuth() *cobra.Command

func NewCmdDaemonDNS 

func NewCmdDaemonDNS() *cobra.Command

func NewCmdDaemonDNSDump 

func NewCmdDaemonDNSDump() *cobra.Command

func NewCmdDaemonHeartbeat 

func NewCmdDaemonHeartbeat() *cobra.Command

func NewCmdDaemonHeartbeatRestart 

func NewCmdDaemonHeartbeatRestart() *cobra.Command

func NewCmdDaemonHeartbeatRotate 

func NewCmdDaemonHeartbeatRotate() *cobra.Command

func NewCmdDaemonHeartbeatStart 

func NewCmdDaemonHeartbeatStart() *cobra.Command

func NewCmdDaemonHeartbeatStatus 

func NewCmdDaemonHeartbeatStatus(defaultNodeSelectorFilter string) *cobra.Command

func NewCmdDaemonHeartbeatStop 

func NewCmdDaemonHeartbeatStop() *cobra.Command

func NewCmdDaemonListener 

func NewCmdDaemonListener() *cobra.Command

func NewCmdDaemonListenerLog 

func NewCmdDaemonListenerLog() *cobra.Command

func NewCmdDaemonListenerRestart 

func NewCmdDaemonListenerRestart() *cobra.Command

func NewCmdDaemonListenerStart 

func NewCmdDaemonListenerStart() *cobra.Command

func NewCmdDaemonListenerStop 

func NewCmdDaemonListenerStop() *cobra.Command

func NewCmdDaemonLog 

func NewCmdDaemonLog() *cobra.Command

func NewCmdDaemonRelay 

func NewCmdDaemonRelay() *cobra.Command

func NewCmdDaemonRelayStatus 

func NewCmdDaemonRelayStatus() *cobra.Command

func NewCmdDaemonStatus 

func NewCmdDaemonStatus() *cobra.Command

func NewCmdHeartbeatSign 

func NewCmdHeartbeatSign() *cobra.Command

func NewCmdHeartbeatWipe 

func NewCmdHeartbeatWipe() *cobra.Command

func NewCmdMonitor 

func NewCmdMonitor() *cobra.Command

func NewCmdNode 

func NewCmdNode() *cobra.Command

func NewCmdNodeConfigDoc 

func NewCmdNodeConfigDoc() *cobra.Command

func NewCmdObjectClear 

func NewCmdObjectClear(kind string) *cobra.Command

func NewCmdObjectCollector 

func NewCmdObjectCollector(kind string) *cobra.Command

func NewCmdObjectCompliance 

func NewCmdObjectCompliance(kind string) *cobra.Command

func NewCmdObjectConfig 

func NewCmdObjectConfig(kind string) *cobra.Command

func NewCmdObjectConfigDoc 

func NewCmdObjectConfigDoc(kind string) *cobra.Command

func NewCmdObjectInstance 

func NewCmdObjectInstance(kind string) *cobra.Command

func NewCmdObjectInstanceClear 

func NewCmdObjectInstanceClear(kind, defaultNodeSelector string) *cobra.Command

func NewCmdObjectInstanceDevice 

func NewCmdObjectInstanceDevice(kind string) *cobra.Command

func NewCmdObjectInstanceResource 

func NewCmdObjectInstanceResource(kind string) *cobra.Command

func NewCmdObjectInstanceResourceInfo 

func NewCmdObjectInstanceResourceInfo(kind string) *cobra.Command

func NewCmdObjectInstanceSync 

func NewCmdObjectInstanceSync(kind string) *cobra.Command

func NewCmdObjectKey 

func NewCmdObjectKey(kind string) *cobra.Command

func NewCmdObjectMonitor 

func NewCmdObjectMonitor(selector, kind string) *cobra.Command

func NewCmdObjectResource 

func NewCmdObjectResource(kind string) *cobra.Command

func NewCmdObjectSSH 

func NewCmdObjectSSH(kind string) *cobra.Command

func NewCmdObjectSchedule 

func NewCmdObjectSchedule(kind string) *cobra.Command

func NewCmdObjectSync 

func NewCmdObjectSync(kind string) *cobra.Command

func NewGroupOrchestratedActions 

func NewGroupOrchestratedActions() *cobra.Group

func NewGroupQuery 

func NewGroupQuery() *cobra.Group

func NewGroupSubsystems 

func NewGroupSubsystems() *cobra.Group

func NodesFromPaths 

func NodesFromPaths(c *client.T, selector string) ([]string, error)

func ObjectInstanceDeleteRemoteFunc 

func ObjectInstanceDeleteRemoteFunc(ctx context.Context, p naming.Path, nodename string) (interface{}, error)

func PostDaemonRestart 

func PostDaemonRestart(ctx context.Context, cli *client.T, nodename string) error

PostDaemonRestart sends an api request to restart the daemon and handles the response status codes.

func PostDaemonStop 

func PostDaemonStop(ctx context.Context, cli *client.T, nodename string) error

PostDaemonStop sends an api request to stop the daemon and handles the response status codes.

func ReadPasswordFromStdinOrPrompt 

func ReadPasswordFromStdinOrPrompt(prompt string) ([]byte, error)

func RefreshInstanceStatusFromClusterStatus 

func RefreshInstanceStatusFromClusterStatus(ctx context.Context, clusterStatus clusterdump.Data) error

RefreshInstanceStatusFromClusterStatus updates instance statuses for all nodes using cluster status data. It ensures instance status updates before return. Returns an error if client creation, API calls, or processing fails.

func Sections 

func Sections(b []byte, sections []string) []byte

func SelectorFromStdin 

func SelectorFromStdin() string

func UsageFlagEventFilter 

func UsageFlagEventFilter() string

func UsageFlagEventTemplate 

func UsageFlagEventTemplate() string

func WaitAllInstanceMonitor 

func WaitAllInstanceMonitor(ctx context.Context, c *client.T, p naming.Path, timeout time.Duration, errC chan error) error

WaitAllInstanceMonitor launches a go routine that waits for all instance monitor updated events are received for an object within a given timeout, or ctx.Done() reached. The result of the wait is sent to the errC channel: nil if the InstanceMonitorUpdated event occurs, or a non-nil error otherwise.

It also filters the ObjectConfigUpdated events to get the expected Instance monitor updated events from the instance config scope nodes.

If acquiring the event reader fails, WaitInstanceMonitor returns the error immediately and does not send anything to errC.

func WaitInstanceMonitor 

func WaitInstanceMonitor(ctx context.Context, c *client.T, p naming.Path, timeout time.Duration, errC chan error) error

WaitInstanceMonitor launches a go routine that waits for a specific instance monitor update event within a given timeout, or ctx.Done() reached. The result of the wait is sent to the errC channel: nil if the InstanceMonitorUpdated event occurs, or a non-nil error otherwise.

If acquiring the event reader fails, WaitInstanceMonitor returns the error immediately and does not send anything to errC.

func WaitInstanceStatusUpdated 

func WaitInstanceStatusUpdated(ctx context.Context, c *client.T, nodename string, p naming.Path, timeout time.Duration, errC chan error) error

WaitInstanceStatusUpdated launches a go routine that waits for a specific instance status update event within a given timeout, or ctx.Done() reached. The result of the wait is sent to the errC channel: nil if the InstanceStatusUpdated event occurs, or a non-nil error otherwise.

If acquiring the event reader fails, WaitInstanceStatusUpdated returns the error immediately and does not send anything to errC.

Types

type CmdClusterAbort 

type CmdClusterAbort struct {
	Color  string
	Output string
	OptsAsync
}

func (*CmdClusterAbort) Run 

func (t *CmdClusterAbort) Run() error

type CmdClusterConfigDoc 

type CmdClusterConfigDoc struct {
	Color   string
	Output  string
	Keyword string
	Driver  string
	Depth   int
}

func (*CmdClusterConfigDoc) Run 

func (t *CmdClusterConfigDoc) Run() error

type CmdClusterFreeze 

type CmdClusterFreeze struct {
	OptsAsync
	Color  string
	Output string
}

func (*CmdClusterFreeze) Run 

func (t *CmdClusterFreeze) Run() error

type CmdClusterLogs 

type CmdClusterLogs struct {
	OptsLogs
	Color        string
	NodeSelector string
	Output       string
}

func (*CmdClusterLogs) Run 

func (t *CmdClusterLogs) Run() error

type CmdClusterSSHTrust 

type CmdClusterSSHTrust struct {
}

func (*CmdClusterSSHTrust) Run 

func (t *CmdClusterSSHTrust) Run() error

type CmdClusterUnfreeze 

type CmdClusterUnfreeze struct {
	OptsAsync
	Color  string
	Output string
}

func (*CmdClusterUnfreeze) Run 

func (t *CmdClusterUnfreeze) Run() error

type CmdDaemonAuth 

type CmdDaemonAuth struct {
	Roles           []string
	Subject         string
	Scope           string
	AccessDuration  time.Duration
	Out             string
	Refresh         bool
	RefreshDuration time.Duration
}

func (*CmdDaemonAuth) Run 

func (t *CmdDaemonAuth) Run() error

type CmdDaemonDNSDump 

type CmdDaemonDNSDump struct {
	Color        string
	Output       string
	NodeSelector string
}

func (*CmdDaemonDNSDump) Run 

func (t *CmdDaemonDNSDump) Run() error

type CmdDaemonHeartbeatRestart 

type CmdDaemonHeartbeatRestart struct {
	CmdDaemonSubAction
	Name string
}

func (*CmdDaemonHeartbeatRestart) Run 

func (t *CmdDaemonHeartbeatRestart) Run() error

type CmdDaemonHeartbeatRotate 

type CmdDaemonHeartbeatRotate struct {
	Wait bool
	Time time.Duration
}

func (*CmdDaemonHeartbeatRotate) Run 

func (t *CmdDaemonHeartbeatRotate) Run() error

type CmdDaemonHeartbeatSign 

type CmdDaemonHeartbeatSign struct {
	CmdDaemonSubAction
	Name string
}

func (*CmdDaemonHeartbeatSign) Run 

func (t *CmdDaemonHeartbeatSign) Run() error

type CmdDaemonHeartbeatStart 

type CmdDaemonHeartbeatStart struct {
	CmdDaemonSubAction
	Name string
}

func (*CmdDaemonHeartbeatStart) Run 

func (t *CmdDaemonHeartbeatStart) Run() error

type CmdDaemonHeartbeatStatus 

type CmdDaemonHeartbeatStatus struct {
	Color        string
	Output       string
	NodeSelector string
	PeerSelector string
	Name         string
}

func (*CmdDaemonHeartbeatStatus) Run 

func (t *CmdDaemonHeartbeatStatus) Run() error

type CmdDaemonHeartbeatStop 

type CmdDaemonHeartbeatStop struct {
	CmdDaemonSubAction
	Name string
}

func (*CmdDaemonHeartbeatStop) Run 

func (t *CmdDaemonHeartbeatStop) Run() error

type CmdDaemonHeartbeatWipe 

type CmdDaemonHeartbeatWipe struct {
	CmdDaemonSubAction
	Name string
}

func (*CmdDaemonHeartbeatWipe) Run 

func (t *CmdDaemonHeartbeatWipe) Run() error

type CmdDaemonListenerLog 

type CmdDaemonListenerLog struct {
	CmdDaemonSubAction
	Name  string
	Level string
}

func (*CmdDaemonListenerLog) Run 

func (t *CmdDaemonListenerLog) Run() error

type CmdDaemonListenerRestart 

type CmdDaemonListenerRestart struct {
	CmdDaemonSubAction
	Name string
}

func (*CmdDaemonListenerRestart) Run 

func (t *CmdDaemonListenerRestart) Run() error

type CmdDaemonListenerStart 

type CmdDaemonListenerStart struct {
	CmdDaemonSubAction
	Name string
}

func (*CmdDaemonListenerStart) Run 

func (t *CmdDaemonListenerStart) Run() error

type CmdDaemonListenerStop 

type CmdDaemonListenerStop struct {
	CmdDaemonSubAction
	Name string
}

func (*CmdDaemonListenerStop) Run 

func (t *CmdDaemonListenerStop) Run() error

type CmdDaemonLog 

type CmdDaemonLog struct {
	CmdDaemonSubAction
	Level string
}

func (*CmdDaemonLog) Run 

func (t *CmdDaemonLog) Run() error

type CmdDaemonRelayStatus 

type CmdDaemonRelayStatus struct {
	Color  string
	Output string
}

func (*CmdDaemonRelayStatus) Run 

func (t *CmdDaemonRelayStatus) Run() error

type CmdDaemonSubAction 

type CmdDaemonSubAction struct {
	Debug        bool
	NodeSelector string
}

func (*CmdDaemonSubAction) Run 

func (t *CmdDaemonSubAction) Run(fn apiFuncWithNode) error

Run daemon sub-component action

type CmdNodeConfigDoc 

type CmdNodeConfigDoc struct {
	Color   string
	Output  string
	Keyword string
	Driver  string
	Depth   int
}

func (*CmdNodeConfigDoc) Run 

func (t *CmdNodeConfigDoc) Run() error

type CmdNodeEvents 

type CmdNodeEvents struct {
	OptsGlobal
	Filters  []string
	Duration time.Duration
	Limit    uint64
	Template string
	Wait     bool
	Quiet    bool

	NodeSelector string
	// contains filtered or unexported fields
}

func (*CmdNodeEvents) DoNodes 

func (t *CmdNodeEvents) DoNodes() error

type CmdNodeLogs 

type CmdNodeLogs struct {
	OptsGlobal
	OptsLogs
	NodeSelector string
}

CmdNodeLogs duplicates the omcmd and oxcmd CmdNodeLogs configuration for fetching logs from nodes based on the specified NodeSelector.

func (*CmdNodeLogs) Remote 

func (t *CmdNodeLogs) Remote() error

Remote fetches logs remotely from the nodes specified by the NodeSelector, using concurrent streaming for each node. Returns an error if the client setup fails, no nodes are selected, or if there are issues during the process.

type CmdObjectConfigDoc 

type CmdObjectConfigDoc struct {
	OptsGlobal
	Color   string
	Output  string
	Keyword string
	Driver  string
	Depth   int
}

func (*CmdObjectConfigDoc) Run 

func (t *CmdObjectConfigDoc) Run(kind string) error

type CmdObjectInstanceClear 

type CmdObjectInstanceClear struct {
	ObjectSelector string
	NodeSelector   *string
}

func (*CmdObjectInstanceClear) Run 

func (t *CmdObjectInstanceClear) Run(kind string) error

type CmdObjectLogs 

type CmdObjectLogs struct {
	OptsGlobal
	OptsLogs
	NodeSelector string
}

CmdObjectLogs duplicates the omcmd and oxcmd CmdObjectLogs configuration for fetching logs from nodes based on the specified NodeSelector.

func (*CmdObjectLogs) Remote 

func (t *CmdObjectLogs) Remote(selStr string) error

Remote executes the object log retrieval operation for selected nodes and paths in an asynchronous manner. It leverages the provided selector string to identify target objects and nodes for log streaming.

type CmdObjectMonitor 

type CmdObjectMonitor struct {
	Color          string
	ObjectSelector string
	Output         string
	Sections       string
	Watch          bool
}

func (*CmdObjectMonitor) Run 

func (t *CmdObjectMonitor) Run(selector, kind string) error

type CmdPoolList 

type CmdPoolList struct {
	OptsGlobal
	Name         string
	NodeSelector string
}

func (*CmdPoolList) Run 

func (t *CmdPoolList) Run() error

type OptTo 

type OptTo struct {
	To     string
	UpTo   string // Deprecated
	DownTo string // Deprecated
}

OptTo sets a barrier when iterating over a resource lister

type OptsAsync 

type OptsAsync struct {
	Watch bool
	Wait  bool
	Time  time.Duration
}

OptsAsync contains options accepted by all actions having an orchestration

type OptsEncap 

type OptsEncap struct {
	// A list of encap instance, identified by hostname of the container
	Slaves []string

	// The host instance
	Master bool

	// All encap instances
	AllSlaves bool
}

OptsEncap contains options to select where a instance action runs with a encap enabled service

type OptsGlobal 

type OptsGlobal struct {
	Color          string
	Output         string
	ObjectSelector string
}

type OptsLock 

type OptsLock struct {
	Disable bool
	Timeout time.Duration
}

OptsLock contains options accepted by all actions using an action lock

type OptsLogs 

type OptsLogs struct {
	Follow bool
	Lines  int
	Filter []string
}

OptsLogs contains options used by all log commands: node logs, cluster logs, object logs

type OptsResourceSelector 

type OptsResourceSelector struct {
	RID    string
	Subset string
	Tag    string
}

OptsResourceSelector contains options needed to initialize a resourceselector.Options struct

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.