events

Documentation

Index

• Constants
• func Event(kr map[string]contracts.Kind, event Events, node uint64)
• func Handle(platform string, shared *shared.Shared, msg interface{})
• func HandleChange(shared *containerShared.Shared, event Events, node uint64)
• func HandleConnect(shared *shared.Shared, container platforms.IContainer, ...)
• func HandleDelete(shared *containerShared.Shared, event Events, node uint64)
• 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 HandleRefresh(shared *gitopsShared.Shared, event Events, node uint64)
• func HandleRestart(shared *containerShared.Shared, event Events, node uint64)
• func HandleStart(shared *shared.Shared, container platforms.IContainer, ...)
• func HandleStop(shared *shared.Shared, container platforms.IContainer, ...)
• func HandleSync(shared *gitopsShared.Shared, event Events, node uint64)
• func NewEventsListener(kr map[string]contracts.Kind, e chan KV.KV)
• func NewPlatformEventsListener(shared *shared.Shared, platform string)
• type Events
  • func New(event string, 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_REFRESH = "refresh"

const EVENT_RESTART = "restart"

const EVENT_STOP = "stop"

const EVENT_SYNC = "sync"

Functions

func Event

func Event(kr map[string]contracts.Kind, event Events, node uint64)

func Handle

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

func HandleChange

func HandleChange(shared *containerShared.Shared, event Events, node uint64)

func HandleConnect

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

func HandleDelete

func HandleDelete(shared *containerShared.Shared, event Events, node uint64)

func HandleDie

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

func HandleDisconnect

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

func HandleKill

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

func HandleRefresh

func HandleRefresh(shared *gitopsShared.Shared, event Events, node uint64)

func HandleRestart

func HandleRestart(shared *containerShared.Shared, event Events, node uint64)

func HandleStart

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

func HandleStop

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

func HandleSync

func HandleSync(shared *gitopsShared.Shared, event Events, node uint64)

func NewEventsListener

func NewEventsListener(kr map[string]contracts.Kind, e chan KV.KV)

func NewPlatformEventsListener

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

Types

type Events

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

func New

func New(event string, 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)