bund

Documentation

Index

• Variables
• func AddShellCommand(name string, fun ShellCommand)
• func Agent()
• func Agitator()
• func AgitatorScheduleConfig()
• func BundEvalExpression(code string)
• func BundGlobalEvalExpression(code string)
• func CheckNewRelic()
• func CloseEtcdAgent()
• func CloseNatsAgent()
• func Config()
• func EtcdGetItems() *map[string]string
• func EtcdSetItem(key string, value string)
• func Eval()
• func EvalDisplayResult(core *stdlib.BUNDEnv)
• func Fin()
• func GlobalDisplayResult(core *stdlib.BUNDEnv)
• func HJsonLoadConfig(uri string) *map[string]interface{}
• func IfSTOP(msg *NRBundPacket) bool
• func IfSYNC(msg *NRBundPacket) bool
• func Init()
• func InitEtcdAgent(otype string)
• func InitNatsAgent()
• func InitNewRelicAgent()
• func IsShellCommand(name string) bool
• func Loop()
• func Main()
• func MakeScript(orole string, script []byte, args []interface{}) ([]byte, error)
• func MakeStop(orole string) ([]byte, error)
• func MakeSync(orole string) ([]byte, error)
• func Marshal(orole string, pktclass string, pktkey string, args []interface{}, value []byte) ([]byte, error)
• func NRBundAgent(m *nats.Msg)
• func NRBundExecuteScript(m *nats.Msg)
• func NatsRecv(fun nats.MsgHandler)
• func NatsRecvSys(fun nats.MsgHandler)
• func NatsSend(data []byte)
• func NatsSendSys(data []byte)
• func Run()
• func RunFile(core *stdlib.BUNDEnv, name string)
• func RunShellCommand(name string, core *tc.TCstate)
• func SendStop()
• func SendSync()
• func SetApplicationId(atype string)
• func Shell()
• func ShellCommandLast(core *tc.TCstate) interface{}
• func ShellCommandStack(core *tc.TCstate) interface{}
• func ShellCommandVersion(core *tc.TCstate) interface{}
• func ShellDisplayResult(core *tc.TCstate, show bool)
• func Stop()
• func Submit()
• func Sync()
• func SysQueueHandler(m *nats.Msg)
• func Take()
• func UpdateConfigToEtcd()
• func UpdateLocalConfigFromEtcd()
• func Version()
• func Watch()
• func WatchDisplay(m *nats.Msg)
• type NATSSync
  • func (s NATSSync) Run()
• type NRBundPacket
  • func UnMarshal(data []byte) *NRBundPacket
• type ShellCommand
• type TheScript
  • func (s TheScript) Run()

Variables

var ApplicationId string

var ApplicattionType string

var DoContinue bool

var Etcd *clientv3.Client

var HadSync bool

var NRapp newrelic.Application

var Nats *nats.Conn

var (
	PROMPT = "[ NRBUND ] "
)

var QueueName string

var SysQueueName string

Functions

func AddShellCommand

func AddShellCommand(name string, fun ShellCommand)

func Agent

func Agent()

func Agitator

func Agitator()

func AgitatorScheduleConfig

func AgitatorScheduleConfig()

func BundEvalExpression

func BundEvalExpression(code string)

func BundGlobalEvalExpression

func BundGlobalEvalExpression(code string)

func CheckNewRelic

func CheckNewRelic()

func CloseEtcdAgent

func CloseEtcdAgent()

func CloseNatsAgent

func CloseNatsAgent()

func Config

func Config()

func EtcdGetItems

func EtcdGetItems() *map[string]string

func EtcdSetItem

func EtcdSetItem(key string, value string)

func Eval

func Eval()

func EvalDisplayResult

func EvalDisplayResult(core *stdlib.BUNDEnv)

func Fin

func Fin()

func GlobalDisplayResult

func GlobalDisplayResult(core *stdlib.BUNDEnv)

func HJsonLoadConfig

func HJsonLoadConfig(uri string) *map[string]interface{}

func IfSTOP

func IfSTOP(msg *NRBundPacket) bool

func IfSYNC

func IfSYNC(msg *NRBundPacket) bool

func Init

func Init()

func InitEtcdAgent

func InitEtcdAgent(otype string)

func InitNatsAgent

func InitNatsAgent()

func InitNewRelicAgent

func InitNewRelicAgent()

func IsShellCommand

func IsShellCommand(name string) bool

func Loop

func Loop()

func Main

func Main()

func MakeScript

func MakeScript(orole string, script []byte, args []interface{}) ([]byte, error)

func MakeStop

func MakeStop(orole string) ([]byte, error)

func MakeSync

func MakeSync(orole string) ([]byte, error)

func Marshal

func Marshal(orole string, pktclass string, pktkey string, args []interface{}, value []byte) ([]byte, error)

func NRBundAgent

func NRBundAgent(m *nats.Msg)

func NRBundExecuteScript

func NRBundExecuteScript(m *nats.Msg)

func NatsRecv

func NatsRecv(fun nats.MsgHandler)

func NatsRecvSys

func NatsRecvSys(fun nats.MsgHandler)

func NatsSend

func NatsSend(data []byte)

func NatsSendSys

func NatsSendSys(data []byte)

func Run

func Run()

func RunFile

func RunFile(core *stdlib.BUNDEnv, name string)

func RunShellCommand

func RunShellCommand(name string, core *tc.TCstate)

func SendStop

func SendStop()

func SendSync

func SendSync()

func SetApplicationId

func SetApplicationId(atype string)

func Shell

func Shell()

func ShellCommandLast

func ShellCommandLast(core *tc.TCstate) interface{}

func ShellCommandStack

func ShellCommandStack(core *tc.TCstate) interface{}

func ShellCommandVersion

func ShellCommandVersion(core *tc.TCstate) interface{}

func ShellDisplayResult

func ShellDisplayResult(core *tc.TCstate, show bool)

func Stop

func Stop()

func Submit

func Submit()

func Sync

func Sync()

func SysQueueHandler

func SysQueueHandler(m *nats.Msg)

func Take

func Take()

func UpdateConfigToEtcd

func UpdateConfigToEtcd()

func UpdateLocalConfigFromEtcd

func UpdateLocalConfigFromEtcd()

func Version

func Version()

func Watch

func Watch()

func WatchDisplay

func WatchDisplay(m *nats.Msg)

Types

type NATSSync

type NATSSync struct {
}

func (NATSSync) Run

func (s NATSSync) Run()

type NRBundPacket

type NRBundPacket struct {
	Id       string
	PktId    string
	OrigName string
	OrgRole  string
	PktClass string
	PktKey   string
	Args     []interface{}
	Value    []byte
}

func UnMarshal

func UnMarshal(data []byte) *NRBundPacket

type ShellCommand

type ShellCommand func(*tc.TCstate) interface{}

type TheScript

type TheScript struct {
	Name string
	Uri  string
}

func (TheScript) Run

func (s TheScript) Run()