gleam

README

gLeam

gLeam witch works with mqtt is a cluster for executing customised tasks.

Installing & Running

Authors

• Xing Xing mikespook@gmail.com Blog @Twitter

Open Source - MIT Software License

See LICENSE.

Documentation

Index

• Constants
• type Config
• type ConfigMQTT
• type ConfigSchedule
• type ConfigTask
• type Gleam
  • func NewGleam(workdir string) *Gleam
  • func (g *Gleam) Final() error
  • func (g *Gleam) Init() error
  • func (g *Gleam) Serve()

Constants

const (
	TopicAll        = ""
	TopicIndividual = "i"
	TopicBroadcast  = "b"
)

const (
	MessageFunc        = "onDefaultMessage"
	ErrorFunc          = "onError"
	InitFunc           = "init"
	AfterInitFunc      = "afterInit"
	BeforeFinalizeFunc = "beforeFinalize"
	FinalizeFunc       = "finalize"

	LogFunc  = "log"
	LogfFunc = "logf"

	ConfigVar = "config"

	LuaCallStackSize       = 1024
	LuaIncludeGoStackTrace = true
	LuaRegistrySize        = 1024 * 64
	LuaSkipOpenLibs        = false

	BootstrapFile = "bootstrap.lua"
)

Types

type Config

type Config struct {
	ClientId  string
	FinalTick time.Duration

	MQTT         []ConfigMQTT
	NotVerifyTLS bool

	Tasks    map[string]ConfigTask
	Schedule ConfigSchedule
}

type ConfigMQTT

type ConfigMQTT struct {
	Addr     string
	Username string
	Password string
}

type ConfigSchedule

type ConfigSchedule struct {
	Tick  time.Duration
	Tasks map[string]time.Duration
}

type ConfigTask

type ConfigTask map[string]byte

type Gleam

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

func NewGleam

func NewGleam(workdir string) *Gleam

func (*Gleam) Final

func (g *Gleam) Final() error

func (*Gleam) Init

func (g *Gleam) Init() error

func (*Gleam) Serve

func (g *Gleam) Serve()