dataflow

package

v0.5.0 Latest Latest Go to latest Published: Aug 22, 2023 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Dataflow interface {
	Jobs(ctx context.Context) ([]model.Job, error)
	ErrorLogs(ctx context.Context, jobId string) ([]model.LogEntry, error)
}

type DataflowClient struct {
	Project  string
	Location string
	Prefix   string
}

func (client DataflowClient) ErrorLogs(ctx context.Context, jobId string) ([]model.LogEntry, error)

func (client DataflowClient) Jobs(ctx context.Context) ([]model.Job, error)