Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + const DROPPED + const EVENTS_INCR + const EVENTS_TOTAL + const FAILED + const FINISHED + const HEALTHY + const INSTANCE_FAILED + const INSTANCE_FINISHED + const INSTANCE_HEALTH_CHANGED_EVENT + const INSTANCE_KILLED + const INSTANCE_RUNNING + const INSTANCE_STATUS + const KILLED + const KILLING + const LEFT_EDGE + const RIGHT_DEGE + const RUNNING + const STAGING + const STARTING + const START_HC_TIME_SUFFIX + const STATUS_UPDATE_EVENT + const SUFFIX_EDAS + const SUFFIX_EDASV2_INIT + const SUFFIX_EDASV2_NORMAL + const SUFFIX_EDASV2_PERIOD + const SUFFIX_INIT + const SUFFIX_K8S_INIT + const SUFFIX_K8S_NORMAL + const SUFFIX_K8S_PERIOD + const SUFFIX_NORMAL + const SUFFIX_PERIOD + const UNHEALTHY + const UNKNOWN + const UNREACHABLE + const WATCHED_DIR + var EventboxDir = "/eventbox" + var MessageDir = filepath.Join(EventboxDir, "messages") + func HandleOneExecutorEvent(name string, ch chan *eventtypes.StatusEvent, lstore *sync.Map, ...) + func OnlyOne(ctx context.Context, lock *dlock.DLock) (func(), error) + type EventLayer struct + InstanceId string + RuntimeName string + ServiceName string + type EventMgr struct + MemEtcdStore jsonstore.JsonStore + func GetEventManager() *EventMgr + func (m *EventMgr) RegisterEventCallback(name string, cb executortypes.EventCbFn) error + func (m *EventMgr) UnRegisterEventCallback(name string) + type GetExecutorJsonStoreFn func(string) (*sync.Map, error) + type GetExecutorLocalStoreFn func(string) (*sync.Map, error) + type InstanceStatus struct + Extra map[string]interface{} + ID string + InstanceStatus string + Ip string + Stage string + type InstancesWindow struct + type LabelKey string + type Message struct + Content interface{} + Labels map[LabelKey]interface{} + Sender string + Time int64 + type Notifier interface + Send func(content interface{}, options ...OpOperation) error + SendRaw func(message *Message) error + func New(sender string, dest map[string]interface{}) (Notifier, error) + type NotifierImpl struct + func (n *NotifierImpl) Send(content interface{}, options ...OpOperation) error + func (n *NotifierImpl) SendRaw(message *Message) error + type Op struct + type OpOperation func(*Op) + func WithDest(dest map[string]interface{}) OpOperation + func WithSender(sender string) OpOperation + type RuntimeEvent struct + EventType string + IsDeleted bool + RuntimeName string + ServiceStatuses []ServiceStatus + type ServiceStatus struct + HealthCheckDuration int + InstanceStatuses []InstanceStatus + Replica int + ServiceName string + ServiceStatus string + type SetCallbackFn func(string) error + type WindowStatus struct