Documentation ¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 }
type MockClient ¶
func (*MockClient) DescribeScheduledProc ¶ added in v0.5.0
func (m *MockClient) DescribeScheduledProc(jobID string) (schedule.ScheduledJob, error)
func (*MockClient) ExecuteProc ¶
func (*MockClient) GetDefinitiveProcExecutionStatus ¶ added in v0.4.0
func (m *MockClient) GetDefinitiveProcExecutionStatus(name string) (string, error)
func (*MockClient) ListProcs ¶
func (m *MockClient) ListProcs() ([]proc_metadata.Metadata, error)
func (*MockClient) ListScheduledProcs ¶ added in v0.5.0
func (m *MockClient) ListScheduledProcs() ([]schedule.ScheduledJob, error)
func (*MockClient) RemoveScheduledProc ¶ added in v0.5.0
func (m *MockClient) RemoveScheduledProc(jobID string) error
func (*MockClient) ScheduleJob ¶ added in v0.5.0
func (*MockClient) StreamProcLogs ¶
func (m *MockClient) StreamProcLogs(name string) error
type ProcToExecute ¶
type ScheduleJobPayload ¶ added in v0.5.0
Click to show internal directories.
Click to hide internal directories.