Golang domain.Task类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中deaagent/domain.Task类的典型用法代码示例。如果您正苦于以下问题：Golang Task类的具体用法？Golang Task怎么用？Golang Task使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了Task类的7个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: TestIdentifier

func TestIdentifier(t *testing.T) {
	task := domain.Task{
		ApplicationId:       "4aa9506e-277f-41ab-b764-a35c0b96fa1b",
		WardenJobId:         272,
		WardenContainerPath: "/var/vcap/data/warden/depot/16vbs06ibo1"}

	assert.Equal(t, "/var/vcap/data/warden/depot/16vbs06ibo1/jobs/272", task.Identifier())
}

开发者ID:robsonmwoc，项目名称:loggregator，代码行数:8，代码来源:task_test.go

示例2: NewTaskListener

func NewTaskListener(task domain.Task, e emitter.Emitter, logger *gosteno.Logger) *TaskListener {
	return &TaskListener{
		Logger:         logger,
		emitter:        e,
		taskIdentifier: task.Identifier(),
		stdOutListener: loggingstream.NewLoggingStream(&task, logger, logmessage.LogMessage_OUT),
		stdErrListener: loggingstream.NewLoggingStream(&task, logger, logmessage.LogMessage_ERR),
	}
}

开发者ID:robsonmwoc，项目名称:loggregator，代码行数:9，代码来源:task_listener.go

示例3: setupSockets

func setupSockets(t *testing.T, task *domain.Task) (net.Listener, net.Listener) {
	stdoutSocketPath := filepath.Join(task.Identifier(), "stdout.sock")
	stderrSocketPath := filepath.Join(task.Identifier(), "stderr.sock")
	os.Remove(stdoutSocketPath)
	os.Remove(stderrSocketPath)
	stdoutListener, err := net.Listen("unix", stdoutSocketPath)
	assert.NoError(t, err)
	stderrListener, err := net.Listen("unix", stderrSocketPath)
	assert.NoError(t, err)
	return stdoutListener, stderrListener
}

开发者ID:robsonmwoc，项目名称:loggregator，代码行数:11，代码来源:task_listener_test.go

示例4: NewTaskListener

func NewTaskListener(task domain.Task, logger *gosteno.Logger) (*TaskListener, error) {
	stdOutReader, err := dial(task.Identifier(), events.LogMessage_OUT, logger)
	if err != nil {
		return nil, errors.New(fmt.Sprintf("Connection to stdout %s failed\n", task.Identifier()))
	}
	stdErrReader, err := dial(task.Identifier(), events.LogMessage_ERR, logger)
	if err != nil {
		stdOutReader.Close()
		return nil, errors.New(fmt.Sprintf("Connection to stderr %s failed\n", task.Identifier()))
	}
	return &TaskListener{
		Logger:         logger,
		taskIdentifier: task.Identifier(),
		stdOutReader:   stdOutReader,
		stdErrReader:   stdErrReader,
		task:           task,
	}, nil
}

开发者ID:lyuyun，项目名称:loggregator，代码行数:18，代码来源:task_listener.go

示例5: setupTaskSockets

func setupTaskSockets(task *domain.Task) (stdout net.Listener, stderr net.Listener) {
	os.MkdirAll(task.Identifier(), 0777)
	stdoutSocketPath := filepath.Join(task.Identifier(), "stdout.sock")
	os.Remove(stdoutSocketPath)
	stdoutListener, _ := net.Listen("unix", stdoutSocketPath)

	stderrSocketPath := filepath.Join(task.Identifier(), "stderr.sock")
	os.Remove(stderrSocketPath)
	stderrListener, _ := net.Listen("unix", stderrSocketPath)
	return stdoutListener, stderrListener
}

开发者ID:khj0651，项目名称:loggregator，代码行数:11，代码来源:dea_agent_test.go

示例6: setupTaskSockets

func setupTaskSockets(task *domain.Task) (stdout net.Listener, stderr net.Listener) {
	err := os.MkdirAll(task.Identifier(), 0777)
	Expect(err).NotTo(HaveOccurred())
	stdoutSocketPath := filepath.Join(task.Identifier(), "stdout.sock")
	_ = os.Remove(stdoutSocketPath)

	stdoutListener, err := net.Listen("unix", stdoutSocketPath)
	Expect(err).NotTo(HaveOccurred())

	stderrSocketPath := filepath.Join(task.Identifier(), "stderr.sock")
	_ = os.Remove(stderrSocketPath)
	stderrListener, err := net.Listen("unix", stderrSocketPath)
	Expect(err).NotTo(HaveOccurred())

	return stdoutListener, stderrListener
}

开发者ID:lyuyun，项目名称:loggregator，代码行数:16，代码来源:dea_agent_test.go

示例7:

package domain_test

import (
	"deaagent/domain"
	. "github.com/onsi/ginkgo"
	. "github.com/onsi/gomega"
)

var _ = Describe("Task", func() {
	It("sets identifier correctly", func() {
		task := domain.Task{
			ApplicationId:       "4aa9506e-277f-41ab-b764-a35c0b96fa1b",
			WardenJobId:         272,
			WardenContainerPath: "/var/vcap/data/warden/depot/16vbs06ibo1"}

		Expect(task.Identifier()).To(Equal("/var/vcap/data/warden/depot/16vbs06ibo1/jobs/272"))
	})
})

开发者ID:lyuyun，项目名称:loggregator，代码行数:18，代码来源:task_test.go

注：本文中的deaagent/domain.Task类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。