本文整理汇总了Golang中github.com/mesos/mesos-go/mesosutil.NewExecutorID函数的典型用法代码示例。如果您正苦于以下问题:Golang NewExecutorID函数的具体用法?Golang NewExecutorID怎么用?Golang NewExecutorID使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了NewExecutorID函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: prepareExecutorInfo
func prepareExecutorInfo(id string) *mesos.ExecutorInfo {
executorUris := []*mesos.CommandInfo_URI{}
executorUris = append(executorUris, &mesos.CommandInfo_URI{Value: execUri, Executable: proto.Bool(true)})
// forward the value of the scheduler's -v flag to the executor
v := 0
if f := flag.Lookup("v"); f != nil && f.Value != nil {
if vstr := f.Value.String(); vstr != "" {
if vi, err := strconv.ParseInt(vstr, 10, 32); err == nil {
v = int(vi)
}
}
}
executorCommand := fmt.Sprintf("./%s -logtostderr=true -v=%d", execCmd, v)
go http.ListenAndServe(fmt.Sprintf("%s:%d", *address, *artifactPort), nil)
log.V(2).Info("Serving executor artifacts...")
// Create mesos scheduler driver.
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID(id),
Name: proto.String("Test Executor (Go)"),
Source: proto.String("go_test"),
Command: &mesos.CommandInfo{
Value: proto.String(executorCommand),
Uris: executorUris,
},
}
}
开发者ID:cebufooddroid,项目名称:mesos-go,代码行数:29,代码来源:main.go
示例2: prepareExecutorInfo
func prepareExecutorInfo(gt net.Addr) *mesos.ExecutorInfo {
executorUris := []*mesos.CommandInfo_URI{}
uri := serveSelf()
executorUris = append(executorUris, &mesos.CommandInfo_URI{Value: uri, Executable: proto.Bool(true)})
// forward the value of the scheduler's -v flag to the executor
v := 0
if f := flag.Lookup("v"); f != nil && f.Value != nil {
if vstr := f.Value.String(); vstr != "" {
if vi, err := strconv.ParseInt(vstr, 10, 32); err == nil {
v = int(vi)
}
}
}
nodeCommand := fmt.Sprintf("./executor -logtostderr=true -v=%d -node -tracerAddr %s", v, gt.String())
log.V(2).Info("nodeCommand: ", nodeCommand)
// Create mesos scheduler driver.
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID("default"),
Name: proto.String("visghs-node"),
Source: proto.String("visghs"),
Command: &mesos.CommandInfo{
Value: proto.String(nodeCommand),
Uris: executorUris,
},
Resources: []*mesos.Resource{
util.NewScalarResource("cpus", CPUS_PER_EXECUTOR),
util.NewScalarResource("mem", MEM_PER_EXECUTOR),
},
}
}
开发者ID:tcolgate,项目名称:radia,代码行数:32,代码来源:main.go
示例3: createExecutor
func (s *Scheduler) createExecutor(offer *mesos.Offer, tcpPort uint64, udpPort uint64) *mesos.ExecutorInfo {
name := fmt.Sprintf("syslog-%s", offer.GetSlaveId().GetValue())
id := fmt.Sprintf("%s-%s", name, uuid())
uris := []*mesos.CommandInfo_URI{
&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("%s/resource/%s", Config.Api, Config.Executor)),
Executable: proto.Bool(true),
},
}
if Config.ProducerProperties != "" {
uris = append(uris, &mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("%s/resource/%s", Config.Api, Config.ProducerProperties)),
})
}
command := fmt.Sprintf("./%s --log.level %s --tcp %d --udp %d --host %s", Config.Executor, Config.LogLevel, tcpPort, udpPort, offer.GetHostname())
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID(id),
Name: proto.String(name),
Command: &mesos.CommandInfo{
Value: proto.String(command),
Uris: uris,
},
}
}
开发者ID:elodina,项目名称:syslog-service,代码行数:28,代码来源:scheduler.go
示例4: createExecutor
func (s *Scheduler) createExecutor(hostname string) *mesos.ExecutorInfo {
id := fmt.Sprintf("statsd-kafka-%s", hostname)
uris := []*mesos.CommandInfo_URI{
&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("%s/resource/%s", Config.Api, Config.Executor)),
Executable: proto.Bool(true),
},
}
if Config.ProducerProperties != "" {
uris = append(uris, &mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("%s/resource/%s", Config.Api, Config.ProducerProperties)),
})
}
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID(id),
Name: proto.String(id),
Command: &mesos.CommandInfo{
Value: proto.String(fmt.Sprintf("./%s --log.level %s --host %s", Config.Executor, Config.LogLevel, hostname)),
Uris: uris,
},
}
}
开发者ID:elodina,项目名称:statsd-mesos-kafka,代码行数:25,代码来源:scheduler.go
示例5: createExecutor
func (this *ElodinaTransportScheduler) createExecutor(instanceId int, port uint64) *mesos.ExecutorInfo {
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID(fmt.Sprintf("elodina-mirror-%d", instanceId)),
Name: proto.String("Elodina Mirror Executor"),
Source: proto.String("Elodina"),
Command: &mesos.CommandInfo{
Value: proto.String(fmt.Sprintf("./%s --port %d --ssl.cert %s --ssl.key %s --ssl.cacert %s --api.key %s --api.user %s --target.url %s --insecure %v",
this.config.ExecutorBinaryName, port, this.config.SSLCertFilePath, this.config.SSLKeyFilePath, this.config.SSLCACertFilePath, this.config.ApiKey, this.config.ApiUser, this.config.TargetURL, this.config.Insecure)),
Uris: []*mesos.CommandInfo_URI{&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("http://%s:%d/resource/%s", this.config.ServiceHost, this.config.ServicePort, this.config.ExecutorBinaryName)),
Executable: proto.Bool(true),
},
&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("http://%s:%d/resource/%s", this.config.ServiceHost, this.config.ServicePort, this.config.SSLCertFilePath)),
Executable: proto.Bool(false),
Extract: proto.Bool(false),
},
&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("http://%s:%d/resource/%s", this.config.ServiceHost, this.config.ServicePort, this.config.SSLKeyFilePath)),
Executable: proto.Bool(false),
Extract: proto.Bool(false),
},
&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("http://%s:%d/resource/%s", this.config.ServiceHost, this.config.ServicePort, this.config.SSLCACertFilePath)),
Executable: proto.Bool(false),
Extract: proto.Bool(false),
}},
},
}
}
开发者ID:elodina,项目名称:syphon,代码行数:30,代码来源:scheduler.go
示例6: TestSchdulerDriverSendFrameworkMessage
func (suite *SchedulerTestSuite) TestSchdulerDriverSendFrameworkMessage() {
messenger := messenger.NewMockedMessenger()
messenger.On("Start").Return(nil)
messenger.On("UPID").Return(&upid.UPID{})
messenger.On("Send").Return(nil)
messenger.On("Stop").Return(nil)
messenger.On("Route").Return(nil)
driver, err := newTestSchedulerDriver(NewMockScheduler(), suite.framework, suite.master, nil)
driver.messenger = messenger
suite.NoError(err)
suite.True(driver.Stopped())
driver.Start()
driver.setConnected(true) // simulated
suite.Equal(mesos.Status_DRIVER_RUNNING, driver.Status())
stat, err := driver.SendFrameworkMessage(
util.NewExecutorID("test-exec-001"),
util.NewSlaveID("test-slave-001"),
"Hello!",
)
suite.NoError(err)
suite.Equal(mesos.Status_DRIVER_RUNNING, stat)
}
开发者ID:nagyistoce,项目名称:ms-docker-swarm,代码行数:25,代码来源:scheduler_unit_test.go
示例7: createExecutor
func (ct *ConsumerTask) createExecutor() *mesos.ExecutorInfo {
executor, err := ct.Config.GetString("executor")
if err != nil || executor == "" {
fmt.Println("Executor name required")
return nil
}
id := fmt.Sprintf("consumer-%s", ct.ID)
uris := []*mesos.CommandInfo_URI{
&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("%s/resource/%s", Config.Api, executor)),
Executable: proto.Bool(true),
},
}
paramNames := []string{"brokers", "topics", "partitions", "cassandra", "keyspace", "schema"}
params := make([]string, 0)
for _, name := range paramNames {
params = append(params, ct.makeParam(name))
}
paramString := strings.Join(params, " ")
Logger.Debugf("Launching executor with params %s", paramString)
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID(id),
Name: proto.String("kafka-consumer"),
Command: &mesos.CommandInfo{
Value: proto.String(fmt.Sprintf("./%s --log.level %s --type %s %s", executor, Config.LogLevel, TaskTypeConsumer, paramString)),
Uris: uris,
},
}
}
开发者ID:elodina,项目名称:go-kafka-client-mesos,代码行数:34,代码来源:consumer_task.go
示例8: createExecutor
func (mm *MirrorMakerTask) createExecutor() *mesos.ExecutorInfo {
executor, err := mm.Config.GetString("executor")
if err != nil || executor == "" {
fmt.Println("Executor name required")
return nil
}
id := fmt.Sprintf("mirrormaker-%s", mm.ID)
uris := []*mesos.CommandInfo_URI{
&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("%s/resource/%s", Config.Api, executor)),
Executable: proto.Bool(true),
},
toURI(mm.Config["producer.config"]),
}
for _, consumerConfig := range strings.Split(mm.Config["consumer.config"], ",") {
uris = append(uris, toURI(consumerConfig))
}
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID(id),
Name: proto.String(id),
Command: &mesos.CommandInfo{
Value: proto.String(fmt.Sprintf("./%s --log.level %s --type %s", executor, Config.LogLevel, TaskTypeMirrorMaker)),
Uris: uris,
},
}
}
开发者ID:elodina,项目名称:go-kafka-client-mesos,代码行数:29,代码来源:mirror_maker_task.go
示例9: prepareExecutorInfo
func prepareExecutorInfo() *mesos.ExecutorInfo {
executorUris := []*mesos.CommandInfo_URI{}
uri, executorCmd := serveExecutorArtifact(*executorPath)
executorUris = append(executorUris, &mesos.CommandInfo_URI{Value: uri, Executable: proto.Bool(true)})
// forward the value of the scheduler's -v flag to the executor
v := 0
if f := flag.Lookup("v"); f != nil && f.Value != nil {
if vstr := f.Value.String(); vstr != "" {
if vi, err := strconv.ParseInt(vstr, 10, 32); err == nil {
v = int(vi)
}
}
}
executorCommand := fmt.Sprintf("./%s -logtostderr=true -v=%d -slow_tasks=%v", executorCmd, v, *slowTasks)
go http.ListenAndServe(fmt.Sprintf("%s:%d", *address, *artifactPort), nil)
log.V(2).Info("Serving executor artifacts...")
// Create mesos scheduler driver.
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID("default"),
Name: proto.String("Test Executor (Go)"),
Source: proto.String("go_test"),
Command: &mesos.CommandInfo{
Value: proto.String(executorCommand),
Uris: executorUris,
},
Resources: []*mesos.Resource{
util.NewScalarResource("cpus", CPUS_PER_EXECUTOR),
util.NewScalarResource("mem", MEM_PER_EXECUTOR),
},
}
}
开发者ID:elodina,项目名称:stack-deploy,代码行数:34,代码来源:main.go
示例10: executorRefs
// executorRefs returns a slice of known references to running executors known to this framework
func (k *framework) executorRefs() []executorRef {
slaves := k.slaveHostNames.SlaveIDs()
refs := make([]executorRef, 0, len(slaves))
for _, slaveID := range slaves {
hostname := k.slaveHostNames.HostName(slaveID)
if hostname == "" {
log.Warningf("hostname lookup for slaveID %q failed", slaveID)
continue
}
node := k.lookupNode(hostname)
if node == nil {
log.Warningf("node lookup for slaveID %q failed", slaveID)
continue
}
eid, ok := node.Annotations[meta.ExecutorIdKey]
if !ok {
log.Warningf("unable to find %q annotation for node %v", meta.ExecutorIdKey, node)
continue
}
refs = append(refs, executorRef{
executorID: mutil.NewExecutorID(eid),
slaveID: mutil.NewSlaveID(slaveID),
})
}
return refs
}
开发者ID:robertabbott,项目名称:kubernetes,代码行数:32,代码来源:framework.go
示例11: prepareExecutorInfo
func prepareExecutorInfo() *mesos.ExecutorInfo {
containerType := mesos.ContainerInfo_DOCKER
containerNetwork := mesos.ContainerInfo_DockerInfo_HOST
vcapDataVolumeMode := mesos.Volume_RW
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID("diego-executor"),
Name: proto.String("Diego Executor"),
Source: proto.String("diego-executor"),
Container: &mesos.ContainerInfo{
Type: &containerType,
Volumes: []*mesos.Volume{
&mesos.Volume{
Mode: &vcapDataVolumeMode,
ContainerPath: proto.String("/var/vcap/data"),
HostPath: proto.String("data"),
},
&mesos.Volume{
Mode: &vcapDataVolumeMode,
ContainerPath: proto.String("/var/vcap/sys/log"),
HostPath: proto.String("log"),
},
&mesos.Volume{
Mode: &vcapDataVolumeMode,
ContainerPath: proto.String("/sys/fs/cgroup"),
HostPath: proto.String("/sys/fs/cgroup"),
},
},
Docker: &mesos.ContainerInfo_DockerInfo{
Image: executorImage,
Network: &containerNetwork,
Privileged: proto.Bool(true),
ForcePullImage: proto.Bool(true),
},
},
Command: &mesos.CommandInfo{
Environment: &mesos.Environment{
Variables: []*mesos.Environment_Variable{
&mesos.Environment_Variable{
Name: proto.String("CONSUL_SERVER"),
Value: consulServer,
},
&mesos.Environment_Variable{
Name: proto.String("ETCD_URL"),
Value: etcdUrl,
},
},
},
Shell: proto.Bool(false),
User: proto.String("root"),
Value: proto.String("/executor"),
Arguments: []string{"-logtostderr=true"},
},
}
}
开发者ID:accelazh,项目名称:cloudfoundry-mesos,代码行数:55,代码来源:init.go
示例12: startScheduler
func startScheduler() (reflex *scheduler.ReflexScheduler, start func()) {
exec := &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID("default"),
Name: proto.String("BH executor (Go)"),
Source: proto.String("bh_test"),
Command: &mesos.CommandInfo{
Value: proto.String(""),
Uris: []*mesos.CommandInfo_URI{},
},
}
fwinfo := &mesos.FrameworkInfo{
User: proto.String(""),
Name: proto.String("reflex"),
}
// skipping creds for now...
// cred := (*mesos.Credential)(nil)
// if *mesosAuthPrincipal != "" {
// fwinfo.Principal = proto.String(*mesosAuthPrincipal)
// secret, err := ioutil.ReadFile(*mesosAuthSecretFile)
// if err != nil {
// logrus.WithField("error", err).Fatal("failed reading secret file")
// }
// cred = &mesos.Credential{
// Principal: proto.String(*mesosAuthPrincipal),
// Secret: secret,
// }
// }
reflex = scheduler.NewScheduler(exec)
config := sched.DriverConfig{
Scheduler: reflex,
Framework: fwinfo,
Master: "127.0.0.1:5050", // TODO: grab this from somewhere
// Credential: cred,
}
start = func() {
driver, err := sched.NewMesosSchedulerDriver(config)
if err != nil {
logrus.WithField("error", err).Fatal("unable to create a SchedulerDriver")
}
if stat, err := driver.Run(); err != nil {
logrus.WithFields(logrus.Fields{
"status": stat.String(),
"error": err,
}).Info("framework stopped")
}
}
return reflex, start
}
开发者ID:asteris-llc,项目名称:reflex,代码行数:54,代码来源:main.go
示例13: prepareExecutorInfo
func prepareExecutorInfo() *mesos.ExecutorInfo {
// Create mesos scheduler driver.
containerType := mesos.ContainerInfo_DOCKER
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID("default"),
Name: proto.String("mesos-runonce-executor"),
Source: proto.String("mesos-runonce-executor"),
Container: &mesos.ContainerInfo{
Type: &containerType,
},
}
}
开发者ID:yp-engineering,项目名称:mesos-runonce,代码行数:12,代码来源:main.go
示例14: TestSchdulerDriverAcceptOffersWithError
func (suite *SchedulerTestSuite) TestSchdulerDriverAcceptOffersWithError() {
sched := mock_scheduler.New()
sched.On("StatusUpdate").Return(nil)
sched.On("Error").Return()
msgr := mockedMessenger()
driver := newTestDriver(suite.T(), driverConfigMessenger(sched, suite.framework, suite.master, nil, msgr))
driver.OnDispatch(func(_ context.Context, _ *upid.UPID, _ proto.Message) error {
return fmt.Errorf("Unable to send message")
})
go func() {
driver.Run()
}()
<-driver.Started()
driver.SetConnected(true) // simulated
suite.True(driver.Running())
// setup an offer
offer := util.NewOffer(
util.NewOfferID("test-offer-001"),
suite.framework.Id,
util.NewSlaveID("test-slave-001"),
"test-slave(1)@localhost:5050",
)
pid, err := upid.Parse("test-slave(1)@localhost:5050")
suite.NoError(err)
driver.CacheOffer(offer, pid)
// launch task
task := util.NewTaskInfo(
"simple-task",
util.NewTaskID("simpe-task-1"),
util.NewSlaveID("test-slave-001"),
[]*mesos.Resource{util.NewScalarResourceWithReservation("mem", 400, "principal", "role")},
)
task.Command = util.NewCommandInfo("pwd")
task.Executor = util.NewExecutorInfo(util.NewExecutorID("test-exec"), task.Command)
tasks := []*mesos.TaskInfo{task}
operations := []*mesos.Offer_Operation{util.NewLaunchOperation(tasks)}
stat, err := driver.AcceptOffers(
[]*mesos.OfferID{offer.Id},
operations,
&mesos.Filters{},
)
suite.Equal(mesos.Status_DRIVER_RUNNING, stat)
suite.Error(err)
}
开发者ID:elodina,项目名称:stack-deploy,代码行数:51,代码来源:scheduler_unit_test.go
示例15: TestSchdulerDriverSendFrameworkMessage
func (suite *SchedulerTestSuite) TestSchdulerDriverSendFrameworkMessage() {
driver := newTestDriver(suite.T(), driverConfigMessenger(mock_scheduler.New(), suite.framework, suite.master, nil, mockedMessenger()))
driver.Start()
driver.SetConnected(true) // simulated
suite.Equal(mesos.Status_DRIVER_RUNNING, driver.Status())
stat, err := driver.SendFrameworkMessage(
util.NewExecutorID("test-exec-001"),
util.NewSlaveID("test-slave-001"),
"Hello!",
)
suite.NoError(err)
suite.Equal(mesos.Status_DRIVER_RUNNING, stat)
}
开发者ID:elodina,项目名称:stack-deploy,代码行数:15,代码来源:scheduler_unit_test.go
示例16: TestSchedulerDriverFrameworkMessageEvent
func (suite *SchedulerIntegrationTestSuite) TestSchedulerDriverFrameworkMessageEvent() {
ok := suite.configureServerWithRegisteredFramework()
suite.True(ok, "failed to establish running test server and driver")
// Send a event to this SchedulerDriver (via http) to test handlers. offer := util.NewOffer(
pbMsg := &mesos.ExecutorToFrameworkMessage{
SlaveId: util.NewSlaveID("test-slave-001"),
FrameworkId: suite.registeredFrameworkId,
ExecutorId: util.NewExecutorID("test-executor-001"),
Data: []byte("test-data-999"),
}
c := suite.newMockClient()
c.SendMessage(suite.driver.UPID(), pbMsg)
suite.sched.waitForCallback(0)
}
开发者ID:elodina,项目名称:stack-deploy,代码行数:16,代码来源:scheduler_intgr_test.go
示例17: main
func main() {
var master = flag.String("master", "127.0.0.1:5050", "Master address <ip:port>")
log.Infoln("Lancement PGAgentScheduler") //, time.Now())
flag.Parse()
config := scheduler.DriverConfig{
Master: *master,
Scheduler: forbin.NewDatabaseScheduler(
&mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID("default"),
Name: proto.String("FBN"),
Source: proto.String("fb_test"),
Command: &mesos.CommandInfo{
Value: proto.String(CMD),
Uris: []*mesos.CommandInfo_URI{
&mesos.CommandInfo_URI{
Value: proto.String("http://localhost:8080/postgresql-bin.tar.gz"),
Extract: proto.Bool(true),
},
&mesos.CommandInfo_URI{
Value: proto.String("http://localhost:8080/tools.tar.gz"),
Extract: proto.Bool(true),
},
}},
},
),
Framework: &mesos.FrameworkInfo{
Name: proto.String(NAME),
User: proto.String(""),
},
}
driver, err := scheduler.NewMesosSchedulerDriver(config)
if err != nil {
log.Fatalln("Unable to create a SchedulerDriver ", err.Error())
}
if stat, err := driver.Run(); err != nil {
log.Infoln("Framework stopped with status %s and error: %s\n", stat.String(), err.Error())
}
}
开发者ID:lionelg3,项目名称:Forbin,代码行数:45,代码来源:main.go
示例18: prepareExecutorInfo
func prepareExecutorInfo(uri string, cmd string) *mesos.ExecutorInfo {
executorUris := []*mesos.CommandInfo_URI{
{
Value: &uri,
Executable: proto.Bool(true),
},
}
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID("default"),
Name: proto.String("Test Executor (Go)"),
Source: proto.String("go_test"),
Command: &mesos.CommandInfo{
Value: proto.String(cmd),
Uris: executorUris,
},
}
}
开发者ID:EMC-CMD,项目名称:test-framework,代码行数:18,代码来源:main.go
示例19: createExecutor
func (this *TransformScheduler) createExecutor(instanceId int32, port uint64) *mesos.ExecutorInfo {
path := strings.Split(this.config.ExecutorArchiveName, "/")
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID(fmt.Sprintf("transform-%d", instanceId)),
Name: proto.String("LogLine Transform Executor"),
Source: proto.String("cisco"),
Command: &mesos.CommandInfo{
Value: proto.String(fmt.Sprintf("./%s --producer.config %s --topic %s --port %d --sync %t",
this.config.ExecutorBinaryName, this.config.ProducerConfig, this.config.Topic, port, this.config.Sync)),
Uris: []*mesos.CommandInfo_URI{&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("http://%s:%d/resource/%s", this.config.ArtifactServerHost, this.config.ArtifactServerPort, path[len(path)-1])),
Extract: proto.Bool(true),
}, &mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("http://%s:%d/resource/%s", this.config.ArtifactServerHost, this.config.ArtifactServerPort, this.config.ProducerConfig)),
}},
},
}
}
开发者ID:stealthly,项目名称:edge-test,代码行数:18,代码来源:scheduler.go
示例20: createExecutor
func (s *Scheduler) createExecutor(slave string) *mesos.ExecutorInfo {
id := fmt.Sprintf("syscol-%s", slave)
return &mesos.ExecutorInfo{
ExecutorId: util.NewExecutorID(id),
Name: proto.String(id),
Command: &mesos.CommandInfo{
Value: proto.String(fmt.Sprintf("./%s --log.level %s", Config.Executor, Config.LogLevel)),
Uris: []*mesos.CommandInfo_URI{
&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("%s/resource/%s", Config.Api, Config.Executor)),
Executable: proto.Bool(true),
},
&mesos.CommandInfo_URI{
Value: proto.String(fmt.Sprintf("%s/resource/%s", Config.Api, Config.ProducerProperties)),
},
},
},
}
}
开发者ID:elodina,项目名称:syscol,代码行数:19,代码来源:scheduler.go
注:本文中的github.com/mesos/mesos-go/mesosutil.NewExecutorID函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论