cmd

Documentation

Index

• Constants
• func WithCronTaskLogName() func(*CmdOpts)
• func WithLogName(logName string) func(*CmdOpts)
• type ApiCmd
  • func NewApiCmd() *ApiCmd
  • func (a *ApiCmd) AddApi(f func(port int, promPort int) error)
  • func (a *ApiCmd) GetPortFromConfig(portType string) int
• type ClearCmd
  • func NewClearCmd() *ClearCmd
• type CmdOpts
• type CronTaskCmd
  • func NewCronTaskCmd() *CronTaskCmd
  • func (c *CronTaskCmd) Exec(f func() error) error
• type FixCmd
  • func NewFixCmd() *FixCmd
• type GetCmd
  • func NewGetCmd() *GetCmd
• type MsgCmd
  • func NewMsgCmd() *MsgCmd
  • func (m *MsgCmd) ClearMsgCmd() *cobra.Command
  • func (m *MsgCmd) GetMsgCmd() *cobra.Command
• type MsgGatewayCmd
  • func NewMsgGatewayCmd() *MsgGatewayCmd
  • func (m *MsgGatewayCmd) AddWsPortFlag()
  • func (m *MsgGatewayCmd) Exec() error
  • func (m *MsgGatewayCmd) GetPortFromConfig(portType string) int
• type MsgTransferCmd
  • func NewMsgTransferCmd() *MsgTransferCmd
  • func (m *MsgTransferCmd) AddTransferProgressFlag()
  • func (m *MsgTransferCmd) Exec() error
  • func (m *MsgTransferCmd) GetPortFromConfig(portType string) int
• type MsgUtilsCmd
  • func NewMsgUtilsCmd(use, short string, args cobra.PositionalArgs) *MsgUtilsCmd
  • func (m *MsgUtilsCmd) AddBeginSeqFlag()
  • func (m *MsgUtilsCmd) AddClearAllFlag()
  • func (m *MsgUtilsCmd) AddFixAllFlag()
  • func (m *MsgUtilsCmd) AddLimitFlag()
  • func (m *MsgUtilsCmd) AddSuperGroupIDFlag()
  • func (m *MsgUtilsCmd) AddUserIDFlag()
  • func (m *MsgUtilsCmd) Execute() error
• type RootCmd
  • func NewRootCmd(name string, opts ...func(*CmdOpts)) *RootCmd
  • func (r *RootCmd) AddCommand(cmds ...*cobra.Command)
  • func (r *RootCmd) AddPortFlag()
  • func (r *RootCmd) AddPrometheusPortFlag()
  • func (r *RootCmd) Execute() error
  • func (r *RootCmd) GetPortFlag() int
  • func (r *RootCmd) GetPortFromConfig(portType string) int
  • func (r *RootCmd) GetPrometheusPortFlag() int
  • func (r *RootCmd) PortFromConfig(portType string) int
  • func (r *RootCmd) SetRootCmdPt(cmdItf RootCmdPt)
• type RootCmdPt
• type RpcCmd
  • func NewRpcCmd(name string) *RpcCmd
  • func (a *RpcCmd) Exec() error
  • func (a *RpcCmd) GetPortFromConfig(portType string) int
  • func (a *RpcCmd) StartSvr(name string, ...) error
• type SeqCmd
  • func NewSeqCmd() *SeqCmd
  • func (s *SeqCmd) FixSeqCmd() *cobra.Command
  • func (s *SeqCmd) GetSeqCmd() *cobra.Command

Constants

const (
	RpcPushServer         = "push"
	RpcAuthServer         = "auth"
	RpcConversationServer = "conversation"
	RpcFriendServer       = "friend"
	RpcGroupServer        = "group"
	RpcMsgServer          = "msg"
	RpcThirdServer        = "third"
	RpcUserServer         = "user"
)

Functions

func WithCronTaskLogName

func WithCronTaskLogName() func(*CmdOpts)

func WithLogName

func WithLogName(logName string) func(*CmdOpts)

Types

type ApiCmd

type ApiCmd struct {
	*RootCmd
}

func NewApiCmd

func NewApiCmd() *ApiCmd

func (*ApiCmd) AddApi

func (a *ApiCmd) AddApi(f func(port int, promPort int) error)

func (*ApiCmd) GetPortFromConfig

func (a *ApiCmd) GetPortFromConfig(portType string) int

type ClearCmd

type ClearCmd struct {
	*MsgUtilsCmd
}

func NewClearCmd

func NewClearCmd() *ClearCmd

type CmdOpts

type CmdOpts struct {
	// contains filtered or unexported fields
}

type CronTaskCmd

type CronTaskCmd struct {
	*RootCmd
}

func NewCronTaskCmd

func NewCronTaskCmd() *CronTaskCmd

func (*CronTaskCmd) Exec

func (c *CronTaskCmd) Exec(f func() error) error

type FixCmd

type FixCmd struct {
	*MsgUtilsCmd
}

func NewFixCmd

func NewFixCmd() *FixCmd

type GetCmd

type GetCmd struct {
	*MsgUtilsCmd
}

func NewGetCmd

func NewGetCmd() *GetCmd

type MsgCmd

type MsgCmd struct {
	*MsgUtilsCmd
}

func NewMsgCmd

func NewMsgCmd() *MsgCmd

func (*MsgCmd) ClearMsgCmd

func (m *MsgCmd) ClearMsgCmd() *cobra.Command

func (*MsgCmd) GetMsgCmd

func (m *MsgCmd) GetMsgCmd() *cobra.Command

type MsgGatewayCmd

type MsgGatewayCmd struct {
	*RootCmd
}

func NewMsgGatewayCmd

func NewMsgGatewayCmd() *MsgGatewayCmd

func (*MsgGatewayCmd) AddWsPortFlag

func (m *MsgGatewayCmd) AddWsPortFlag()

func (*MsgGatewayCmd) Exec

func (m *MsgGatewayCmd) Exec() error

func (*MsgGatewayCmd) GetPortFromConfig

func (m *MsgGatewayCmd) GetPortFromConfig(portType string) int

type MsgTransferCmd

type MsgTransferCmd struct {
	*RootCmd
}

func NewMsgTransferCmd

func NewMsgTransferCmd() *MsgTransferCmd

func (*MsgTransferCmd) AddTransferProgressFlag

func (m *MsgTransferCmd) AddTransferProgressFlag()

func (*MsgTransferCmd) Exec

func (m *MsgTransferCmd) Exec() error

func (*MsgTransferCmd) GetPortFromConfig

func (m *MsgTransferCmd) GetPortFromConfig(portType string) int

type MsgUtilsCmd

type MsgUtilsCmd struct {
	cobra.Command
	// contains filtered or unexported fields
}

func NewMsgUtilsCmd

func NewMsgUtilsCmd(use, short string, args cobra.PositionalArgs) *MsgUtilsCmd

func (*MsgUtilsCmd) AddBeginSeqFlag

func (m *MsgUtilsCmd) AddBeginSeqFlag()

func (*MsgUtilsCmd) AddClearAllFlag

func (m *MsgUtilsCmd) AddClearAllFlag()

func (*MsgUtilsCmd) AddFixAllFlag

func (m *MsgUtilsCmd) AddFixAllFlag()

func (*MsgUtilsCmd) AddLimitFlag

func (m *MsgUtilsCmd) AddLimitFlag()

func (*MsgUtilsCmd) AddSuperGroupIDFlag

func (m *MsgUtilsCmd) AddSuperGroupIDFlag()

func (*MsgUtilsCmd) AddUserIDFlag

func (m *MsgUtilsCmd) AddUserIDFlag()

func (*MsgUtilsCmd) Execute

func (m *MsgUtilsCmd) Execute() error

type RootCmd

type RootCmd struct {
	Command cobra.Command
	Name    string
	// contains filtered or unexported fields
}

func NewRootCmd

func NewRootCmd(name string, opts ...func(*CmdOpts)) *RootCmd

func (*RootCmd) AddCommand

func (r *RootCmd) AddCommand(cmds ...*cobra.Command)

func (*RootCmd) AddPortFlag

func (r *RootCmd) AddPortFlag()

func (*RootCmd) AddPrometheusPortFlag

func (r *RootCmd) AddPrometheusPortFlag()

func (*RootCmd) Execute

func (r *RootCmd) Execute() error

func (*RootCmd) GetPortFlag

func (r *RootCmd) GetPortFlag() int

func (*RootCmd) GetPortFromConfig

func (r *RootCmd) GetPortFromConfig(portType string) int

func (*RootCmd) GetPrometheusPortFlag

func (r *RootCmd) GetPrometheusPortFlag() int

func (*RootCmd) PortFromConfig

func (r *RootCmd) PortFromConfig(portType string) int

func (*RootCmd) SetRootCmdPt

func (r *RootCmd) SetRootCmdPt(cmdItf RootCmdPt)

type RootCmdPt

type RootCmdPt interface {
	GetPortFromConfig(portType string) int
}

type RpcCmd

type RpcCmd struct {
	*RootCmd
}

func NewRpcCmd

func NewRpcCmd(name string) *RpcCmd

func (*RpcCmd) Exec

func (a *RpcCmd) Exec() error

func (*RpcCmd) GetPortFromConfig

func (a *RpcCmd) GetPortFromConfig(portType string) int

func (*RpcCmd) StartSvr

func (a *RpcCmd) StartSvr(
	name string,
	rpcFn func(discov discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error,
) error

type SeqCmd

type SeqCmd struct {
	*MsgUtilsCmd
}

func NewSeqCmd

func NewSeqCmd() *SeqCmd

func (*SeqCmd) FixSeqCmd

func (s *SeqCmd) FixSeqCmd() *cobra.Command

func (*SeqCmd) GetSeqCmd

func (s *SeqCmd) GetSeqCmd() *cobra.Command