dataprocserverless

type BasicOperator struct {
	// contains filtered or unexported fields
}

type Client struct {
	Config
}

type CloudLoggingConsumer struct {
	// contains filtered or unexported fields
}

type Config struct {
	ServiceAccountJSON string `yaml:"service_account_json,omitempty"`
	ServiceAccountFile string `yaml:"service_account_file,omitempty"`
	ProjectID          string `yaml:"project_id,omitempty"`
	Region             string `yaml:"region" json:"region"`
	Workspace          string `yaml:"workspace"`
	ExecutionRole      string `yaml:"execution_role"`
}

type Job struct {
	// contains filtered or unexported fields
}

type JobRunParams struct {
	Project        string
	Region         string
	RuntimeVersion string
	Config         string
	Args           []string
	Timeout        time.Duration
	Workspace      string
	ExecutionRole  string
}

type LogConsumer interface {
	Next() []LogLine
}

type LogLine struct {
	Message string
	Source  string
}

type MissingFieldsError struct {
	Fields []string
}

type NoOpLogConsumer struct{}