client

Documentation

Index

• Variables
• type MQClient
  • func NewMqClient(etcdendpoints []string, defaultserver string) (MQClient, error)
• type TaskStruct

Variables

var BuilderTopic = "builder"

BuilderTopic builder for linux

var WindowsBuilderTopic = "windows_builder"

WindowsBuilderTopic builder for windows

var WorkerTopic = "worker"

WorkerTopic worker topic

Types

type MQClient

type MQClient interface {
	pb.TaskQueueClient
	Close()
	SendBuilderTopic(t TaskStruct) error
}

MQClient mq client

func NewMqClient

func NewMqClient(etcdendpoints []string, defaultserver string) (MQClient, error)

NewMqClient new a mq client

type TaskStruct

type TaskStruct struct {
	Topic    string
	TaskType string
	TaskBody interface{}
}

TaskStruct task struct