event

Documentation

Index

• Constants
• Variables
• type AbstractHandler
  • func (h *AbstractHandler) EventHandleFunc(handler IHandler) EventHandleFunc
• type CreateVmHandler
  • func (h *CreateVmHandler) HandlerEvent(e *VmRequest)
  • func (h *CreateVmHandler) Name() string
• type DestroyVmHandler
  • func (h *DestroyVmHandler) HandlerEvent(e *VmRequest)
  • func (h *DestroyVmHandler) Name() string
• type EventBus
  • func (me *EventBus) Pub(e string, args interface{})
  • func (me *EventBus) Sub(e string, id string, handleFunc EventHandleFunc)
  • func (me *EventBus) Unsub(e string, id string)
• type EventContext
  • func (ec *EventContext) GetConfig() *config.Config
• type EventHandleFunc
• type EventHandler
• type EventService
  • func (s *EventService) Create(req *VmRequest)
  • func (s *EventService) Destroy(req *VmRequest)
  • func (s *EventService) Recover(req *VmRequest)
  • func (s *EventService) Renew(req *VmRequest)
• type IEventBus
• type IEventService
  • func NewEventService(coreContext *EventContext) IEventService
• type IHandler
• type IVmEventHandler
• type OperationTag
• type RecoverVmHandler
  • func (h *RecoverVmHandler) HandlerEvent(e *VmRequest)
  • func (h *RecoverVmHandler) Name() string
• type RenewVmHandler
  • func (h *RenewVmHandler) HandlerEvent(e *VmRequest)
  • func (h *RenewVmHandler) Name() string
• type TheGraphHandler
  • func (h *TheGraphHandler) HandlerEvent(e *VmRequest)
  • func (h *TheGraphHandler) Name() string
• type VmRequest

Constants

const ResourceOrder_CreateOrderSuccess = "resource.create_order.cmd"

const ResourceOrder_ReNewOrderSuccess = "resource.renew_order.cmd"

const ResourceOrder_Recover = "resource.recover_order.cmd"

const ResourceOrder_TheGraph = "resource.thegraph"

const ResourceOrder_WithdrawLockedOrderPriceSuccess = "resource.cancel_order.cmd"

Variables

var GlobalEventBus = newEventBus()

Types

type AbstractHandler

type AbstractHandler struct {
}

func (*AbstractHandler) EventHandleFunc

func (h *AbstractHandler) EventHandleFunc(handler IHandler) EventHandleFunc

type CreateVmHandler

type CreateVmHandler struct {
	AbstractHandler
	CoreContext *EventContext
}

func (*CreateVmHandler) HandlerEvent

func (h *CreateVmHandler) HandlerEvent(e *VmRequest)

func (*CreateVmHandler) Name

func (h *CreateVmHandler) Name() string

type DestroyVmHandler

type DestroyVmHandler struct {
	AbstractHandler
	CoreContext *EventContext
}

func (*DestroyVmHandler) HandlerEvent

func (h *DestroyVmHandler) HandlerEvent(e *VmRequest)

func (*DestroyVmHandler) Name

func (h *DestroyVmHandler) Name() string

type EventBus

type EventBus struct {
	// contains filtered or unexported fields
}

func (*EventBus) Pub

func (me *EventBus) Pub(e string, args interface{})

func (*EventBus) Sub

func (me *EventBus) Sub(e string, id string, handleFunc EventHandleFunc)

func (*EventBus) Unsub

func (me *EventBus) Unsub(e string, id string)

type EventContext

type EventContext struct {
	ReportClient chain.ReportClient
	VmManager    provider.Manager
	TimerService *utils.TimerService
	Cm           *config.ConfigManager
	P2pClient    *p2p.P2pClient
}

func (*EventContext) GetConfig

func (ec *EventContext) GetConfig() *config.Config

type EventHandleFunc

type EventHandleFunc func(e string, args interface{})

type EventHandler

type EventHandler struct {
	ID      string
	Handler EventHandleFunc
}

type EventService

type EventService struct {
	// contains filtered or unexported fields
}

func (*EventService) Create

func (s *EventService) Create(req *VmRequest)

func (*EventService) Destroy

func (s *EventService) Destroy(req *VmRequest)

func (*EventService) Recover

func (s *EventService) Recover(req *VmRequest)

func (*EventService) Renew

func (s *EventService) Renew(req *VmRequest)

type IEventBus

type IEventBus interface {
	Pub(e string, args interface{})
	Sub(e string, id string, handleFunc EventHandleFunc)
	Unsub(e string, id string)
}

type IEventService

type IEventService interface {
	Create(r *VmRequest)
	Destroy(r *VmRequest)
	Renew(r *VmRequest)
	Recover(r *VmRequest)
}

func NewEventService

func NewEventService(coreContext *EventContext) IEventService

type IHandler

type IHandler interface {
	Name() string
	HandlerEvent(e *VmRequest)
}

type IVmEventHandler

type IVmEventHandler interface {
	EventHandleFunc(e string, args interface{})
}

type OperationTag

type OperationTag int

const OPCreatedVm OperationTag = 1

const OPDestroyVm OperationTag = 2

const OPFreeResourceApply OperationTag = 5

const OPRecoverVM OperationTag = 4

const OPRenewVM OperationTag = 3

type RecoverVmHandler

type RecoverVmHandler struct {
	AbstractHandler
	CoreContext *EventContext
}

func (*RecoverVmHandler) HandlerEvent

func (h *RecoverVmHandler) HandlerEvent(e *VmRequest)

func (*RecoverVmHandler) Name

func (h *RecoverVmHandler) Name() string

type RenewVmHandler

type RenewVmHandler struct {
	AbstractHandler
	CoreContext *EventContext
}

func (*RenewVmHandler) HandlerEvent

func (h *RenewVmHandler) HandlerEvent(e *VmRequest)

func (*RenewVmHandler) Name

func (h *RenewVmHandler) Name() string

type TheGraphHandler

type TheGraphHandler struct {
	AbstractHandler
	CoreContext *EventContext
}

func (*TheGraphHandler) HandlerEvent

func (h *TheGraphHandler) HandlerEvent(e *VmRequest)

func (*TheGraphHandler) Name

func (h *TheGraphHandler) Name() string

type VmRequest

type VmRequest struct {
	Tag         OperationTag
	Cpu         uint64
	Mem         uint64
	Disk        uint64
	AccessPort  uint64
	Type        string
	Image       string
	System      string
	PublicKey   string
	OrderNo     uint64
	AgreementNo uint64
	Duration    uint64
}