events

Documentation

Index

• Constants
• func Event(shared *shared.Shared, event Events)
• func Handle(platform string, shared *shared.Shared, msg interface{})
• func HandleChange(shared *shared.Shared, event Events)
• func HandleConnect(shared *shared.Shared, container platforms.IContainer)
• func HandleDelete(shared *shared.Shared, event Events)
• func HandleDie(shared *shared.Shared, container platforms.IContainer)
• func HandleDisconnect(shared *shared.Shared, container platforms.IContainer)
• func HandleKill(shared *shared.Shared, container platforms.IContainer)
• func HandleRestart(shared *shared.Shared, event Events)
• func HandleStart(shared *shared.Shared, container platforms.IContainer)
• func HandleStop(shared *shared.Shared, container platforms.IContainer)
• func NewEventsListener(shared *shared.Shared, e chan raft.KV)
• func NewPlatformEventsListener(shared *shared.Shared, platform string)
• type Events
  • func New(kind string, group string, name string, data []byte) Events
  • func (event *Events) GetKey() string
  • func (event *Events) ToJson() ([]byte, error)

Constants

const EVENT_CHANGE = "change"

const EVENT_DELETE = "delete"

const EVENT_RECREATE = "recreate"

const EVENT_RESTART = "restart"

const EVENT_STOP = "stop"

Functions

func Event

func Event(shared *shared.Shared, event Events)

func Handle

func Handle(platform string, shared *shared.Shared, msg interface{})

func HandleChange

func HandleChange(shared *shared.Shared, event Events)

func HandleConnect

func HandleConnect(shared *shared.Shared, container platforms.IContainer)

func HandleDelete

func HandleDelete(shared *shared.Shared, event Events)

func HandleDie

func HandleDie(shared *shared.Shared, container platforms.IContainer)

func HandleDisconnect

func HandleDisconnect(shared *shared.Shared, container platforms.IContainer)

func HandleKill

func HandleKill(shared *shared.Shared, container platforms.IContainer)

func HandleRestart

func HandleRestart(shared *shared.Shared, event Events)

func HandleStart

func HandleStart(shared *shared.Shared, container platforms.IContainer)

func HandleStop

func HandleStop(shared *shared.Shared, container platforms.IContainer)

func NewEventsListener

func NewEventsListener(shared *shared.Shared, e chan raft.KV)

func NewPlatformEventsListener

func NewPlatformEventsListener(shared *shared.Shared, platform string)

Types

type Events

type Events struct {
	Kind  string
	Group string
	Name  string
	Data  []byte
}

func New

func New(kind string, group string, name string, data []byte) Events

func (*Events) GetKey

func (event *Events) GetKey() string

func (*Events) ToJson

func (event *Events) ToJson() ([]byte, error)