Documentation ¶
Index ¶
- Constants
- func ConfigDir() (string, error)
- func MakeAgentChannelRequest(addr string, appId byte, f func(ch channel.Channel) error) error
- func NewAgentChannel(conn net.Conn) (channel.Channel, error)
- func NewAgentClusterAdd(p common.OptionsProvider) *cobra.Command
- func NewAgentClusterList(p common.OptionsProvider) *cobra.Command
- func NewAgentClusterRemove(p common.OptionsProvider) *cobra.Command
- func NewAgentCmd(p common.OptionsProvider) *cobra.Command
- func NewAgentCtrlInit(p common.OptionsProvider) *cobra.Command
- func NewAgentCtrlInitFromDb(p common.OptionsProvider) *cobra.Command
- func NewAgentTransferLeadership(p common.OptionsProvider) *cobra.Command
- func NewClearChannelLogLevelCmd(p common.OptionsProvider) *cobra.Command
- func NewForgetLinkAgentCmd(p common.OptionsProvider) *cobra.Command
- func NewGetCmd(p common.OptionsProvider) *cobra.Command
- func NewListCmd(p common.OptionsProvider) *cobra.Command
- func NewPprofCpuCmd(p common.OptionsProvider) *cobra.Command
- func NewPprofHeapCmd(p common.OptionsProvider) *cobra.Command
- func NewPsCmd(p common.OptionsProvider) *cobra.Command
- func NewRouteCmd(p common.OptionsProvider) *cobra.Command
- func NewSetChannelLogLevelCmd(p common.OptionsProvider) *cobra.Command
- func NewSetGcCmd(p common.OptionsProvider) *cobra.Command
- func NewSetLogLevelCmd(p common.OptionsProvider) *cobra.Command
- func NewSimpleAgentCmd(name string, op byte, p common.OptionsProvider, desc string) *cobra.Command
- func NewSimpleAgentCustomCmd(name string, appId AgentAppId, op byte, p common.OptionsProvider) *cobra.Command
- func NewSimpleChAgentCustomCmd(name string, appId AgentAppId, op int32, p common.OptionsProvider) *cobra.Command
- func NewStackCmd(p common.OptionsProvider) *cobra.Command
- func NewToggleCtrlChannelAgentCmd(p common.OptionsProvider, name string, enable bool) *cobra.Command
- func NewTraceCmd(p common.OptionsProvider) *cobra.Command
- func NewUnrouteCmd(p common.OptionsProvider) *cobra.Command
- func PIDFile(pid int) (string, error)
- type AgentAppId
- type AgentClearChannelLogLevelAction
- type AgentClusterAddAction
- type AgentClusterListAction
- type AgentClusterRemoveAction
- type AgentCtrlInitFromDbAction
- type AgentCtrlInitOptions
- type AgentGetOptionsAction
- type AgentListAction
- type AgentOptions
- func (self *AgentOptions) AddAgentOptions(cmd *cobra.Command)
- func (self *AgentOptions) CopyToWriter(out io.Writer) func(conn net.Conn) error
- func (self *AgentOptions) GetProcess() (*agent.Process, error)
- func (self *AgentOptions) MakeChannelRequest(appId byte, f func(ch channel.Channel) error) error
- func (self *AgentOptions) MakeRequest(signal byte, params []byte, f func(c net.Conn) error) error
- func (self *AgentOptions) RunCopyOut(op byte, params []byte, out io.Writer) error
- type AgentPprofCpuAction
- type AgentPprofHeapAction
- type AgentPsAction
- type AgentRouteAction
- type AgentSetChannelLogLevelAction
- type AgentSetGcAction
- type AgentSetLogLevelAction
- type AgentStackAction
- type AgentTraceAction
- type AgentTransferLeadershipAction
- type AgentUnrouteAction
- type ForgetLinkAgentAction
- type P
- type SimpleAgentAction
- type SimpleChAgentCmdAction
- type ToggleCtrlChannelAgentAction
Constants ¶
View Source
const ( AgentAppController = AgentAppId(controller.AgentAppId) AgentAppRouter = AgentAppId(router.AgentAppId) )
Variables ¶
This section is empty.
Functions ¶
func MakeAgentChannelRequest ¶
func NewAgentChannel ¶
func NewAgentClusterAdd ¶ added in v0.27.6
func NewAgentClusterAdd(p common.OptionsProvider) *cobra.Command
func NewAgentClusterList ¶ added in v0.27.6
func NewAgentClusterList(p common.OptionsProvider) *cobra.Command
func NewAgentClusterRemove ¶ added in v0.27.6
func NewAgentClusterRemove(p common.OptionsProvider) *cobra.Command
func NewAgentCmd ¶
func NewAgentCmd(p common.OptionsProvider) *cobra.Command
func NewAgentCtrlInit ¶
func NewAgentCtrlInit(p common.OptionsProvider) *cobra.Command
func NewAgentCtrlInitFromDb ¶ added in v0.27.2
func NewAgentCtrlInitFromDb(p common.OptionsProvider) *cobra.Command
func NewAgentTransferLeadership ¶ added in v0.27.6
func NewAgentTransferLeadership(p common.OptionsProvider) *cobra.Command
func NewClearChannelLogLevelCmd ¶
func NewClearChannelLogLevelCmd(p common.OptionsProvider) *cobra.Command
func NewForgetLinkAgentCmd ¶
func NewForgetLinkAgentCmd(p common.OptionsProvider) *cobra.Command
func NewListCmd ¶ added in v0.27.3
func NewListCmd(p common.OptionsProvider) *cobra.Command
NewListCmd Pss a command object for the "list" command
func NewPprofCpuCmd ¶
func NewPprofCpuCmd(p common.OptionsProvider) *cobra.Command
func NewPprofHeapCmd ¶
func NewPprofHeapCmd(p common.OptionsProvider) *cobra.Command
func NewPsCmd ¶
func NewPsCmd(p common.OptionsProvider) *cobra.Command
NewPsCmd Pss a command object for the "Ps" command
func NewRouteCmd ¶
func NewRouteCmd(p common.OptionsProvider) *cobra.Command
func NewSetChannelLogLevelCmd ¶
func NewSetChannelLogLevelCmd(p common.OptionsProvider) *cobra.Command
func NewSetGcCmd ¶
func NewSetGcCmd(p common.OptionsProvider) *cobra.Command
func NewSetLogLevelCmd ¶
func NewSetLogLevelCmd(p common.OptionsProvider) *cobra.Command
func NewSimpleAgentCmd ¶ added in v0.27.3
func NewSimpleAgentCustomCmd ¶
func NewSimpleAgentCustomCmd(name string, appId AgentAppId, op byte, p common.OptionsProvider) *cobra.Command
func NewSimpleChAgentCustomCmd ¶
func NewSimpleChAgentCustomCmd(name string, appId AgentAppId, op int32, p common.OptionsProvider) *cobra.Command
func NewStackCmd ¶
func NewStackCmd(p common.OptionsProvider) *cobra.Command
func NewToggleCtrlChannelAgentCmd ¶ added in v0.27.3
func NewTraceCmd ¶
func NewTraceCmd(p common.OptionsProvider) *cobra.Command
func NewUnrouteCmd ¶ added in v0.28.0
func NewUnrouteCmd(p common.OptionsProvider) *cobra.Command
Types ¶
type AgentAppId ¶
type AgentAppId byte
type AgentClearChannelLogLevelAction ¶
type AgentClearChannelLogLevelAction struct {
AgentOptions
}
func (*AgentClearChannelLogLevelAction) Run ¶
func (self *AgentClearChannelLogLevelAction) Run() error
Run implements the command
type AgentClusterAddAction ¶ added in v0.27.6
type AgentClusterAddAction struct { AgentOptions Voter bool MemberId string }
type AgentClusterListAction ¶ added in v0.27.6
type AgentClusterListAction struct {
AgentOptions
}
type AgentClusterRemoveAction ¶ added in v0.27.6
type AgentClusterRemoveAction struct {
AgentOptions
}
type AgentCtrlInitFromDbAction ¶ added in v0.27.3
type AgentCtrlInitFromDbAction struct { AgentOptions Voter bool MemberId string }
type AgentCtrlInitOptions ¶
type AgentCtrlInitOptions struct {
AgentOptions
}
type AgentGetOptionsAction ¶
type AgentGetOptionsAction struct { AgentOptions Pid string }
func (*AgentGetOptionsAction) Run ¶
func (self *AgentGetOptionsAction) Run() error
Run implements the command
type AgentListAction ¶ added in v0.27.3
type AgentListAction struct {
AgentOptions
}
func (*AgentListAction) Run ¶ added in v0.27.3
func (self *AgentListAction) Run() error
type AgentOptions ¶
type AgentOptions struct { common.CommonOptions // contains filtered or unexported fields }
AgentOptions contains the command line options
func (*AgentOptions) AddAgentOptions ¶ added in v0.27.3
func (self *AgentOptions) AddAgentOptions(cmd *cobra.Command)
func (*AgentOptions) CopyToWriter ¶ added in v0.27.3
func (*AgentOptions) GetProcess ¶ added in v0.27.3
func (self *AgentOptions) GetProcess() (*agent.Process, error)
func (*AgentOptions) MakeChannelRequest ¶ added in v0.27.3
func (self *AgentOptions) MakeChannelRequest(appId byte, f func(ch channel.Channel) error) error
func (*AgentOptions) MakeRequest ¶ added in v0.27.3
func (*AgentOptions) RunCopyOut ¶ added in v0.27.3
type AgentPprofCpuAction ¶
type AgentPprofCpuAction struct { AgentOptions // contains filtered or unexported fields }
func (*AgentPprofCpuAction) Run ¶
func (self *AgentPprofCpuAction) Run() error
Run implements the command
type AgentPprofHeapAction ¶
type AgentPprofHeapAction struct { AgentOptions // contains filtered or unexported fields }
func (*AgentPprofHeapAction) Run ¶
func (self *AgentPprofHeapAction) Run() error
Run implements the command
type AgentPsAction ¶
type AgentPsAction struct {
AgentOptions
}
type AgentRouteAction ¶
type AgentRouteAction struct {
AgentOptions
}
type AgentSetChannelLogLevelAction ¶
type AgentSetChannelLogLevelAction struct {
AgentOptions
}
func (*AgentSetChannelLogLevelAction) Run ¶
func (self *AgentSetChannelLogLevelAction) Run() error
Run implements the command
type AgentSetGcAction ¶
type AgentSetGcAction struct {
AgentOptions
}
type AgentSetLogLevelAction ¶
type AgentSetLogLevelAction struct {
AgentOptions
}
func (*AgentSetLogLevelAction) Run ¶
func (self *AgentSetLogLevelAction) Run() error
Run implements the command
type AgentStackAction ¶
type AgentStackAction struct { AgentOptions StackTimeout time.Duration }
type AgentTraceAction ¶
type AgentTraceAction struct {
AgentOptions
}
type AgentTransferLeadershipAction ¶ added in v0.27.6
type AgentTransferLeadershipAction struct {
AgentOptions
}
type AgentUnrouteAction ¶ added in v0.28.0
type AgentUnrouteAction struct {
AgentOptions
}
type ForgetLinkAgentAction ¶
type ForgetLinkAgentAction struct {
AgentOptions
}
func (*ForgetLinkAgentAction) Run ¶
func (self *ForgetLinkAgentAction) Run() error
Run implements the command
type SimpleAgentAction ¶
type SimpleAgentAction struct {
AgentOptions
}
func (*SimpleAgentAction) Run ¶
func (self *SimpleAgentAction) Run(appId AgentAppId, op byte) error
Run implements the command
type SimpleChAgentCmdAction ¶ added in v0.27.3
type SimpleChAgentCmdAction struct { AgentOptions // contains filtered or unexported fields }
func (*SimpleChAgentCmdAction) Run ¶ added in v0.27.3
func (self *SimpleChAgentCmdAction) Run(appId AgentAppId) error
Run implements the command
type ToggleCtrlChannelAgentAction ¶ added in v0.27.3
type ToggleCtrlChannelAgentAction struct { AgentOptions // contains filtered or unexported fields }
func (*ToggleCtrlChannelAgentAction) Run ¶ added in v0.27.3
func (self *ToggleCtrlChannelAgentAction) Run() error
Run implements the command
Source Files ¶
- agent.go
- agent_ch_simple.go
- agent_clear_channel_log_level.go
- agent_cluster_add.go
- agent_cluster_list.go
- agent_cluster_remove.go
- agent_cluster_transfer_leadership.go
- agent_controller_init.go
- agent_controller_init_from_db.go
- agent_get.go
- agent_list.go
- agent_pprof_cpu.go
- agent_pprof_heap.go
- agent_ps.go
- agent_router_add_route.go
- agent_router_forget_link.go
- agent_router_toggle_ctrl_channel.go
- agent_router_unroute.go
- agent_set_channel_log_level.go
- agent_set_log_level.go
- agent_setgc.go
- agent_simple.go
- agent_stack.go
- agent_trace.go
Click to show internal directories.
Click to hide internal directories.