cloudpods/pkg/cloudcommon/notifyclient/events.go

// Copyright 2019 Yunion
//
// 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
//
//     http://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 notifyclient

import (
	"fmt"
	"strings"

	"yunion.io/x/onecloud/pkg/cloudcommon/db"
)

const (
	SYSTEM_ERROR   = "SYSTEM_ERROR"
	SYSTEM_WARNING = "SYSTEM_WARNING"

	SERVER_CREATED       = "SERVER_CREATED"
	SERVER_CREATED_ADMIN = "SERVER_CREATED_ADMIN"
	SERVER_DELETED       = "SERVER_DELETED"
	SERVER_DELETED_ADMIN = "SERVER_DELETED_ADMIN"
	SERVER_REBUILD_ROOT  = "SERVER_REBUILD_ROOT"
	SERVER_CHANGE_FLAVOR = "SERVER_CHANGE_FLAVOR"
	SERVER_PANICKED      = "SERVER_PANICKED"

	IMAGE_ACTIVED = "IMAGE_ACTIVED"
)

type SAction string

var (
	Event SEvent

	ActionCreate       SAction = "create"
	ActionUpdate       SAction = "update"
	ActionDelete       SAction = "delete"
	ActionRebuildRoot  SAction = "rebuild_root"
	ActionChangeConfig SAction = "change_config"
)

type SEvent struct {
	resourceType string
	action       SAction
}

func (se SEvent) WithResourceType(manager db.IModelManager) SEvent {
	se.resourceType = manager.Keyword()
	return se
}

func (se SEvent) WithAction(a SAction) SEvent {
	se.action = a
	return se
}

func (se SEvent) ResourceType() string {
	return se.resourceType
}

func (se SEvent) Action() string {
	return string(se.action)
}

func (se SEvent) String() string {
	return strings.ToUpper(fmt.Sprintf("%s_%s", se.ResourceType(), se.Action()))
}