/* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at https://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package events import ( "fmt" "time" ) // Type indicates type of the event type Type int const ( // ApplierType is event that are produced by applier ApplierType Type = iota // ErrorType means that even is of error type ErrorType // StatusPollerType event produced by status poller StatusPollerType // WaitType is event emitted when airshipctl is waiting for something WaitType // ClusterctlType event emitted by Clusterctl executor ClusterctlType // BootstrapType event emitted by Bootstrap executor BootstrapType // GenericContainerType event emitted by GenericContainer GenericContainerType // BaremetalManagerEventType event emitted by BaremetalManager BaremetalManagerEventType ) // Event holds all possible events that can be produced by airship type Event struct { Type Type Timestamp time.Time ApplierEvent ApplierEvent ErrorEvent ErrorEvent ClusterctlEvent ClusterctlEvent BootstrapEvent BootstrapEvent GenericContainerEvent GenericContainerEvent BaremetalManagerEvent BaremetalManagerEvent } // ApplierEvent is produced by k8s_apply executor type ApplierEvent struct { Operation string Message string } //GenericEvent generalized type for custom events type GenericEvent struct { Type string Operation string Message string Timestamp time.Time } var mapTypeToEvent = map[Type]string{ ClusterctlType: "ClusterctlEvent", BootstrapType: "BootstrapEvent", GenericContainerType: "GenericContainerEvent", } var unknownEventType = map[Type]string{ ApplierType: "ApplierType", ErrorType: "ErrorType", StatusPollerType: "StatusPollerType", WaitType: "WaitType", } var clusterctlOperationToString = map[ClusterctlOperation]string{ ClusterctlInitStart: "ClusterctlInitStart", ClusterctlInitEnd: "ClusterctlInitEnd", ClusterctlMoveStart: "ClusterctlMoveStart", ClusterctlMoveEnd: "ClusterctlMoveEnd", } var bootstrapOperationToString = map[BootstrapOperation]string{ BootstrapStart: "BootstrapStart", BootstrapDryRun: "BootstrapDryRun", BootstrapValidation: "BootstrapValidation", BootstrapRun: "BootstrapRun", BootstrapEnd: "BootstrapEnd", } var genericContainerOperationToString = map[GenericContainerOperation]string{ GenericContainerStart: "GenericContainerStart", GenericContainerStop: "GenericContainerStop", } var baremetalInventoryOperationToString = map[BaremetalManagerStep]string{ BaremetalManagerStart: "BaremetalOperationStart", BaremetalManagerComplete: "BaremetalOperationComplete", } //Normalize cast Event to GenericEvent type func Normalize(e Event) GenericEvent { var eventType string if t, exists := mapTypeToEvent[e.Type]; exists { eventType = t } else { eventType = fmt.Sprintf("Unknown event type: %v", unknownEventType[e.Type]) } var operation, message string switch e.Type { case ClusterctlType: operation = clusterctlOperationToString[e.ClusterctlEvent.Operation] message = e.ClusterctlEvent.Message case BootstrapType: operation = bootstrapOperationToString[e.BootstrapEvent.Operation] message = e.BootstrapEvent.Message case GenericContainerType: operation = genericContainerOperationToString[e.GenericContainerEvent.Operation] message = e.GenericContainerEvent.Message case BaremetalManagerEventType: operation = baremetalInventoryOperationToString[e.BaremetalManagerEvent.Step] message = e.BaremetalManagerEvent.Message } return GenericEvent{ Type: eventType, Operation: operation, Message: message, Timestamp: e.Timestamp, } } // NewEvent create new event with timestamp func NewEvent() Event { return Event{ Timestamp: time.Now(), } } // ErrorEvent is produced when error is encountered type ErrorEvent struct { Error error } // WithErrorEvent sets type and actual error event func (e Event) WithErrorEvent(event ErrorEvent) Event { e.Type = ErrorType e.ErrorEvent = event return e } // ClusterctlOperation type type ClusterctlOperation int const ( // ClusterctlInitStart operation ClusterctlInitStart ClusterctlOperation = iota // ClusterctlInitEnd operation ClusterctlInitEnd // ClusterctlMoveStart operation ClusterctlMoveStart // ClusterctlMoveEnd operation ClusterctlMoveEnd ) // ClusterctlEvent is produced by clusterctl executor type ClusterctlEvent struct { Operation ClusterctlOperation Message string } // WithClusterctlEvent sets type and actual clusterctl event func (e Event) WithClusterctlEvent(concreteEvent ClusterctlEvent) Event { e.Type = ClusterctlType e.ClusterctlEvent = concreteEvent return e } // BootstrapOperation type type BootstrapOperation int const ( // BootstrapStart operation BootstrapStart BootstrapOperation = iota // BootstrapDryRun operation BootstrapDryRun // BootstrapValidation operation BootstrapValidation // BootstrapRun operation BootstrapRun // BootstrapEnd operation BootstrapEnd ) // BootstrapEvent needs to to track events in bootstrap executor type BootstrapEvent struct { Operation BootstrapOperation Message string } // WithBootstrapEvent sets type and actual bootstrap event func (e Event) WithBootstrapEvent(concreteEvent BootstrapEvent) Event { e.Type = BootstrapType e.BootstrapEvent = concreteEvent return e } // GenericContainerOperation type type GenericContainerOperation int const ( // GenericContainerStart operation GenericContainerStart GenericContainerOperation = iota // GenericContainerStop operation GenericContainerStop ) // GenericContainerEvent needs to to track events in GenericContainer executor type GenericContainerEvent struct { Operation GenericContainerOperation Message string } // WithGenericContainerEvent sets type and actual GenericContainer event func (e Event) WithGenericContainerEvent(concreteEvent GenericContainerEvent) Event { e.Type = GenericContainerType e.GenericContainerEvent = concreteEvent return e } // BaremetalManagerStep indicates what operation baremetal manager is currently peforming // Note that this is not baremetal type BaremetalManagerStep int const ( // BaremetalManagerStart operation BaremetalManagerStart BaremetalManagerStep = iota // BaremetalManagerComplete operation BaremetalManagerComplete ) // BaremetalManagerEvent event emitted by BaremetalManager type BaremetalManagerEvent struct { Step BaremetalManagerStep // HostOperation indicates which operation is performed against BMH Host HostOperation string Message string } // WithBaremetalManagerEvent sets type and actual bootstrap event func (e Event) WithBaremetalManagerEvent(concreteEvent BaremetalManagerEvent) Event { e.Type = BaremetalManagerEventType e.BaremetalManagerEvent = concreteEvent return e }