daemon

Documentation

Index

• type Client
  • func NewClient(printer io.Printer, proctorConfigLoader config.Loader) Client
• type MockClient
  • func (m *MockClient) DescribeScheduledProc(jobID string) (schedule.ScheduledJob, error)
  • func (m *MockClient) ExecuteProc(name string, procArgs map[string]string) (string, error)
  • func (m *MockClient) GetDefinitiveProcExecutionStatus(name string) (string, error)
  • func (m *MockClient) ListProcs() ([]proc_metadata.Metadata, error)
  • func (m *MockClient) ListScheduledProcs() ([]schedule.ScheduledJob, error)
  • func (m *MockClient) RemoveScheduledProc(jobID string) error
  • func (m *MockClient) ScheduleJob(name, tags, time, notificationEmails string, group string, ...) (string, error)
  • func (m *MockClient) StreamProcLogs(name string) error
• type ProcToExecute
• type ScheduleJobPayload

Types

type Client

type Client interface {
	ListProcs() ([]proc_metadata.Metadata, error)
	ExecuteProc(string, map[string]string) (string, error)
	StreamProcLogs(string) error
	GetDefinitiveProcExecutionStatus(string) (string, error)
	ScheduleJob(string, string, string, string, string, map[string]string) (string, error)
	ListScheduledProcs() ([]schedule.ScheduledJob, error)
	DescribeScheduledProc(string) (schedule.ScheduledJob, error)
	RemoveScheduledProc(string) error
}

func NewClient

func NewClient(printer io.Printer, proctorConfigLoader config.Loader) Client

type MockClient

type MockClient struct {
	mock.Mock
}

func (*MockClient) DescribeScheduledProc

func (m *MockClient) DescribeScheduledProc(jobID string) (schedule.ScheduledJob, error)

func (*MockClient) ExecuteProc

func (m *MockClient) ExecuteProc(name string, procArgs map[string]string) (string, error)

func (*MockClient) GetDefinitiveProcExecutionStatus

func (m *MockClient) GetDefinitiveProcExecutionStatus(name string) (string, error)

func (*MockClient) ListProcs

func (m *MockClient) ListProcs() ([]proc_metadata.Metadata, error)

func (*MockClient) ListScheduledProcs

func (m *MockClient) ListScheduledProcs() ([]schedule.ScheduledJob, error)

func (*MockClient) RemoveScheduledProc

func (m *MockClient) RemoveScheduledProc(jobID string) error

func (*MockClient) ScheduleJob

func (m *MockClient) ScheduleJob(name, tags, time, notificationEmails string, group string, jobArgs map[string]string) (string, error)

func (*MockClient) StreamProcLogs

func (m *MockClient) StreamProcLogs(name string) error

type ProcToExecute

type ProcToExecute struct {
	Name string            `json:"name"`
	Args map[string]string `json:"args"`
}

type ScheduleJobPayload

type ScheduleJobPayload struct {
	ID                 string            `json:"id"`
	Name               string            `json:"name"`
	Tags               string            `json:"tags"`
	Time               string            `json:"time"`
	NotificationEmails string            `json:"notification_emails"`
	Group              string            `json:"group_name"`
	Args               map[string]string `json:"args"`
}