app

Documentation

Index

• func InstallFlags(flags *pflag.FlagSet, opt *VolumeWatcherOpts)
• func NewConfigManagerCommand(ctx context.Context, name string) *cobra.Command
• type NotifyEventType
  • func (f *NotifyEventType) Set(val string) error
  • func (f *NotifyEventType) String() string
  • func (f *NotifyEventType) Type() string
• type ReconfigureServiceOptions
• type TplScriptConfig
• type VolumeWatcherOpts
  • func NewVolumeWatcherOpts() *VolumeWatcherOpts

Functions

func InstallFlags

func InstallFlags(flags *pflag.FlagSet, opt *VolumeWatcherOpts)

func NewConfigManagerCommand

func NewConfigManagerCommand(ctx context.Context, name string) *cobra.Command

NewConfigManagerCommand is used to reload configuration

Types

type NotifyEventType

type NotifyEventType int

const (
	UnixSignal NotifyEventType = iota // "signal"
	WebHook                           // "http"
	ShellTool                         // "exec"
	SQL                               // "sql"
	TPLScript                         // "tpl"
)

func (*NotifyEventType) Set

func (f *NotifyEventType) Set(val string) error

func (*NotifyEventType) String

func (f *NotifyEventType) String() string

func (*NotifyEventType) Type

func (f *NotifyEventType) Type() string

type ReconfigureServiceOptions

type ReconfigureServiceOptions struct {
	GrpcPort int
	PodIP    string

	// EnableRemoteOnlineUpdate enables remote online update
	RemoteOnlineUpdateEnable bool
	// EnableContainerRuntime enables container runtime
	ContainerRuntimeEnable bool

	DebugMode        bool
	ContainerRuntime cfgutil.CRIType
	RuntimeEndpoint  string
}

type TplScriptConfig

type TplScriptConfig struct {
	Scripts         string                       `json:"scripts"`
	FileRegex       string                       `json:"fileRegex"`
	DataType        string                       `json:"dataType"`
	DSN             string                       `json:"dsn"`
	FormatterConfig appsv1alpha1.FormatterConfig `json:"formatterConfig"`
}

type VolumeWatcherOpts

type VolumeWatcherOpts struct {
	VolumeDirs []string

	// fileRegex watches file regex
	FileRegex string

	// ProcessName: program name
	ProcessName string

	// Signal is valid for UnixSignal
	Signal appsv1alpha1.SignalType

	// Exec command for reload
	Command string

	// Exec command for reload
	TPLConfig       string
	BackupPath      string
	FormatterConfig *appsv1alpha1.FormatterConfig
	TPLScriptPath   string
	DataType        string
	DSN             string

	LogLevel       string
	NotifyHandType NotifyEventType

	ServiceOpt ReconfigureServiceOptions
}

func NewVolumeWatcherOpts

func NewVolumeWatcherOpts() *VolumeWatcherOpts