utils

Documentation

Index

• Variables
• func ConnTCP(address string) (net.Conn, error)
• func ConnTLS(address string) (net.Conn, error)
• func DeleteCounter(client *docker.Client)
• func DeleteM1(cname string)
• func GetIp() (ip string, err error)
• func HttpGet(url string) (string, error)
• func ReceiveContainer(container *docker.Container)
• func Run()
• func SendMessage(cn, msg, cid string, container *gabs.Container)
• func ShortID(id string) string
• type Message

Variables

var (
	UUID      string
	M1        map[string]string
	IP        string
	Hostname  string
	UserId    string
	ClusterId string
)

Functions

func ConnTCP

func ConnTCP(address string) (net.Conn, error)

func ConnTLS

func ConnTLS(address string) (net.Conn, error)

func DeleteCounter

func DeleteCounter(client *docker.Client)

func DeleteM1

func DeleteM1(cname string)

func GetIp

func GetIp() (ip string, err error)

func HttpGet

func HttpGet(url string) (string, error)

func ReceiveContainer

func ReceiveContainer(container *docker.Container)

func Run

func Run()

func SendMessage

func SendMessage(cn, msg, cid string, container *gabs.Container)

func ShortID

func ShortID(id string) string

Types

type Message

type Message struct {
	FrameWorks []struct {
		Executors []struct {
			Container string `json:"container"`
			Tasks     []struct {
				SlaveId   string `json:"slave_id"`
				State     string `json:"state"`
				Name      string `json:"name"`
				Id        string `json:"id"`
				Resources struct {
					Ports string `json:"ports"`
				} `json:"resources"`
			} `json:"tasks"`
		} `json:"executors"`
	} `json:"frameworks"`
	HostName string `json:"hostname"`
}