Documentation ¶
Index ¶
- func AssignClientSetToContext(machinectx *MachineCtx, eventBuilder *events.EventBuilder) error
- func AssignInitialCtx(ctx context.Context, machineCtx interface{}, log logger.Handler) (interface{}, *events.Event, error)
- func Connected() machines.State
- func Delete() machines.State
- func Disconnected() machines.State
- func Discovered() machines.State
- func GenerateClientSetAction(k8sContext *models.K8sContext, eventBuilder *events.EventBuilder) (*kubernetes.Client, error)
- func Ignored() machines.State
- func Initial() machines.State
- func New(ID string, log logger.Handler) (*machines.StateMachine, error)
- func NotFound() machines.State
- func Registered() machines.State
- type ConnectAction
- func (ca *ConnectAction) Execute(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (ca *ConnectAction) ExecuteOnEntry(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (ca *ConnectAction) ExecuteOnExit(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- type DeleteAction
- func (da *DeleteAction) Execute(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (da *DeleteAction) ExecuteOnEntry(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (da *DeleteAction) ExecuteOnExit(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- type DisconnectAction
- func (da *DisconnectAction) Execute(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (da *DisconnectAction) ExecuteOnEntry(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (da *DisconnectAction) ExecuteOnExit(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- type DiscoverAction
- func (da *DiscoverAction) Execute(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (da *DiscoverAction) ExecuteOnEntry(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (da *DiscoverAction) ExecuteOnExit(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- type IgnoreAction
- func (ia *IgnoreAction) Execute(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (ia *IgnoreAction) ExecuteOnEntry(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (ia *IgnoreAction) ExecuteOnExit(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- type MachineCtx
- type NotFoundAction
- func (ia *NotFoundAction) Execute(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (ia *NotFoundAction) ExecuteOnEntry(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (ia *NotFoundAction) ExecuteOnExit(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- type RegisterAction
- func (ra *RegisterAction) Execute(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (ra *RegisterAction) ExecuteOnEntry(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
- func (ra *RegisterAction) ExecuteOnExit(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AssignClientSetToContext ¶
func AssignClientSetToContext(machinectx *MachineCtx, eventBuilder *events.EventBuilder) error
func AssignInitialCtx ¶
func Disconnected ¶
func Discovered ¶
func GenerateClientSetAction ¶
func GenerateClientSetAction(k8sContext *models.K8sContext, eventBuilder *events.EventBuilder) (*kubernetes.Client, error)
func Registered ¶
Types ¶
type ConnectAction ¶
type ConnectAction struct{}
func (*ConnectAction) ExecuteOnEntry ¶
func (ca *ConnectAction) ExecuteOnEntry(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
Execute On Entry and Exit should not return next eventtype i suppose, look again.
func (*ConnectAction) ExecuteOnExit ¶
type DeleteAction ¶
type DeleteAction struct{}
func (*DeleteAction) ExecuteOnEntry ¶
func (*DeleteAction) ExecuteOnExit ¶
type DisconnectAction ¶
type DisconnectAction struct{}
func (*DisconnectAction) ExecuteOnEntry ¶
func (*DisconnectAction) ExecuteOnExit ¶
type DiscoverAction ¶
type DiscoverAction struct{}
func (*DiscoverAction) ExecuteOnEntry ¶
func (da *DiscoverAction) ExecuteOnEntry(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
Execute On Entry and Exit should not return next eventtype i suppose, look again.
func (*DiscoverAction) ExecuteOnExit ¶
type IgnoreAction ¶
type IgnoreAction struct{}
func (*IgnoreAction) ExecuteOnEntry ¶
func (*IgnoreAction) ExecuteOnExit ¶
type MachineCtx ¶
type MachineCtx struct { K8sContext models.K8sContext MesheryCtrlsHelper *models.MesheryControllersHelper K8sCompRegHelper *models.ComponentsRegistrationHelper EventBroadcaster *models.Broadcast Provider models.Provider OperatorTracker *models.OperatorTracker K8scontextChannel *models.K8scontextChan RegistryManager *meshmodel.RegistryManager // contains filtered or unexported fields }
func GetMachineCtx ¶
func GetMachineCtx(machinectx interface{}, eb *events.EventBuilder) (*MachineCtx, error)
type NotFoundAction ¶
type NotFoundAction struct{}
func (*NotFoundAction) ExecuteOnEntry ¶
func (*NotFoundAction) ExecuteOnExit ¶
type RegisterAction ¶
type RegisterAction struct{}
func (*RegisterAction) ExecuteOnEntry ¶
func (ra *RegisterAction) ExecuteOnEntry(ctx context.Context, machineCtx interface{}, data interface{}) (machines.EventType, *events.Event, error)
Execute On Entry and Exit should not return next eventtype i suppose, look again.
func (*RegisterAction) ExecuteOnExit ¶
Click to show internal directories.
Click to hide internal directories.