pps

package
v2.6.0-nightly.20230505 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 4, 2023 License: Apache-2.0 Imports: 21 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPps        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPps          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPps = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DatumState_name = map[int32]string{
	0: "UNKNOWN",
	1: "FAILED",
	2: "SUCCESS",
	3: "SKIPPED",
	4: "STARTING",
	5: "RECOVERED",
}
View Source 
var DatumState_value = map[string]int32{
	"UNKNOWN":   0,
	"FAILED":    1,
	"SUCCESS":   2,
	"SKIPPED":   3,
	"STARTING":  4,
	"RECOVERED": 5,
}
View Source 
var JobState_name = map[int32]string{
	0: "JOB_STATE_UNKNOWN",
	1: "JOB_CREATED",
	2: "JOB_STARTING",
	3: "JOB_RUNNING",
	4: "JOB_FAILURE",
	5: "JOB_SUCCESS",
	6: "JOB_KILLED",
	7: "JOB_EGRESSING",
	8: "JOB_FINISHING",
	9: "JOB_UNRUNNABLE",
}
View Source 
var JobState_value = map[string]int32{
	"JOB_STATE_UNKNOWN": 0,
	"JOB_CREATED":       1,
	"JOB_STARTING":      2,
	"JOB_RUNNING":       3,
	"JOB_FAILURE":       4,
	"JOB_SUCCESS":       5,
	"JOB_KILLED":        6,
	"JOB_EGRESSING":     7,
	"JOB_FINISHING":     8,
	"JOB_UNRUNNABLE":    9,
}
View Source 
var PipelineInfo_PipelineType_name = map[int32]string{
	0: "PIPELINT_TYPE_UNKNOWN",
	1: "PIPELINE_TYPE_TRANSFORM",
	2: "PIPELINE_TYPE_SPOUT",
	3: "PIPELINE_TYPE_SERVICE",
}
View Source 
var PipelineInfo_PipelineType_value = map[string]int32{
	"PIPELINT_TYPE_UNKNOWN":   0,
	"PIPELINE_TYPE_TRANSFORM": 1,
	"PIPELINE_TYPE_SPOUT":     2,
	"PIPELINE_TYPE_SERVICE":   3,
}
View Source 
var PipelineState_name = map[int32]string{
	0: "PIPELINE_STATE_UNKNOWN",
	1: "PIPELINE_STARTING",
	2: "PIPELINE_RUNNING",
	3: "PIPELINE_RESTARTING",
	4: "PIPELINE_FAILURE",
	5: "PIPELINE_PAUSED",
	6: "PIPELINE_STANDBY",
	7: "PIPELINE_CRASHING",
}
View Source 
var PipelineState_value = map[string]int32{
	"PIPELINE_STATE_UNKNOWN": 0,
	"PIPELINE_STARTING":      1,
	"PIPELINE_RUNNING":       2,
	"PIPELINE_RESTARTING":    3,
	"PIPELINE_FAILURE":       4,
	"PIPELINE_PAUSED":        5,
	"PIPELINE_STANDBY":       6,
	"PIPELINE_CRASHING":      7,
}
View Source 
var TaintEffect_name = map[int32]string{
	0: "ALL_EFFECTS",
	1: "NO_SCHEDULE",
	2: "PREFER_NO_SCHEDULE",
	3: "NO_EXECUTE",
}
View Source 
var TaintEffect_value = map[string]int32{
	"ALL_EFFECTS":        0,
	"NO_SCHEDULE":        1,
	"PREFER_NO_SCHEDULE": 2,
	"NO_EXECUTE":         3,
}
View Source 
var TolerationOperator_name = map[int32]string{
	0: "EMPTY",
	1: "EXISTS",
	2: "EQUAL",
}
View Source 
var TolerationOperator_value = map[string]int32{
	"EMPTY":  0,
	"EXISTS": 1,
	"EQUAL":  2,
}
View Source 
var WorkerState_name = map[int32]string{
	0: "WORKER_STATE_UNKNOWN",
	1: "POD_RUNNING",
	2: "POD_SUCCESS",
	3: "POD_FAILED",
}
View Source 
var WorkerState_value = map[string]int32{
	"WORKER_STATE_UNKNOWN": 0,
	"POD_RUNNING":          1,
	"POD_SUCCESS":          2,
	"POD_FAILED":           3,
}

Functions

func DataField 

func DataField(data []*InputFile) zap.Field

func DatumIDField 

func DatumIDField(id string) zap.Field

func InputBranches deprecated 

func InputBranches(input *Input) []*pfs.Branch

InputBranches returns the branches in an Input.

Deprecated: Use ProjectInputBranches instead.

func InputName 

func InputName(input *Input) string

InputName computes the name of an Input.

func IsTerminal 

func IsTerminal(state JobState) bool

IsTerminal returns 'true' if 'state' indicates that the job is done (i.e. the state will not change later: SUCCESS, FAILURE, KILLED) and 'false' otherwise.

func JobIDField 

func JobIDField(id string) zap.Field

func MasterField 

func MasterField(master bool) zap.Field

func PipelineNameField 

func PipelineNameField(name string) zap.Field

func ProjectInputBranches 

func ProjectInputBranches(projectName string, input *Input) []*pfs.Branch

func ProjectNameField 

func ProjectNameField(name string) zap.Field

The following are zap fields for log lines that can be parsed into a LogMessage. The field name must be equal to the `protobuf:"...,json="` name.

func RegisterAPIServer 

func RegisterAPIServer(s *grpc.Server, srv APIServer)

func SortInput 

func SortInput(input *Input)

SortInput sorts an Input.

func UserField 

func UserField(user bool) zap.Field

func VisitInput 

func VisitInput(input *Input, f func(*Input) error) error

VisitInput visits each input recursively in ascending order (root last). It cannot return an error unless f returns an error.

func WorkerIDField 

func WorkerIDField(id string) zap.Field

Types

type APIClient 

type APIClient interface {
	InspectJob(ctx context.Context, in *InspectJobRequest, opts ...grpc.CallOption) (*JobInfo, error)
	InspectJobSet(ctx context.Context, in *InspectJobSetRequest, opts ...grpc.CallOption) (API_InspectJobSetClient, error)
	// ListJob returns information about current and past Pachyderm jobs.
	ListJob(ctx context.Context, in *ListJobRequest, opts ...grpc.CallOption) (API_ListJobClient, error)
	ListJobSet(ctx context.Context, in *ListJobSetRequest, opts ...grpc.CallOption) (API_ListJobSetClient, error)
	SubscribeJob(ctx context.Context, in *SubscribeJobRequest, opts ...grpc.CallOption) (API_SubscribeJobClient, error)
	DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*types.Empty, error)
	StopJob(ctx context.Context, in *StopJobRequest, opts ...grpc.CallOption) (*types.Empty, error)
	InspectDatum(ctx context.Context, in *InspectDatumRequest, opts ...grpc.CallOption) (*DatumInfo, error)
	// ListDatum returns information about each datum fed to a Pachyderm job
	ListDatum(ctx context.Context, in *ListDatumRequest, opts ...grpc.CallOption) (API_ListDatumClient, error)
	RestartDatum(ctx context.Context, in *RestartDatumRequest, opts ...grpc.CallOption) (*types.Empty, error)
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)
	InspectPipeline(ctx context.Context, in *InspectPipelineRequest, opts ...grpc.CallOption) (*PipelineInfo, error)
	ListPipeline(ctx context.Context, in *ListPipelineRequest, opts ...grpc.CallOption) (API_ListPipelineClient, error)
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)
	DeletePipelines(ctx context.Context, in *DeletePipelinesRequest, opts ...grpc.CallOption) (*DeletePipelinesResponse, error)
	StartPipeline(ctx context.Context, in *StartPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)
	StopPipeline(ctx context.Context, in *StopPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)
	RunPipeline(ctx context.Context, in *RunPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)
	RunCron(ctx context.Context, in *RunCronRequest, opts ...grpc.CallOption) (*types.Empty, error)
	CreateSecret(ctx context.Context, in *CreateSecretRequest, opts ...grpc.CallOption) (*types.Empty, error)
	DeleteSecret(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*types.Empty, error)
	ListSecret(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*SecretInfos, error)
	InspectSecret(ctx context.Context, in *InspectSecretRequest, opts ...grpc.CallOption) (*SecretInfo, error)
	// DeleteAll deletes everything
	DeleteAll(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error)
	GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (API_GetLogsClient, error)
	// An internal call that causes PPS to put itself into an auth-enabled state
	// (all pipeline have tokens, correct permissions, etcd)
	ActivateAuth(ctx context.Context, in *ActivateAuthRequest, opts ...grpc.CallOption) (*ActivateAuthResponse, error)
	// An internal call used to move a job from one state to another
	UpdateJobState(ctx context.Context, in *UpdateJobStateRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// RunLoadTest runs a load test.
	RunLoadTest(ctx context.Context, in *RunLoadTestRequest, opts ...grpc.CallOption) (*RunLoadTestResponse, error)
	// RunLoadTestDefault runs the default load test.
	RunLoadTestDefault(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*RunLoadTestResponse, error)
	// RenderTemplate renders the provided template and arguments into a list of Pipeline specicifications
	RenderTemplate(ctx context.Context, in *RenderTemplateRequest, opts ...grpc.CallOption) (*RenderTemplateResponse, error)
	// ListTask lists PPS tasks
	ListTask(ctx context.Context, in *task.ListTaskRequest, opts ...grpc.CallOption) (API_ListTaskClient, error)
	// GetKubeEvents returns a stream of kubernetes events
	GetKubeEvents(ctx context.Context, in *LokiRequest, opts ...grpc.CallOption) (API_GetKubeEventsClient, error)
	// QueryLoki returns a stream of loki log messages given a query string
	QueryLoki(ctx context.Context, in *LokiRequest, opts ...grpc.CallOption) (API_QueryLokiClient, error)
}

APIClient is the client API for API service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer 

type APIServer interface {
	InspectJob(context.Context, *InspectJobRequest) (*JobInfo, error)
	InspectJobSet(*InspectJobSetRequest, API_InspectJobSetServer) error
	// ListJob returns information about current and past Pachyderm jobs.
	ListJob(*ListJobRequest, API_ListJobServer) error
	ListJobSet(*ListJobSetRequest, API_ListJobSetServer) error
	SubscribeJob(*SubscribeJobRequest, API_SubscribeJobServer) error
	DeleteJob(context.Context, *DeleteJobRequest) (*types.Empty, error)
	StopJob(context.Context, *StopJobRequest) (*types.Empty, error)
	InspectDatum(context.Context, *InspectDatumRequest) (*DatumInfo, error)
	// ListDatum returns information about each datum fed to a Pachyderm job
	ListDatum(*ListDatumRequest, API_ListDatumServer) error
	RestartDatum(context.Context, *RestartDatumRequest) (*types.Empty, error)
	CreatePipeline(context.Context, *CreatePipelineRequest) (*types.Empty, error)
	InspectPipeline(context.Context, *InspectPipelineRequest) (*PipelineInfo, error)
	ListPipeline(*ListPipelineRequest, API_ListPipelineServer) error
	DeletePipeline(context.Context, *DeletePipelineRequest) (*types.Empty, error)
	DeletePipelines(context.Context, *DeletePipelinesRequest) (*DeletePipelinesResponse, error)
	StartPipeline(context.Context, *StartPipelineRequest) (*types.Empty, error)
	StopPipeline(context.Context, *StopPipelineRequest) (*types.Empty, error)
	RunPipeline(context.Context, *RunPipelineRequest) (*types.Empty, error)
	RunCron(context.Context, *RunCronRequest) (*types.Empty, error)
	CreateSecret(context.Context, *CreateSecretRequest) (*types.Empty, error)
	DeleteSecret(context.Context, *DeleteSecretRequest) (*types.Empty, error)
	ListSecret(context.Context, *types.Empty) (*SecretInfos, error)
	InspectSecret(context.Context, *InspectSecretRequest) (*SecretInfo, error)
	// DeleteAll deletes everything
	DeleteAll(context.Context, *types.Empty) (*types.Empty, error)
	GetLogs(*GetLogsRequest, API_GetLogsServer) error
	// An internal call that causes PPS to put itself into an auth-enabled state
	// (all pipeline have tokens, correct permissions, etcd)
	ActivateAuth(context.Context, *ActivateAuthRequest) (*ActivateAuthResponse, error)
	// An internal call used to move a job from one state to another
	UpdateJobState(context.Context, *UpdateJobStateRequest) (*types.Empty, error)
	// RunLoadTest runs a load test.
	RunLoadTest(context.Context, *RunLoadTestRequest) (*RunLoadTestResponse, error)
	// RunLoadTestDefault runs the default load test.
	RunLoadTestDefault(context.Context, *types.Empty) (*RunLoadTestResponse, error)
	// RenderTemplate renders the provided template and arguments into a list of Pipeline specicifications
	RenderTemplate(context.Context, *RenderTemplateRequest) (*RenderTemplateResponse, error)
	// ListTask lists PPS tasks
	ListTask(*task.ListTaskRequest, API_ListTaskServer) error
	// GetKubeEvents returns a stream of kubernetes events
	GetKubeEvents(*LokiRequest, API_GetKubeEventsServer) error
	// QueryLoki returns a stream of loki log messages given a query string
	QueryLoki(*LokiRequest, API_QueryLokiServer) error
}

APIServer is the server API for API service.

type API_GetKubeEventsClient 

type API_GetKubeEventsClient interface {
	Recv() (*LokiLogMessage, error)
	grpc.ClientStream
}

type API_GetKubeEventsServer 

type API_GetKubeEventsServer interface {
	Send(*LokiLogMessage) error
	grpc.ServerStream
}

type API_GetLogsClient 

type API_GetLogsClient interface {
	Recv() (*LogMessage, error)
	grpc.ClientStream
}

type API_GetLogsServer 

type API_GetLogsServer interface {
	Send(*LogMessage) error
	grpc.ServerStream
}

type API_InspectJobSetClient 

type API_InspectJobSetClient interface {
	Recv() (*JobInfo, error)
	grpc.ClientStream
}

type API_InspectJobSetServer 

type API_InspectJobSetServer interface {
	Send(*JobInfo) error
	grpc.ServerStream
}

type API_ListDatumClient 

type API_ListDatumClient interface {
	Recv() (*DatumInfo, error)
	grpc.ClientStream
}

type API_ListDatumServer 

type API_ListDatumServer interface {
	Send(*DatumInfo) error
	grpc.ServerStream
}

type API_ListJobClient 

type API_ListJobClient interface {
	Recv() (*JobInfo, error)
	grpc.ClientStream
}

type API_ListJobServer 

type API_ListJobServer interface {
	Send(*JobInfo) error
	grpc.ServerStream
}

type API_ListJobSetClient 

type API_ListJobSetClient interface {
	Recv() (*JobSetInfo, error)
	grpc.ClientStream
}

type API_ListJobSetServer 

type API_ListJobSetServer interface {
	Send(*JobSetInfo) error
	grpc.ServerStream
}

type API_ListPipelineClient 

type API_ListPipelineClient interface {
	Recv() (*PipelineInfo, error)
	grpc.ClientStream
}

type API_ListPipelineServer 

type API_ListPipelineServer interface {
	Send(*PipelineInfo) error
	grpc.ServerStream
}

type API_ListTaskClient 

type API_ListTaskClient interface {
	Recv() (*task.TaskInfo, error)
	grpc.ClientStream
}

type API_ListTaskServer 

type API_ListTaskServer interface {
	Send(*task.TaskInfo) error
	grpc.ServerStream
}

type API_QueryLokiClient 

type API_QueryLokiClient interface {
	Recv() (*LokiLogMessage, error)
	grpc.ClientStream
}

type API_QueryLokiServer 

type API_QueryLokiServer interface {
	Send(*LokiLogMessage) error
	grpc.ServerStream
}

type API_SubscribeJobClient 

type API_SubscribeJobClient interface {
	Recv() (*JobInfo, error)
	grpc.ClientStream
}

type API_SubscribeJobServer 

type API_SubscribeJobServer interface {
	Send(*JobInfo) error
	grpc.ServerStream
}

type ActivateAuthRequest 

type ActivateAuthRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActivateAuthRequest) Descriptor 

func (*ActivateAuthRequest) Descriptor() ([]byte, []int)

func (*ActivateAuthRequest) Marshal 

func (m *ActivateAuthRequest) Marshal() (dAtA []byte, err error)

func (*ActivateAuthRequest) MarshalLogObject 

func (x *ActivateAuthRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ActivateAuthRequest) MarshalTo 

func (m *ActivateAuthRequest) MarshalTo(dAtA []byte) (int, error)

func (*ActivateAuthRequest) MarshalToSizedBuffer 

func (m *ActivateAuthRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivateAuthRequest) ProtoMessage 

func (*ActivateAuthRequest) ProtoMessage()

func (*ActivateAuthRequest) Reset 

func (m *ActivateAuthRequest) Reset()

func (*ActivateAuthRequest) Size 

func (m *ActivateAuthRequest) Size() (n int)

func (*ActivateAuthRequest) String 

func (m *ActivateAuthRequest) String() string

func (*ActivateAuthRequest) Unmarshal 

func (m *ActivateAuthRequest) Unmarshal(dAtA []byte) error

func (*ActivateAuthRequest) XXX_DiscardUnknown 

func (m *ActivateAuthRequest) XXX_DiscardUnknown()

func (*ActivateAuthRequest) XXX_Marshal 

func (m *ActivateAuthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivateAuthRequest) XXX_Merge 

func (m *ActivateAuthRequest) XXX_Merge(src proto.Message)

func (*ActivateAuthRequest) XXX_Size 

func (m *ActivateAuthRequest) XXX_Size() int

func (*ActivateAuthRequest) XXX_Unmarshal 

func (m *ActivateAuthRequest) XXX_Unmarshal(b []byte) error

type ActivateAuthResponse 

type ActivateAuthResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActivateAuthResponse) Descriptor 

func (*ActivateAuthResponse) Descriptor() ([]byte, []int)

func (*ActivateAuthResponse) Marshal 

func (m *ActivateAuthResponse) Marshal() (dAtA []byte, err error)

func (*ActivateAuthResponse) MarshalLogObject 

func (x *ActivateAuthResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ActivateAuthResponse) MarshalTo 

func (m *ActivateAuthResponse) MarshalTo(dAtA []byte) (int, error)

func (*ActivateAuthResponse) MarshalToSizedBuffer 

func (m *ActivateAuthResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivateAuthResponse) ProtoMessage 

func (*ActivateAuthResponse) ProtoMessage()

func (*ActivateAuthResponse) Reset 

func (m *ActivateAuthResponse) Reset()

func (*ActivateAuthResponse) Size 

func (m *ActivateAuthResponse) Size() (n int)

func (*ActivateAuthResponse) String 

func (m *ActivateAuthResponse) String() string

func (*ActivateAuthResponse) Unmarshal 

func (m *ActivateAuthResponse) Unmarshal(dAtA []byte) error

func (*ActivateAuthResponse) XXX_DiscardUnknown 

func (m *ActivateAuthResponse) XXX_DiscardUnknown()

func (*ActivateAuthResponse) XXX_Marshal 

func (m *ActivateAuthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivateAuthResponse) XXX_Merge 

func (m *ActivateAuthResponse) XXX_Merge(src proto.Message)

func (*ActivateAuthResponse) XXX_Size 

func (m *ActivateAuthResponse) XXX_Size() int

func (*ActivateAuthResponse) XXX_Unmarshal 

func (m *ActivateAuthResponse) XXX_Unmarshal(b []byte) error

type Aggregate 

type Aggregate struct {
	Count                 int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Mean                  float64  `protobuf:"fixed64,2,opt,name=mean,proto3" json:"mean,omitempty"`
	Stddev                float64  `protobuf:"fixed64,3,opt,name=stddev,proto3" json:"stddev,omitempty"`
	FifthPercentile       float64  `protobuf:"fixed64,4,opt,name=fifth_percentile,json=fifthPercentile,proto3" json:"fifth_percentile,omitempty"`
	NinetyFifthPercentile float64  `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*Aggregate) Descriptor 

func (*Aggregate) Descriptor() ([]byte, []int)

func (*Aggregate) GetCount 

func (m *Aggregate) GetCount() int64

func (*Aggregate) GetFifthPercentile 

func (m *Aggregate) GetFifthPercentile() float64

func (*Aggregate) GetMean 

func (m *Aggregate) GetMean() float64

func (*Aggregate) GetNinetyFifthPercentile 

func (m *Aggregate) GetNinetyFifthPercentile() float64

func (*Aggregate) GetStddev 

func (m *Aggregate) GetStddev() float64

func (*Aggregate) Marshal 

func (m *Aggregate) Marshal() (dAtA []byte, err error)

func (*Aggregate) MarshalLogObject 

func (x *Aggregate) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Aggregate) MarshalTo 

func (m *Aggregate) MarshalTo(dAtA []byte) (int, error)

func (*Aggregate) MarshalToSizedBuffer 

func (m *Aggregate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Aggregate) ProtoMessage 

func (*Aggregate) ProtoMessage()

func (*Aggregate) Reset 

func (m *Aggregate) Reset()

func (*Aggregate) Size 

func (m *Aggregate) Size() (n int)

func (*Aggregate) String 

func (m *Aggregate) String() string

func (*Aggregate) Unmarshal 

func (m *Aggregate) Unmarshal(dAtA []byte) error

func (*Aggregate) XXX_DiscardUnknown 

func (m *Aggregate) XXX_DiscardUnknown()

func (*Aggregate) XXX_Marshal 

func (m *Aggregate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Aggregate) XXX_Merge 

func (m *Aggregate) XXX_Merge(src proto.Message)

func (*Aggregate) XXX_Size 

func (m *Aggregate) XXX_Size() int

func (*Aggregate) XXX_Unmarshal 

func (m *Aggregate) XXX_Unmarshal(b []byte) error

type AggregateProcessStats 

type AggregateProcessStats struct {
	DownloadTime         *Aggregate `protobuf:"bytes,1,opt,name=download_time,json=downloadTime,proto3" json:"download_time,omitempty"`
	ProcessTime          *Aggregate `protobuf:"bytes,2,opt,name=process_time,json=processTime,proto3" json:"process_time,omitempty"`
	UploadTime           *Aggregate `protobuf:"bytes,3,opt,name=upload_time,json=uploadTime,proto3" json:"upload_time,omitempty"`
	DownloadBytes        *Aggregate `protobuf:"bytes,4,opt,name=download_bytes,json=downloadBytes,proto3" json:"download_bytes,omitempty"`
	UploadBytes          *Aggregate `protobuf:"bytes,5,opt,name=upload_bytes,json=uploadBytes,proto3" json:"upload_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*AggregateProcessStats) Descriptor 

func (*AggregateProcessStats) Descriptor() ([]byte, []int)

func (*AggregateProcessStats) GetDownloadBytes 

func (m *AggregateProcessStats) GetDownloadBytes() *Aggregate

func (*AggregateProcessStats) GetDownloadTime 

func (m *AggregateProcessStats) GetDownloadTime() *Aggregate

func (*AggregateProcessStats) GetProcessTime 

func (m *AggregateProcessStats) GetProcessTime() *Aggregate

func (*AggregateProcessStats) GetUploadBytes 

func (m *AggregateProcessStats) GetUploadBytes() *Aggregate

func (*AggregateProcessStats) GetUploadTime 

func (m *AggregateProcessStats) GetUploadTime() *Aggregate

func (*AggregateProcessStats) Marshal 

func (m *AggregateProcessStats) Marshal() (dAtA []byte, err error)

func (*AggregateProcessStats) MarshalLogObject 

func (x *AggregateProcessStats) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*AggregateProcessStats) MarshalTo 

func (m *AggregateProcessStats) MarshalTo(dAtA []byte) (int, error)

func (*AggregateProcessStats) MarshalToSizedBuffer 

func (m *AggregateProcessStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AggregateProcessStats) ProtoMessage 

func (*AggregateProcessStats) ProtoMessage()

func (*AggregateProcessStats) Reset 

func (m *AggregateProcessStats) Reset()

func (*AggregateProcessStats) Size 

func (m *AggregateProcessStats) Size() (n int)

func (*AggregateProcessStats) String 

func (m *AggregateProcessStats) String() string

func (*AggregateProcessStats) Unmarshal 

func (m *AggregateProcessStats) Unmarshal(dAtA []byte) error

func (*AggregateProcessStats) XXX_DiscardUnknown 

func (m *AggregateProcessStats) XXX_DiscardUnknown()

func (*AggregateProcessStats) XXX_Marshal 

func (m *AggregateProcessStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AggregateProcessStats) XXX_Merge 

func (m *AggregateProcessStats) XXX_Merge(src proto.Message)

func (*AggregateProcessStats) XXX_Size 

func (m *AggregateProcessStats) XXX_Size() int

func (*AggregateProcessStats) XXX_Unmarshal 

func (m *AggregateProcessStats) XXX_Unmarshal(b []byte) error

type CreatePipelineRequest 

type CreatePipelineRequest struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// tf_job encodes a Kubeflow TFJob spec. Pachyderm uses this to create TFJobs
	// when running in a kubernetes cluster on which kubeflow has been installed.
	// Exactly one of 'tf_job' and 'transform' should be set
	TFJob           *TFJob           `protobuf:"bytes,2,opt,name=tf_job,json=tfJob,proto3" json:"tf_job,omitempty"`
	Transform       *Transform       `protobuf:"bytes,3,opt,name=transform,proto3" json:"transform,omitempty"`
	ParallelismSpec *ParallelismSpec `protobuf:"bytes,4,opt,name=parallelism_spec,json=parallelismSpec,proto3" json:"parallelism_spec,omitempty"`
	Egress          *Egress          `protobuf:"bytes,5,opt,name=egress,proto3" json:"egress,omitempty"`
	Update          bool             `protobuf:"varint,6,opt,name=update,proto3" json:"update,omitempty"`
	OutputBranch    string           `protobuf:"bytes,7,opt,name=output_branch,json=outputBranch,proto3" json:"output_branch,omitempty"`
	// s3_out, if set, requires a pipeline's user to write to its output repo
	// via Pachyderm's s3 gateway (if set, workers will serve Pachyderm's s3
	// gateway API at http://<pipeline>-s3.<namespace>/<job id>.out/my/file).
	// In this mode /pfs_v2/out won't be walked or uploaded, and the s3 gateway
	// service in the workers will allow writes to the job's output commit
	S3Out                 bool          `protobuf:"varint,8,opt,name=s3_out,json=s3Out,proto3" json:"s3_out,omitempty"`
	ResourceRequests      *ResourceSpec `protobuf:"bytes,9,opt,name=resource_requests,json=resourceRequests,proto3" json:"resource_requests,omitempty"`
	ResourceLimits        *ResourceSpec `protobuf:"bytes,10,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"`
	SidecarResourceLimits *ResourceSpec `` /* 127-byte string literal not displayed */
	Input                 *Input        `protobuf:"bytes,12,opt,name=input,proto3" json:"input,omitempty"`
	Description           string        `protobuf:"bytes,13,opt,name=description,proto3" json:"description,omitempty"`
	// Reprocess forces the pipeline to reprocess all datums.
	// It only has meaning if Update is true
	Reprocess               bool            `protobuf:"varint,15,opt,name=reprocess,proto3" json:"reprocess,omitempty"`
	Service                 *Service        `protobuf:"bytes,17,opt,name=service,proto3" json:"service,omitempty"`
	Spout                   *Spout          `protobuf:"bytes,18,opt,name=spout,proto3" json:"spout,omitempty"`
	DatumSetSpec            *DatumSetSpec   `protobuf:"bytes,19,opt,name=datum_set_spec,json=datumSetSpec,proto3" json:"datum_set_spec,omitempty"`
	DatumTimeout            *types.Duration `protobuf:"bytes,20,opt,name=datum_timeout,json=datumTimeout,proto3" json:"datum_timeout,omitempty"`
	JobTimeout              *types.Duration `protobuf:"bytes,21,opt,name=job_timeout,json=jobTimeout,proto3" json:"job_timeout,omitempty"`
	Salt                    string          `protobuf:"bytes,22,opt,name=salt,proto3" json:"salt,omitempty"`
	DatumTries              int64           `protobuf:"varint,23,opt,name=datum_tries,json=datumTries,proto3" json:"datum_tries,omitempty"`
	SchedulingSpec          *SchedulingSpec `protobuf:"bytes,24,opt,name=scheduling_spec,json=schedulingSpec,proto3" json:"scheduling_spec,omitempty"`
	PodSpec                 string          `protobuf:"bytes,25,opt,name=pod_spec,json=podSpec,proto3" json:"pod_spec,omitempty"`
	PodPatch                string          `protobuf:"bytes,26,opt,name=pod_patch,json=podPatch,proto3" json:"pod_patch,omitempty"`
	SpecCommit              *pfs.Commit     `protobuf:"bytes,27,opt,name=spec_commit,json=specCommit,proto3" json:"spec_commit,omitempty"`
	Metadata                *Metadata       `protobuf:"bytes,28,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ReprocessSpec           string          `protobuf:"bytes,29,opt,name=reprocess_spec,json=reprocessSpec,proto3" json:"reprocess_spec,omitempty"`
	Autoscaling             bool            `protobuf:"varint,30,opt,name=autoscaling,proto3" json:"autoscaling,omitempty"`
	Tolerations             []*Toleration   `protobuf:"bytes,34,rep,name=tolerations,proto3" json:"tolerations,omitempty"`
	SidecarResourceRequests *ResourceSpec   `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}        `json:"-"`
	XXX_unrecognized        []byte          `json:"-"`
	XXX_sizecache           int32           `json:"-"`
}

func (*CreatePipelineRequest) Descriptor 

func (*CreatePipelineRequest) Descriptor() ([]byte, []int)

func (*CreatePipelineRequest) GetAutoscaling 

func (m *CreatePipelineRequest) GetAutoscaling() bool

func (*CreatePipelineRequest) GetDatumSetSpec 

func (m *CreatePipelineRequest) GetDatumSetSpec() *DatumSetSpec

func (*CreatePipelineRequest) GetDatumTimeout 

func (m *CreatePipelineRequest) GetDatumTimeout() *types.Duration

func (*CreatePipelineRequest) GetDatumTries 

func (m *CreatePipelineRequest) GetDatumTries() int64

func (*CreatePipelineRequest) GetDescription 

func (m *CreatePipelineRequest) GetDescription() string

func (*CreatePipelineRequest) GetEgress 

func (m *CreatePipelineRequest) GetEgress() *Egress

func (*CreatePipelineRequest) GetInput 

func (m *CreatePipelineRequest) GetInput() *Input

func (*CreatePipelineRequest) GetJobTimeout 

func (m *CreatePipelineRequest) GetJobTimeout() *types.Duration

func (*CreatePipelineRequest) GetMetadata 

func (m *CreatePipelineRequest) GetMetadata() *Metadata

func (*CreatePipelineRequest) GetOutputBranch 

func (m *CreatePipelineRequest) GetOutputBranch() string

func (*CreatePipelineRequest) GetParallelismSpec 

func (m *CreatePipelineRequest) GetParallelismSpec() *ParallelismSpec

func (*CreatePipelineRequest) GetPipeline 

func (m *CreatePipelineRequest) GetPipeline() *Pipeline

func (*CreatePipelineRequest) GetPodPatch 

func (m *CreatePipelineRequest) GetPodPatch() string

func (*CreatePipelineRequest) GetPodSpec 

func (m *CreatePipelineRequest) GetPodSpec() string

func (*CreatePipelineRequest) GetReprocess 

func (m *CreatePipelineRequest) GetReprocess() bool

func (*CreatePipelineRequest) GetReprocessSpec 

func (m *CreatePipelineRequest) GetReprocessSpec() string

func (*CreatePipelineRequest) GetResourceLimits 

func (m *CreatePipelineRequest) GetResourceLimits() *ResourceSpec

func (*CreatePipelineRequest) GetResourceRequests 

func (m *CreatePipelineRequest) GetResourceRequests() *ResourceSpec

func (*CreatePipelineRequest) GetS3Out 

func (m *CreatePipelineRequest) GetS3Out() bool

func (*CreatePipelineRequest) GetSalt 

func (m *CreatePipelineRequest) GetSalt() string

func (*CreatePipelineRequest) GetSchedulingSpec 

func (m *CreatePipelineRequest) GetSchedulingSpec() *SchedulingSpec

func (*CreatePipelineRequest) GetService 

func (m *CreatePipelineRequest) GetService() *Service

func (*CreatePipelineRequest) GetSidecarResourceLimits 

func (m *CreatePipelineRequest) GetSidecarResourceLimits() *ResourceSpec

func (*CreatePipelineRequest) GetSidecarResourceRequests 

func (m *CreatePipelineRequest) GetSidecarResourceRequests() *ResourceSpec

func (*CreatePipelineRequest) GetSpecCommit 

func (m *CreatePipelineRequest) GetSpecCommit() *pfs.Commit

func (*CreatePipelineRequest) GetSpout 

func (m *CreatePipelineRequest) GetSpout() *Spout

func (*CreatePipelineRequest) GetTFJob 

func (m *CreatePipelineRequest) GetTFJob() *TFJob

func (*CreatePipelineRequest) GetTolerations 

func (m *CreatePipelineRequest) GetTolerations() []*Toleration

func (*CreatePipelineRequest) GetTransform 

func (m *CreatePipelineRequest) GetTransform() *Transform

func (*CreatePipelineRequest) GetUpdate 

func (m *CreatePipelineRequest) GetUpdate() bool

func (*CreatePipelineRequest) Marshal 

func (m *CreatePipelineRequest) Marshal() (dAtA []byte, err error)

func (*CreatePipelineRequest) MarshalLogObject 

func (x *CreatePipelineRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CreatePipelineRequest) MarshalTo 

func (m *CreatePipelineRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreatePipelineRequest) MarshalToSizedBuffer 

func (m *CreatePipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreatePipelineRequest) ProtoMessage 

func (*CreatePipelineRequest) ProtoMessage()

func (*CreatePipelineRequest) Reset 

func (m *CreatePipelineRequest) Reset()

func (*CreatePipelineRequest) Size 

func (m *CreatePipelineRequest) Size() (n int)

func (*CreatePipelineRequest) String 

func (m *CreatePipelineRequest) String() string

func (*CreatePipelineRequest) Unmarshal 

func (m *CreatePipelineRequest) Unmarshal(dAtA []byte) error

func (*CreatePipelineRequest) XXX_DiscardUnknown 

func (m *CreatePipelineRequest) XXX_DiscardUnknown()

func (*CreatePipelineRequest) XXX_Marshal 

func (m *CreatePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreatePipelineRequest) XXX_Merge 

func (m *CreatePipelineRequest) XXX_Merge(src proto.Message)

func (*CreatePipelineRequest) XXX_Size 

func (m *CreatePipelineRequest) XXX_Size() int

func (*CreatePipelineRequest) XXX_Unmarshal 

func (m *CreatePipelineRequest) XXX_Unmarshal(b []byte) error

type CreateSecretRequest 

type CreateSecretRequest struct {
	File                 []byte   `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateSecretRequest) Descriptor 

func (*CreateSecretRequest) Descriptor() ([]byte, []int)

func (*CreateSecretRequest) GetFile 

func (m *CreateSecretRequest) GetFile() []byte

func (*CreateSecretRequest) Marshal 

func (m *CreateSecretRequest) Marshal() (dAtA []byte, err error)

func (*CreateSecretRequest) MarshalLogObject 

func (x *CreateSecretRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CreateSecretRequest) MarshalTo 

func (m *CreateSecretRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateSecretRequest) MarshalToSizedBuffer 

func (m *CreateSecretRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateSecretRequest) ProtoMessage 

func (*CreateSecretRequest) ProtoMessage()

func (*CreateSecretRequest) Reset 

func (m *CreateSecretRequest) Reset()

func (*CreateSecretRequest) Size 

func (m *CreateSecretRequest) Size() (n int)

func (*CreateSecretRequest) String 

func (m *CreateSecretRequest) String() string

func (*CreateSecretRequest) Unmarshal 

func (m *CreateSecretRequest) Unmarshal(dAtA []byte) error

func (*CreateSecretRequest) XXX_DiscardUnknown 

func (m *CreateSecretRequest) XXX_DiscardUnknown()

func (*CreateSecretRequest) XXX_Marshal 

func (m *CreateSecretRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSecretRequest) XXX_Merge 

func (m *CreateSecretRequest) XXX_Merge(src proto.Message)

func (*CreateSecretRequest) XXX_Size 

func (m *CreateSecretRequest) XXX_Size() int

func (*CreateSecretRequest) XXX_Unmarshal 

func (m *CreateSecretRequest) XXX_Unmarshal(b []byte) error

type CronInput 

type CronInput struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Project string `protobuf:"bytes,7,opt,name=project,proto3" json:"project,omitempty"`
	Repo    string `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	Commit  string `protobuf:"bytes,3,opt,name=commit,proto3" json:"commit,omitempty"`
	Spec    string `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	// Overwrite, if true, will expose a single datum that gets overwritten each
	// tick. If false, it will create a new datum for each tick.
	Overwrite            bool             `protobuf:"varint,5,opt,name=overwrite,proto3" json:"overwrite,omitempty"`
	Start                *types.Timestamp `protobuf:"bytes,6,opt,name=start,proto3" json:"start,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CronInput) Descriptor 

func (*CronInput) Descriptor() ([]byte, []int)

func (*CronInput) GetCommit 

func (m *CronInput) GetCommit() string

func (*CronInput) GetName 

func (m *CronInput) GetName() string

func (*CronInput) GetOverwrite 

func (m *CronInput) GetOverwrite() bool

func (*CronInput) GetProject 

func (m *CronInput) GetProject() string

func (*CronInput) GetRepo 

func (m *CronInput) GetRepo() string

func (*CronInput) GetSpec 

func (m *CronInput) GetSpec() string

func (*CronInput) GetStart 

func (m *CronInput) GetStart() *types.Timestamp

func (*CronInput) Marshal 

func (m *CronInput) Marshal() (dAtA []byte, err error)

func (*CronInput) MarshalLogObject 

func (x *CronInput) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CronInput) MarshalTo 

func (m *CronInput) MarshalTo(dAtA []byte) (int, error)

func (*CronInput) MarshalToSizedBuffer 

func (m *CronInput) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CronInput) ProtoMessage 

func (*CronInput) ProtoMessage()

func (*CronInput) Reset 

func (m *CronInput) Reset()

func (*CronInput) Size 

func (m *CronInput) Size() (n int)

func (*CronInput) String 

func (m *CronInput) String() string

func (*CronInput) Unmarshal 

func (m *CronInput) Unmarshal(dAtA []byte) error

func (*CronInput) XXX_DiscardUnknown 

func (m *CronInput) XXX_DiscardUnknown()

func (*CronInput) XXX_Marshal 

func (m *CronInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CronInput) XXX_Merge 

func (m *CronInput) XXX_Merge(src proto.Message)

func (*CronInput) XXX_Size 

func (m *CronInput) XXX_Size() int

func (*CronInput) XXX_Unmarshal 

func (m *CronInput) XXX_Unmarshal(b []byte) error

type Datum 

type Datum struct {
	// ID is the hash computed from all the files
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	ID                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Datum) Descriptor 

func (*Datum) Descriptor() ([]byte, []int)

func (*Datum) GetID 

func (m *Datum) GetID() string

func (*Datum) GetJob 

func (m *Datum) GetJob() *Job

func (*Datum) Marshal 

func (m *Datum) Marshal() (dAtA []byte, err error)

func (*Datum) MarshalLogObject 

func (x *Datum) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Datum) MarshalTo 

func (m *Datum) MarshalTo(dAtA []byte) (int, error)

func (*Datum) MarshalToSizedBuffer 

func (m *Datum) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Datum) ProtoMessage 

func (*Datum) ProtoMessage()

func (*Datum) Reset 

func (m *Datum) Reset()

func (*Datum) Size 

func (m *Datum) Size() (n int)

func (*Datum) String 

func (m *Datum) String() string

func (*Datum) Unmarshal 

func (m *Datum) Unmarshal(dAtA []byte) error

func (*Datum) XXX_DiscardUnknown 

func (m *Datum) XXX_DiscardUnknown()

func (*Datum) XXX_Marshal 

func (m *Datum) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Datum) XXX_Merge 

func (m *Datum) XXX_Merge(src proto.Message)

func (*Datum) XXX_Size 

func (m *Datum) XXX_Size() int

func (*Datum) XXX_Unmarshal 

func (m *Datum) XXX_Unmarshal(b []byte) error

type DatumInfo 

type DatumInfo struct {
	Datum                *Datum          `protobuf:"bytes,1,opt,name=datum,proto3" json:"datum,omitempty"`
	State                DatumState      `protobuf:"varint,2,opt,name=state,proto3,enum=pps_v2.DatumState" json:"state,omitempty"`
	Stats                *ProcessStats   `protobuf:"bytes,3,opt,name=stats,proto3" json:"stats,omitempty"`
	PfsState             *pfs.File       `protobuf:"bytes,4,opt,name=pfs_state,json=pfsState,proto3" json:"pfs_state,omitempty"`
	Data                 []*pfs.FileInfo `protobuf:"bytes,5,rep,name=data,proto3" json:"data,omitempty"`
	ImageId              string          `protobuf:"bytes,6,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*DatumInfo) Descriptor 

func (*DatumInfo) Descriptor() ([]byte, []int)

func (*DatumInfo) GetData 

func (m *DatumInfo) GetData() []*pfs.FileInfo

func (*DatumInfo) GetDatum 

func (m *DatumInfo) GetDatum() *Datum

func (*DatumInfo) GetImageId 

func (m *DatumInfo) GetImageId() string

func (*DatumInfo) GetPfsState 

func (m *DatumInfo) GetPfsState() *pfs.File

func (*DatumInfo) GetState 

func (m *DatumInfo) GetState() DatumState

func (*DatumInfo) GetStats 

func (m *DatumInfo) GetStats() *ProcessStats

func (*DatumInfo) Marshal 

func (m *DatumInfo) Marshal() (dAtA []byte, err error)

func (*DatumInfo) MarshalLogObject 

func (x *DatumInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DatumInfo) MarshalTo 

func (m *DatumInfo) MarshalTo(dAtA []byte) (int, error)

func (*DatumInfo) MarshalToSizedBuffer 

func (m *DatumInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DatumInfo) ProtoMessage 

func (*DatumInfo) ProtoMessage()

func (*DatumInfo) Reset 

func (m *DatumInfo) Reset()

func (*DatumInfo) Size 

func (m *DatumInfo) Size() (n int)

func (*DatumInfo) String 

func (m *DatumInfo) String() string

func (*DatumInfo) Unmarshal 

func (m *DatumInfo) Unmarshal(dAtA []byte) error

func (*DatumInfo) XXX_DiscardUnknown 

func (m *DatumInfo) XXX_DiscardUnknown()

func (*DatumInfo) XXX_Marshal 

func (m *DatumInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatumInfo) XXX_Merge 

func (m *DatumInfo) XXX_Merge(src proto.Message)

func (*DatumInfo) XXX_Size 

func (m *DatumInfo) XXX_Size() int

func (*DatumInfo) XXX_Unmarshal 

func (m *DatumInfo) XXX_Unmarshal(b []byte) error

type DatumSetSpec 

type DatumSetSpec struct {
	// number, if nonzero, specifies that each datum set should contain `number`
	// datums. Datum sets may contain fewer if the total number of datums don't
	// divide evenly.
	Number int64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// size_bytes, if nonzero, specifies a target size for each datum set.
	// Datum sets may be larger or smaller than size_bytes, but will usually be
	// pretty close to size_bytes in size.
	SizeBytes int64 `protobuf:"varint,2,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// per_worker, if nonzero, specifies how many datum sets should be created
	// for each worker. It can't be set with number or size_bytes.
	PerWorker            int64    `protobuf:"varint,3,opt,name=per_worker,json=perWorker,proto3" json:"per_worker,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DatumSetSpec specifies how a pipeline should split its datums into datum sets.

func (*DatumSetSpec) Descriptor 

func (*DatumSetSpec) Descriptor() ([]byte, []int)

func (*DatumSetSpec) GetNumber 

func (m *DatumSetSpec) GetNumber() int64

func (*DatumSetSpec) GetPerWorker 

func (m *DatumSetSpec) GetPerWorker() int64

func (*DatumSetSpec) GetSizeBytes 

func (m *DatumSetSpec) GetSizeBytes() int64

func (*DatumSetSpec) Marshal 

func (m *DatumSetSpec) Marshal() (dAtA []byte, err error)

func (*DatumSetSpec) MarshalLogObject 

func (x *DatumSetSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DatumSetSpec) MarshalTo 

func (m *DatumSetSpec) MarshalTo(dAtA []byte) (int, error)

func (*DatumSetSpec) MarshalToSizedBuffer 

func (m *DatumSetSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DatumSetSpec) ProtoMessage 

func (*DatumSetSpec) ProtoMessage()

func (*DatumSetSpec) Reset 

func (m *DatumSetSpec) Reset()

func (*DatumSetSpec) Size 

func (m *DatumSetSpec) Size() (n int)

func (*DatumSetSpec) String 

func (m *DatumSetSpec) String() string

func (*DatumSetSpec) Unmarshal 

func (m *DatumSetSpec) Unmarshal(dAtA []byte) error

func (*DatumSetSpec) XXX_DiscardUnknown 

func (m *DatumSetSpec) XXX_DiscardUnknown()

func (*DatumSetSpec) XXX_Marshal 

func (m *DatumSetSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatumSetSpec) XXX_Merge 

func (m *DatumSetSpec) XXX_Merge(src proto.Message)

func (*DatumSetSpec) XXX_Size 

func (m *DatumSetSpec) XXX_Size() int

func (*DatumSetSpec) XXX_Unmarshal 

func (m *DatumSetSpec) XXX_Unmarshal(b []byte) error

type DatumState 

type DatumState int32
const (
	DatumState_UNKNOWN   DatumState = 0
	DatumState_FAILED    DatumState = 1
	DatumState_SUCCESS   DatumState = 2
	DatumState_SKIPPED   DatumState = 3
	DatumState_STARTING  DatumState = 4
	DatumState_RECOVERED DatumState = 5
)

func (DatumState) EnumDescriptor 

func (DatumState) EnumDescriptor() ([]byte, []int)

func (DatumState) String 

func (x DatumState) String() string

type DatumStatus 

type DatumStatus struct {
	// Started is the time processing on the current datum began.
	Started              *types.Timestamp `protobuf:"bytes,1,opt,name=started,proto3" json:"started,omitempty"`
	Data                 []*InputFile     `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DatumStatus) Descriptor 

func (*DatumStatus) Descriptor() ([]byte, []int)

func (*DatumStatus) GetData 

func (m *DatumStatus) GetData() []*InputFile

func (*DatumStatus) GetStarted 

func (m *DatumStatus) GetStarted() *types.Timestamp

func (*DatumStatus) Marshal 

func (m *DatumStatus) Marshal() (dAtA []byte, err error)

func (*DatumStatus) MarshalLogObject 

func (x *DatumStatus) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DatumStatus) MarshalTo 

func (m *DatumStatus) MarshalTo(dAtA []byte) (int, error)

func (*DatumStatus) MarshalToSizedBuffer 

func (m *DatumStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DatumStatus) ProtoMessage 

func (*DatumStatus) ProtoMessage()

func (*DatumStatus) Reset 

func (m *DatumStatus) Reset()

func (*DatumStatus) Size 

func (m *DatumStatus) Size() (n int)

func (*DatumStatus) String 

func (m *DatumStatus) String() string

func (*DatumStatus) Unmarshal 

func (m *DatumStatus) Unmarshal(dAtA []byte) error

func (*DatumStatus) XXX_DiscardUnknown 

func (m *DatumStatus) XXX_DiscardUnknown()

func (*DatumStatus) XXX_Marshal 

func (m *DatumStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatumStatus) XXX_Merge 

func (m *DatumStatus) XXX_Merge(src proto.Message)

func (*DatumStatus) XXX_Size 

func (m *DatumStatus) XXX_Size() int

func (*DatumStatus) XXX_Unmarshal 

func (m *DatumStatus) XXX_Unmarshal(b []byte) error

type DeleteJobRequest 

type DeleteJobRequest struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteJobRequest) Descriptor 

func (*DeleteJobRequest) Descriptor() ([]byte, []int)

func (*DeleteJobRequest) GetJob 

func (m *DeleteJobRequest) GetJob() *Job

func (*DeleteJobRequest) Marshal 

func (m *DeleteJobRequest) Marshal() (dAtA []byte, err error)

func (*DeleteJobRequest) MarshalLogObject 

func (x *DeleteJobRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteJobRequest) MarshalTo 

func (m *DeleteJobRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteJobRequest) MarshalToSizedBuffer 

func (m *DeleteJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteJobRequest) ProtoMessage 

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) Reset 

func (m *DeleteJobRequest) Reset()

func (*DeleteJobRequest) Size 

func (m *DeleteJobRequest) Size() (n int)

func (*DeleteJobRequest) String 

func (m *DeleteJobRequest) String() string

func (*DeleteJobRequest) Unmarshal 

func (m *DeleteJobRequest) Unmarshal(dAtA []byte) error

func (*DeleteJobRequest) XXX_DiscardUnknown 

func (m *DeleteJobRequest) XXX_DiscardUnknown()

func (*DeleteJobRequest) XXX_Marshal 

func (m *DeleteJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteJobRequest) XXX_Merge 

func (m *DeleteJobRequest) XXX_Merge(src proto.Message)

func (*DeleteJobRequest) XXX_Size 

func (m *DeleteJobRequest) XXX_Size() int

func (*DeleteJobRequest) XXX_Unmarshal 

func (m *DeleteJobRequest) XXX_Unmarshal(b []byte) error

type DeletePipelineRequest 

type DeletePipelineRequest struct {
	Pipeline             *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	All                  bool      `protobuf:"varint,2,opt,name=all,proto3" json:"all,omitempty"` // Deprecated: Do not use.
	Force                bool      `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	KeepRepo             bool      `protobuf:"varint,4,opt,name=keep_repo,json=keepRepo,proto3" json:"keep_repo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Delete a pipeline. If the deprecated all member is true, then delete all pipelines in the default project.

func (*DeletePipelineRequest) Descriptor 

func (*DeletePipelineRequest) Descriptor() ([]byte, []int)

func (*DeletePipelineRequest) GetAll deprecated 

func (m *DeletePipelineRequest) GetAll() bool

Deprecated: Do not use.

func (*DeletePipelineRequest) GetForce 

func (m *DeletePipelineRequest) GetForce() bool

func (*DeletePipelineRequest) GetKeepRepo 

func (m *DeletePipelineRequest) GetKeepRepo() bool

func (*DeletePipelineRequest) GetPipeline 

func (m *DeletePipelineRequest) GetPipeline() *Pipeline

func (*DeletePipelineRequest) Marshal 

func (m *DeletePipelineRequest) Marshal() (dAtA []byte, err error)

func (*DeletePipelineRequest) MarshalLogObject 

func (x *DeletePipelineRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeletePipelineRequest) MarshalTo 

func (m *DeletePipelineRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeletePipelineRequest) MarshalToSizedBuffer 

func (m *DeletePipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeletePipelineRequest) ProtoMessage 

func (*DeletePipelineRequest) ProtoMessage()

func (*DeletePipelineRequest) Reset 

func (m *DeletePipelineRequest) Reset()

func (*DeletePipelineRequest) Size 

func (m *DeletePipelineRequest) Size() (n int)

func (*DeletePipelineRequest) String 

func (m *DeletePipelineRequest) String() string

func (*DeletePipelineRequest) Unmarshal 

func (m *DeletePipelineRequest) Unmarshal(dAtA []byte) error

func (*DeletePipelineRequest) XXX_DiscardUnknown 

func (m *DeletePipelineRequest) XXX_DiscardUnknown()

func (*DeletePipelineRequest) XXX_Marshal 

func (m *DeletePipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeletePipelineRequest) XXX_Merge 

func (m *DeletePipelineRequest) XXX_Merge(src proto.Message)

func (*DeletePipelineRequest) XXX_Size 

func (m *DeletePipelineRequest) XXX_Size() int

func (*DeletePipelineRequest) XXX_Unmarshal 

func (m *DeletePipelineRequest) XXX_Unmarshal(b []byte) error

type DeletePipelinesRequest 

type DeletePipelinesRequest struct {
	// All pipelines in each project will be deleted if the caller has
	// permission.
	Projects []*pfs.Project `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
	Force    bool           `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	KeepRepo bool           `protobuf:"varint,3,opt,name=keep_repo,json=keepRepo,proto3" json:"keep_repo,omitempty"`
	// If set, all pipelines in all projects will be deleted if the caller has
	// permission.
	All                  bool     `protobuf:"varint,4,opt,name=all,proto3" json:"all,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Delete more than one pipeline.

func (*DeletePipelinesRequest) Descriptor 

func (*DeletePipelinesRequest) Descriptor() ([]byte, []int)

func (*DeletePipelinesRequest) GetAll 

func (m *DeletePipelinesRequest) GetAll() bool

func (*DeletePipelinesRequest) GetForce 

func (m *DeletePipelinesRequest) GetForce() bool

func (*DeletePipelinesRequest) GetKeepRepo 

func (m *DeletePipelinesRequest) GetKeepRepo() bool

func (*DeletePipelinesRequest) GetProjects 

func (m *DeletePipelinesRequest) GetProjects() []*pfs.Project

func (*DeletePipelinesRequest) Marshal 

func (m *DeletePipelinesRequest) Marshal() (dAtA []byte, err error)

func (*DeletePipelinesRequest) MarshalLogObject 

func (x *DeletePipelinesRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeletePipelinesRequest) MarshalTo 

func (m *DeletePipelinesRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeletePipelinesRequest) MarshalToSizedBuffer 

func (m *DeletePipelinesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeletePipelinesRequest) ProtoMessage 

func (*DeletePipelinesRequest) ProtoMessage()

func (*DeletePipelinesRequest) Reset 

func (m *DeletePipelinesRequest) Reset()

func (*DeletePipelinesRequest) Size 

func (m *DeletePipelinesRequest) Size() (n int)

func (*DeletePipelinesRequest) String 

func (m *DeletePipelinesRequest) String() string

func (*DeletePipelinesRequest) Unmarshal 

func (m *DeletePipelinesRequest) Unmarshal(dAtA []byte) error

func (*DeletePipelinesRequest) XXX_DiscardUnknown 

func (m *DeletePipelinesRequest) XXX_DiscardUnknown()

func (*DeletePipelinesRequest) XXX_Marshal 

func (m *DeletePipelinesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeletePipelinesRequest) XXX_Merge 

func (m *DeletePipelinesRequest) XXX_Merge(src proto.Message)

func (*DeletePipelinesRequest) XXX_Size 

func (m *DeletePipelinesRequest) XXX_Size() int

func (*DeletePipelinesRequest) XXX_Unmarshal 

func (m *DeletePipelinesRequest) XXX_Unmarshal(b []byte) error

type DeletePipelinesResponse 

type DeletePipelinesResponse struct {
	Pipelines            []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*DeletePipelinesResponse) Descriptor 

func (*DeletePipelinesResponse) Descriptor() ([]byte, []int)

func (*DeletePipelinesResponse) GetPipelines 

func (m *DeletePipelinesResponse) GetPipelines() []*Pipeline

func (*DeletePipelinesResponse) Marshal 

func (m *DeletePipelinesResponse) Marshal() (dAtA []byte, err error)

func (*DeletePipelinesResponse) MarshalLogObject 

func (x *DeletePipelinesResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeletePipelinesResponse) MarshalTo 

func (m *DeletePipelinesResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeletePipelinesResponse) MarshalToSizedBuffer 

func (m *DeletePipelinesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeletePipelinesResponse) ProtoMessage 

func (*DeletePipelinesResponse) ProtoMessage()

func (*DeletePipelinesResponse) Reset 

func (m *DeletePipelinesResponse) Reset()

func (*DeletePipelinesResponse) Size 

func (m *DeletePipelinesResponse) Size() (n int)

func (*DeletePipelinesResponse) String 

func (m *DeletePipelinesResponse) String() string

func (*DeletePipelinesResponse) Unmarshal 

func (m *DeletePipelinesResponse) Unmarshal(dAtA []byte) error

func (*DeletePipelinesResponse) XXX_DiscardUnknown 

func (m *DeletePipelinesResponse) XXX_DiscardUnknown()

func (*DeletePipelinesResponse) XXX_Marshal 

func (m *DeletePipelinesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeletePipelinesResponse) XXX_Merge 

func (m *DeletePipelinesResponse) XXX_Merge(src proto.Message)

func (*DeletePipelinesResponse) XXX_Size 

func (m *DeletePipelinesResponse) XXX_Size() int

func (*DeletePipelinesResponse) XXX_Unmarshal 

func (m *DeletePipelinesResponse) XXX_Unmarshal(b []byte) error

type DeleteSecretRequest 

type DeleteSecretRequest struct {
	Secret               *Secret  `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteSecretRequest) Descriptor 

func (*DeleteSecretRequest) Descriptor() ([]byte, []int)

func (*DeleteSecretRequest) GetSecret 

func (m *DeleteSecretRequest) GetSecret() *Secret

func (*DeleteSecretRequest) Marshal 

func (m *DeleteSecretRequest) Marshal() (dAtA []byte, err error)

func (*DeleteSecretRequest) MarshalLogObject 

func (x *DeleteSecretRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteSecretRequest) MarshalTo 

func (m *DeleteSecretRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteSecretRequest) MarshalToSizedBuffer 

func (m *DeleteSecretRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteSecretRequest) ProtoMessage 

func (*DeleteSecretRequest) ProtoMessage()

func (*DeleteSecretRequest) Reset 

func (m *DeleteSecretRequest) Reset()

func (*DeleteSecretRequest) Size 

func (m *DeleteSecretRequest) Size() (n int)

func (*DeleteSecretRequest) String 

func (m *DeleteSecretRequest) String() string

func (*DeleteSecretRequest) Unmarshal 

func (m *DeleteSecretRequest) Unmarshal(dAtA []byte) error

func (*DeleteSecretRequest) XXX_DiscardUnknown 

func (m *DeleteSecretRequest) XXX_DiscardUnknown()

func (*DeleteSecretRequest) XXX_Marshal 

func (m *DeleteSecretRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSecretRequest) XXX_Merge 

func (m *DeleteSecretRequest) XXX_Merge(src proto.Message)

func (*DeleteSecretRequest) XXX_Size 

func (m *DeleteSecretRequest) XXX_Size() int

func (*DeleteSecretRequest) XXX_Unmarshal 

func (m *DeleteSecretRequest) XXX_Unmarshal(b []byte) error

type Egress 

type Egress struct {
	URL string `protobuf:"bytes,1,opt,name=URL,proto3" json:"URL,omitempty"`
	// Types that are valid to be assigned to Target:
	//	*Egress_ObjectStorage
	//	*Egress_SqlDatabase
	Target               isEgress_Target `protobuf_oneof:"target"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Egress) Descriptor 

func (*Egress) Descriptor() ([]byte, []int)

func (*Egress) GetObjectStorage 

func (m *Egress) GetObjectStorage() *pfs.ObjectStorageEgress

func (*Egress) GetSqlDatabase 

func (m *Egress) GetSqlDatabase() *pfs.SQLDatabaseEgress

func (*Egress) GetTarget 

func (m *Egress) GetTarget() isEgress_Target

func (*Egress) GetURL 

func (m *Egress) GetURL() string

func (*Egress) Marshal 

func (m *Egress) Marshal() (dAtA []byte, err error)

func (*Egress) MarshalLogObject 

func (x *Egress) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Egress) MarshalTo 

func (m *Egress) MarshalTo(dAtA []byte) (int, error)

func (*Egress) MarshalToSizedBuffer 

func (m *Egress) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Egress) ProtoMessage 

func (*Egress) ProtoMessage()

func (*Egress) Reset 

func (m *Egress) Reset()

func (*Egress) Size 

func (m *Egress) Size() (n int)

func (*Egress) String 

func (m *Egress) String() string

func (*Egress) Unmarshal 

func (m *Egress) Unmarshal(dAtA []byte) error

func (*Egress) XXX_DiscardUnknown 

func (m *Egress) XXX_DiscardUnknown()

func (*Egress) XXX_Marshal 

func (m *Egress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Egress) XXX_Merge 

func (m *Egress) XXX_Merge(src proto.Message)

func (*Egress) XXX_OneofWrappers 

func (*Egress) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Egress) XXX_Size 

func (m *Egress) XXX_Size() int

func (*Egress) XXX_Unmarshal 

func (m *Egress) XXX_Unmarshal(b []byte) error

type Egress_ObjectStorage 

type Egress_ObjectStorage struct {
	ObjectStorage *pfs.ObjectStorageEgress `protobuf:"bytes,2,opt,name=object_storage,json=objectStorage,proto3,oneof" json:"object_storage,omitempty"`
}

func (*Egress_ObjectStorage) MarshalTo 

func (m *Egress_ObjectStorage) MarshalTo(dAtA []byte) (int, error)

func (*Egress_ObjectStorage) MarshalToSizedBuffer 

func (m *Egress_ObjectStorage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Egress_ObjectStorage) Size 

func (m *Egress_ObjectStorage) Size() (n int)

type Egress_SqlDatabase 

type Egress_SqlDatabase struct {
	SqlDatabase *pfs.SQLDatabaseEgress `protobuf:"bytes,3,opt,name=sql_database,json=sqlDatabase,proto3,oneof" json:"sql_database,omitempty"`
}

func (*Egress_SqlDatabase) MarshalTo 

func (m *Egress_SqlDatabase) MarshalTo(dAtA []byte) (int, error)

func (*Egress_SqlDatabase) MarshalToSizedBuffer 

func (m *Egress_SqlDatabase) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Egress_SqlDatabase) Size 

func (m *Egress_SqlDatabase) Size() (n int)

type GPUSpec 

type GPUSpec struct {
	// The type of GPU (nvidia.com/gpu or amd.com/gpu for example).
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// The number of GPUs to request.
	Number               int64    `protobuf:"varint,2,opt,name=number,proto3" json:"number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GPUSpec) Descriptor 

func (*GPUSpec) Descriptor() ([]byte, []int)

func (*GPUSpec) GetNumber 

func (m *GPUSpec) GetNumber() int64

func (*GPUSpec) GetType 

func (m *GPUSpec) GetType() string

func (*GPUSpec) Marshal 

func (m *GPUSpec) Marshal() (dAtA []byte, err error)

func (*GPUSpec) MarshalLogObject 

func (x *GPUSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GPUSpec) MarshalTo 

func (m *GPUSpec) MarshalTo(dAtA []byte) (int, error)

func (*GPUSpec) MarshalToSizedBuffer 

func (m *GPUSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GPUSpec) ProtoMessage 

func (*GPUSpec) ProtoMessage()

func (*GPUSpec) Reset 

func (m *GPUSpec) Reset()

func (*GPUSpec) Size 

func (m *GPUSpec) Size() (n int)

func (*GPUSpec) String 

func (m *GPUSpec) String() string

func (*GPUSpec) Unmarshal 

func (m *GPUSpec) Unmarshal(dAtA []byte) error

func (*GPUSpec) XXX_DiscardUnknown 

func (m *GPUSpec) XXX_DiscardUnknown()

func (*GPUSpec) XXX_Marshal 

func (m *GPUSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GPUSpec) XXX_Merge 

func (m *GPUSpec) XXX_Merge(src proto.Message)

func (*GPUSpec) XXX_Size 

func (m *GPUSpec) XXX_Size() int

func (*GPUSpec) XXX_Unmarshal 

func (m *GPUSpec) XXX_Unmarshal(b []byte) error

type GetLogsRequest 

type GetLogsRequest struct {
	// The pipeline from which we want to get logs (required if the job in 'job'
	// was created as part of a pipeline. To get logs from a non-orphan job
	// without the pipeline that created it, you need to use ElasticSearch).
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// The job from which we want to get logs.
	Job *Job `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// Names of input files from which we want processing logs. This may contain
	// multiple files, to query pipelines that contain multiple inputs. Each
	// filter may be an absolute path of a file within a pps repo, or it may be
	// a hash for that file (to search for files at specific versions)
	DataFilters []string `protobuf:"bytes,3,rep,name=data_filters,json=dataFilters,proto3" json:"data_filters,omitempty"`
	Datum       *Datum   `protobuf:"bytes,4,opt,name=datum,proto3" json:"datum,omitempty"`
	// If true get logs from the master process
	Master bool `protobuf:"varint,5,opt,name=master,proto3" json:"master,omitempty"`
	// Continue to follow new logs as they become available.
	Follow bool `protobuf:"varint,6,opt,name=follow,proto3" json:"follow,omitempty"`
	// If nonzero, the number of lines from the end of the logs to return.  Note:
	// tail applies per container, so you will get tail * <number of pods> total
	// lines back.
	Tail int64 `protobuf:"varint,7,opt,name=tail,proto3" json:"tail,omitempty"`
	// UseLokiBackend causes the logs request to go through the loki backend
	// rather than through kubernetes. This behavior can also be achieved by
	// setting the LOKI_LOGGING feature flag.
	UseLokiBackend bool `protobuf:"varint,8,opt,name=use_loki_backend,json=useLokiBackend,proto3" json:"use_loki_backend,omitempty"`
	// Since specifies how far in the past to return logs from. It defaults to 24 hours.
	Since                *types.Duration `protobuf:"bytes,9,opt,name=since,proto3" json:"since,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetLogsRequest) Descriptor 

func (*GetLogsRequest) Descriptor() ([]byte, []int)

func (*GetLogsRequest) GetDataFilters 

func (m *GetLogsRequest) GetDataFilters() []string

func (*GetLogsRequest) GetDatum 

func (m *GetLogsRequest) GetDatum() *Datum

func (*GetLogsRequest) GetFollow 

func (m *GetLogsRequest) GetFollow() bool

func (*GetLogsRequest) GetJob 

func (m *GetLogsRequest) GetJob() *Job

func (*GetLogsRequest) GetMaster 

func (m *GetLogsRequest) GetMaster() bool

func (*GetLogsRequest) GetPipeline 

func (m *GetLogsRequest) GetPipeline() *Pipeline

func (*GetLogsRequest) GetSince 

func (m *GetLogsRequest) GetSince() *types.Duration

func (*GetLogsRequest) GetTail 

func (m *GetLogsRequest) GetTail() int64

func (*GetLogsRequest) GetUseLokiBackend 

func (m *GetLogsRequest) GetUseLokiBackend() bool

func (*GetLogsRequest) Marshal 

func (m *GetLogsRequest) Marshal() (dAtA []byte, err error)

func (*GetLogsRequest) MarshalLogObject 

func (x *GetLogsRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GetLogsRequest) MarshalTo 

func (m *GetLogsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetLogsRequest) MarshalToSizedBuffer 

func (m *GetLogsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetLogsRequest) ProtoMessage 

func (*GetLogsRequest) ProtoMessage()

func (*GetLogsRequest) Reset 

func (m *GetLogsRequest) Reset()

func (*GetLogsRequest) Size 

func (m *GetLogsRequest) Size() (n int)

func (*GetLogsRequest) String 

func (m *GetLogsRequest) String() string

func (*GetLogsRequest) Unmarshal 

func (m *GetLogsRequest) Unmarshal(dAtA []byte) error

func (*GetLogsRequest) XXX_DiscardUnknown 

func (m *GetLogsRequest) XXX_DiscardUnknown()

func (*GetLogsRequest) XXX_Marshal 

func (m *GetLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLogsRequest) XXX_Merge 

func (m *GetLogsRequest) XXX_Merge(src proto.Message)

func (*GetLogsRequest) XXX_Size 

func (m *GetLogsRequest) XXX_Size() int

func (*GetLogsRequest) XXX_Unmarshal 

func (m *GetLogsRequest) XXX_Unmarshal(b []byte) error

type Input 

type Input struct {
	Pfs                  *PFSInput  `protobuf:"bytes,1,opt,name=pfs,proto3" json:"pfs,omitempty"`
	Join                 []*Input   `protobuf:"bytes,2,rep,name=join,proto3" json:"join,omitempty"`
	Group                []*Input   `protobuf:"bytes,3,rep,name=group,proto3" json:"group,omitempty"`
	Cross                []*Input   `protobuf:"bytes,4,rep,name=cross,proto3" json:"cross,omitempty"`
	Union                []*Input   `protobuf:"bytes,5,rep,name=union,proto3" json:"union,omitempty"`
	Cron                 *CronInput `protobuf:"bytes,6,opt,name=cron,proto3" json:"cron,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Input) Descriptor 

func (*Input) Descriptor() ([]byte, []int)

func (*Input) GetCron 

func (m *Input) GetCron() *CronInput

func (*Input) GetCross 

func (m *Input) GetCross() []*Input

func (*Input) GetGroup 

func (m *Input) GetGroup() []*Input

func (*Input) GetJoin 

func (m *Input) GetJoin() []*Input

func (*Input) GetPfs 

func (m *Input) GetPfs() *PFSInput

func (*Input) GetUnion 

func (m *Input) GetUnion() []*Input

func (*Input) Marshal 

func (m *Input) Marshal() (dAtA []byte, err error)

func (*Input) MarshalLogObject 

func (x *Input) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Input) MarshalTo 

func (m *Input) MarshalTo(dAtA []byte) (int, error)

func (*Input) MarshalToSizedBuffer 

func (m *Input) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) Reset 

func (m *Input) Reset()

func (*Input) Size 

func (m *Input) Size() (n int)

func (*Input) String 

func (m *Input) String() string

func (*Input) Unmarshal 

func (m *Input) Unmarshal(dAtA []byte) error

func (*Input) XXX_DiscardUnknown 

func (m *Input) XXX_DiscardUnknown()

func (*Input) XXX_Marshal 

func (m *Input) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Input) XXX_Merge 

func (m *Input) XXX_Merge(src proto.Message)

func (*Input) XXX_Size 

func (m *Input) XXX_Size() int

func (*Input) XXX_Unmarshal 

func (m *Input) XXX_Unmarshal(b []byte) error

type InputFile 

type InputFile struct {
	// This file's absolute path within its pfs repo.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// This file's hash
	Hash                 []byte   `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InputFile) Descriptor 

func (*InputFile) Descriptor() ([]byte, []int)

func (*InputFile) GetHash 

func (m *InputFile) GetHash() []byte

func (*InputFile) GetPath 

func (m *InputFile) GetPath() string

func (*InputFile) Marshal 

func (m *InputFile) Marshal() (dAtA []byte, err error)

func (*InputFile) MarshalLogObject 

func (x *InputFile) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InputFile) MarshalTo 

func (m *InputFile) MarshalTo(dAtA []byte) (int, error)

func (*InputFile) MarshalToSizedBuffer 

func (m *InputFile) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InputFile) ProtoMessage 

func (*InputFile) ProtoMessage()

func (*InputFile) Reset 

func (m *InputFile) Reset()

func (*InputFile) Size 

func (m *InputFile) Size() (n int)

func (*InputFile) String 

func (m *InputFile) String() string

func (*InputFile) Unmarshal 

func (m *InputFile) Unmarshal(dAtA []byte) error

func (*InputFile) XXX_DiscardUnknown 

func (m *InputFile) XXX_DiscardUnknown()

func (*InputFile) XXX_Marshal 

func (m *InputFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InputFile) XXX_Merge 

func (m *InputFile) XXX_Merge(src proto.Message)

func (*InputFile) XXX_Size 

func (m *InputFile) XXX_Size() int

func (*InputFile) XXX_Unmarshal 

func (m *InputFile) XXX_Unmarshal(b []byte) error

type InspectDatumRequest 

type InspectDatumRequest struct {
	Datum                *Datum   `protobuf:"bytes,1,opt,name=datum,proto3" json:"datum,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InspectDatumRequest) Descriptor 

func (*InspectDatumRequest) Descriptor() ([]byte, []int)

func (*InspectDatumRequest) GetDatum 

func (m *InspectDatumRequest) GetDatum() *Datum

func (*InspectDatumRequest) Marshal 

func (m *InspectDatumRequest) Marshal() (dAtA []byte, err error)

func (*InspectDatumRequest) MarshalLogObject 

func (x *InspectDatumRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectDatumRequest) MarshalTo 

func (m *InspectDatumRequest) MarshalTo(dAtA []byte) (int, error)

func (*InspectDatumRequest) MarshalToSizedBuffer 

func (m *InspectDatumRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InspectDatumRequest) ProtoMessage 

func (*InspectDatumRequest) ProtoMessage()

func (*InspectDatumRequest) Reset 

func (m *InspectDatumRequest) Reset()

func (*InspectDatumRequest) Size 

func (m *InspectDatumRequest) Size() (n int)

func (*InspectDatumRequest) String 

func (m *InspectDatumRequest) String() string

func (*InspectDatumRequest) Unmarshal 

func (m *InspectDatumRequest) Unmarshal(dAtA []byte) error

func (*InspectDatumRequest) XXX_DiscardUnknown 

func (m *InspectDatumRequest) XXX_DiscardUnknown()

func (*InspectDatumRequest) XXX_Marshal 

func (m *InspectDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectDatumRequest) XXX_Merge 

func (m *InspectDatumRequest) XXX_Merge(src proto.Message)

func (*InspectDatumRequest) XXX_Size 

func (m *InspectDatumRequest) XXX_Size() int

func (*InspectDatumRequest) XXX_Unmarshal 

func (m *InspectDatumRequest) XXX_Unmarshal(b []byte) error

type InspectJobRequest 

type InspectJobRequest struct {
	// Callers should set either Job or OutputCommit, not both.
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Wait                 bool     `protobuf:"varint,2,opt,name=wait,proto3" json:"wait,omitempty"`
	Details              bool     `protobuf:"varint,3,opt,name=details,proto3" json:"details,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InspectJobRequest) Descriptor 

func (*InspectJobRequest) Descriptor() ([]byte, []int)

func (*InspectJobRequest) GetDetails 

func (m *InspectJobRequest) GetDetails() bool

func (*InspectJobRequest) GetJob 

func (m *InspectJobRequest) GetJob() *Job

func (*InspectJobRequest) GetWait 

func (m *InspectJobRequest) GetWait() bool

func (*InspectJobRequest) Marshal 

func (m *InspectJobRequest) Marshal() (dAtA []byte, err error)

func (*InspectJobRequest) MarshalLogObject 

func (x *InspectJobRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectJobRequest) MarshalTo 

func (m *InspectJobRequest) MarshalTo(dAtA []byte) (int, error)

func (*InspectJobRequest) MarshalToSizedBuffer 

func (m *InspectJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InspectJobRequest) ProtoMessage 

func (*InspectJobRequest) ProtoMessage()

func (*InspectJobRequest) Reset 

func (m *InspectJobRequest) Reset()

func (*InspectJobRequest) Size 

func (m *InspectJobRequest) Size() (n int)

func (*InspectJobRequest) String 

func (m *InspectJobRequest) String() string

func (*InspectJobRequest) Unmarshal 

func (m *InspectJobRequest) Unmarshal(dAtA []byte) error

func (*InspectJobRequest) XXX_DiscardUnknown 

func (m *InspectJobRequest) XXX_DiscardUnknown()

func (*InspectJobRequest) XXX_Marshal 

func (m *InspectJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectJobRequest) XXX_Merge 

func (m *InspectJobRequest) XXX_Merge(src proto.Message)

func (*InspectJobRequest) XXX_Size 

func (m *InspectJobRequest) XXX_Size() int

func (*InspectJobRequest) XXX_Unmarshal 

func (m *InspectJobRequest) XXX_Unmarshal(b []byte) error

type InspectJobSetRequest 

type InspectJobSetRequest struct {
	JobSet               *JobSet  `protobuf:"bytes,1,opt,name=job_set,json=jobSet,proto3" json:"job_set,omitempty"`
	Wait                 bool     `protobuf:"varint,2,opt,name=wait,proto3" json:"wait,omitempty"`
	Details              bool     `protobuf:"varint,3,opt,name=details,proto3" json:"details,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InspectJobSetRequest) Descriptor 

func (*InspectJobSetRequest) Descriptor() ([]byte, []int)

func (*InspectJobSetRequest) GetDetails 

func (m *InspectJobSetRequest) GetDetails() bool

func (*InspectJobSetRequest) GetJobSet 

func (m *InspectJobSetRequest) GetJobSet() *JobSet

func (*InspectJobSetRequest) GetWait 

func (m *InspectJobSetRequest) GetWait() bool

func (*InspectJobSetRequest) Marshal 

func (m *InspectJobSetRequest) Marshal() (dAtA []byte, err error)

func (*InspectJobSetRequest) MarshalLogObject 

func (x *InspectJobSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectJobSetRequest) MarshalTo 

func (m *InspectJobSetRequest) MarshalTo(dAtA []byte) (int, error)

func (*InspectJobSetRequest) MarshalToSizedBuffer 

func (m *InspectJobSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InspectJobSetRequest) ProtoMessage 

func (*InspectJobSetRequest) ProtoMessage()

func (*InspectJobSetRequest) Reset 

func (m *InspectJobSetRequest) Reset()

func (*InspectJobSetRequest) Size 

func (m *InspectJobSetRequest) Size() (n int)

func (*InspectJobSetRequest) String 

func (m *InspectJobSetRequest) String() string

func (*InspectJobSetRequest) Unmarshal 

func (m *InspectJobSetRequest) Unmarshal(dAtA []byte) error

func (*InspectJobSetRequest) XXX_DiscardUnknown 

func (m *InspectJobSetRequest) XXX_DiscardUnknown()

func (*InspectJobSetRequest) XXX_Marshal 

func (m *InspectJobSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectJobSetRequest) XXX_Merge 

func (m *InspectJobSetRequest) XXX_Merge(src proto.Message)

func (*InspectJobSetRequest) XXX_Size 

func (m *InspectJobSetRequest) XXX_Size() int

func (*InspectJobSetRequest) XXX_Unmarshal 

func (m *InspectJobSetRequest) XXX_Unmarshal(b []byte) error

type InspectPipelineRequest 

type InspectPipelineRequest struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// When true, return PipelineInfos with the details field, which requires
	// loading the pipeline spec from PFS.
	Details              bool     `protobuf:"varint,2,opt,name=details,proto3" json:"details,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InspectPipelineRequest) Descriptor 

func (*InspectPipelineRequest) Descriptor() ([]byte, []int)

func (*InspectPipelineRequest) GetDetails 

func (m *InspectPipelineRequest) GetDetails() bool

func (*InspectPipelineRequest) GetPipeline 

func (m *InspectPipelineRequest) GetPipeline() *Pipeline

func (*InspectPipelineRequest) Marshal 

func (m *InspectPipelineRequest) Marshal() (dAtA []byte, err error)

func (*InspectPipelineRequest) MarshalLogObject 

func (x *InspectPipelineRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectPipelineRequest) MarshalTo 

func (m *InspectPipelineRequest) MarshalTo(dAtA []byte) (int, error)

func (*InspectPipelineRequest) MarshalToSizedBuffer 

func (m *InspectPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InspectPipelineRequest) ProtoMessage 

func (*InspectPipelineRequest) ProtoMessage()

func (*InspectPipelineRequest) Reset 

func (m *InspectPipelineRequest) Reset()

func (*InspectPipelineRequest) Size 

func (m *InspectPipelineRequest) Size() (n int)

func (*InspectPipelineRequest) String 

func (m *InspectPipelineRequest) String() string

func (*InspectPipelineRequest) Unmarshal 

func (m *InspectPipelineRequest) Unmarshal(dAtA []byte) error

func (*InspectPipelineRequest) XXX_DiscardUnknown 

func (m *InspectPipelineRequest) XXX_DiscardUnknown()

func (*InspectPipelineRequest) XXX_Marshal 

func (m *InspectPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectPipelineRequest) XXX_Merge 

func (m *InspectPipelineRequest) XXX_Merge(src proto.Message)

func (*InspectPipelineRequest) XXX_Size 

func (m *InspectPipelineRequest) XXX_Size() int

func (*InspectPipelineRequest) XXX_Unmarshal 

func (m *InspectPipelineRequest) XXX_Unmarshal(b []byte) error

type InspectSecretRequest 

type InspectSecretRequest struct {
	Secret               *Secret  `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InspectSecretRequest) Descriptor 

func (*InspectSecretRequest) Descriptor() ([]byte, []int)

func (*InspectSecretRequest) GetSecret 

func (m *InspectSecretRequest) GetSecret() *Secret

func (*InspectSecretRequest) Marshal 

func (m *InspectSecretRequest) Marshal() (dAtA []byte, err error)

func (*InspectSecretRequest) MarshalLogObject 

func (x *InspectSecretRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*InspectSecretRequest) MarshalTo 

func (m *InspectSecretRequest) MarshalTo(dAtA []byte) (int, error)

func (*InspectSecretRequest) MarshalToSizedBuffer 

func (m *InspectSecretRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InspectSecretRequest) ProtoMessage 

func (*InspectSecretRequest) ProtoMessage()

func (*InspectSecretRequest) Reset 

func (m *InspectSecretRequest) Reset()

func (*InspectSecretRequest) Size 

func (m *InspectSecretRequest) Size() (n int)

func (*InspectSecretRequest) String 

func (m *InspectSecretRequest) String() string

func (*InspectSecretRequest) Unmarshal 

func (m *InspectSecretRequest) Unmarshal(dAtA []byte) error

func (*InspectSecretRequest) XXX_DiscardUnknown 

func (m *InspectSecretRequest) XXX_DiscardUnknown()

func (*InspectSecretRequest) XXX_Marshal 

func (m *InspectSecretRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InspectSecretRequest) XXX_Merge 

func (m *InspectSecretRequest) XXX_Merge(src proto.Message)

func (*InspectSecretRequest) XXX_Size 

func (m *InspectSecretRequest) XXX_Size() int

func (*InspectSecretRequest) XXX_Unmarshal 

func (m *InspectSecretRequest) XXX_Unmarshal(b []byte) error

type Job 

type Job struct {
	Pipeline             *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	ID                   string    `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Job) Descriptor 

func (*Job) Descriptor() ([]byte, []int)

func (*Job) GetID 

func (m *Job) GetID() string

func (*Job) GetPipeline 

func (m *Job) GetPipeline() *Pipeline

func (*Job) Marshal 

func (m *Job) Marshal() (dAtA []byte, err error)

func (*Job) MarshalLogObject 

func (x *Job) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Job) MarshalTo 

func (m *Job) MarshalTo(dAtA []byte) (int, error)

func (*Job) MarshalToSizedBuffer 

func (m *Job) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) Size 

func (m *Job) Size() (n int)

func (*Job) String 

func (j *Job) String() string

func (*Job) Unmarshal 

func (m *Job) Unmarshal(dAtA []byte) error

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Job) XXX_Merge 

func (m *Job) XXX_Merge(src proto.Message)

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

func (m *Job) XXX_Unmarshal(b []byte) error

type JobInfo 

type JobInfo struct {
	Job             *Job        `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	PipelineVersion uint64      `protobuf:"varint,2,opt,name=pipeline_version,json=pipelineVersion,proto3" json:"pipeline_version,omitempty"`
	OutputCommit    *pfs.Commit `protobuf:"bytes,3,opt,name=output_commit,json=outputCommit,proto3" json:"output_commit,omitempty"`
	// Job restart count (e.g. due to datum failure)
	Restart uint64 `protobuf:"varint,4,opt,name=restart,proto3" json:"restart,omitempty"`
	// Counts of how many times we processed or skipped a datum
	DataProcessed int64 `protobuf:"varint,5,opt,name=data_processed,json=dataProcessed,proto3" json:"data_processed,omitempty"`
	DataSkipped   int64 `protobuf:"varint,6,opt,name=data_skipped,json=dataSkipped,proto3" json:"data_skipped,omitempty"`
	DataTotal     int64 `protobuf:"varint,7,opt,name=data_total,json=dataTotal,proto3" json:"data_total,omitempty"`
	DataFailed    int64 `protobuf:"varint,8,opt,name=data_failed,json=dataFailed,proto3" json:"data_failed,omitempty"`
	DataRecovered int64 `protobuf:"varint,9,opt,name=data_recovered,json=dataRecovered,proto3" json:"data_recovered,omitempty"`
	// Download/process/upload time and download/upload bytes
	Stats                *ProcessStats    `protobuf:"bytes,10,opt,name=stats,proto3" json:"stats,omitempty"`
	State                JobState         `protobuf:"varint,11,opt,name=state,proto3,enum=pps_v2.JobState" json:"state,omitempty"`
	Reason               string           `protobuf:"bytes,12,opt,name=reason,proto3" json:"reason,omitempty"`
	Created              *types.Timestamp `protobuf:"bytes,13,opt,name=created,proto3" json:"created,omitempty"`
	Started              *types.Timestamp `protobuf:"bytes,14,opt,name=started,proto3" json:"started,omitempty"`
	Finished             *types.Timestamp `protobuf:"bytes,15,opt,name=finished,proto3" json:"finished,omitempty"`
	Details              *JobInfo_Details `protobuf:"bytes,16,opt,name=details,proto3" json:"details,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

JobInfo is the data stored in the database regarding a given job. The 'details' field contains more information about the job which is expensive to fetch, requiring querying workers or loading the pipeline spec from object storage.

func (*JobInfo) Descriptor 

func (*JobInfo) Descriptor() ([]byte, []int)

func (*JobInfo) GetCreated 

func (m *JobInfo) GetCreated() *types.Timestamp

func (*JobInfo) GetDataFailed 

func (m *JobInfo) GetDataFailed() int64

func (*JobInfo) GetDataProcessed 

func (m *JobInfo) GetDataProcessed() int64

func (*JobInfo) GetDataRecovered 

func (m *JobInfo) GetDataRecovered() int64

func (*JobInfo) GetDataSkipped 

func (m *JobInfo) GetDataSkipped() int64

func (*JobInfo) GetDataTotal 

func (m *JobInfo) GetDataTotal() int64

func (*JobInfo) GetDetails 

func (m *JobInfo) GetDetails() *JobInfo_Details

func (*JobInfo) GetFinished 

func (m *JobInfo) GetFinished() *types.Timestamp

func (*JobInfo) GetJob 

func (m *JobInfo) GetJob() *Job

func (*JobInfo) GetOutputCommit 

func (m *JobInfo) GetOutputCommit() *pfs.Commit

func (*JobInfo) GetPipelineVersion 

func (m *JobInfo) GetPipelineVersion() uint64

func (*JobInfo) GetReason 

func (m *JobInfo) GetReason() string

func (*JobInfo) GetRestart 

func (m *JobInfo) GetRestart() uint64

func (*JobInfo) GetStarted 

func (m *JobInfo) GetStarted() *types.Timestamp

func (*JobInfo) GetState 

func (m *JobInfo) GetState() JobState

func (*JobInfo) GetStats 

func (m *JobInfo) GetStats() *ProcessStats

func (*JobInfo) Marshal 

func (m *JobInfo) Marshal() (dAtA []byte, err error)

func (*JobInfo) MarshalLogObject 

func (x *JobInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*JobInfo) MarshalTo 

func (m *JobInfo) MarshalTo(dAtA []byte) (int, error)

func (*JobInfo) MarshalToSizedBuffer 

func (m *JobInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobInfo) ProtoMessage 

func (*JobInfo) ProtoMessage()

func (*JobInfo) Reset 

func (m *JobInfo) Reset()

func (*JobInfo) Size 

func (m *JobInfo) Size() (n int)

func (*JobInfo) String 

func (m *JobInfo) String() string

func (*JobInfo) Unmarshal 

func (m *JobInfo) Unmarshal(dAtA []byte) error

func (*JobInfo) XXX_DiscardUnknown 

func (m *JobInfo) XXX_DiscardUnknown()

func (*JobInfo) XXX_Marshal 

func (m *JobInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobInfo) XXX_Merge 

func (m *JobInfo) XXX_Merge(src proto.Message)

func (*JobInfo) XXX_Size 

func (m *JobInfo) XXX_Size() int

func (*JobInfo) XXX_Unmarshal 

func (m *JobInfo) XXX_Unmarshal(b []byte) error

type JobInfo_Details 

type JobInfo_Details struct {
	Transform               *Transform       `protobuf:"bytes,1,opt,name=transform,proto3" json:"transform,omitempty"`
	ParallelismSpec         *ParallelismSpec `protobuf:"bytes,2,opt,name=parallelism_spec,json=parallelismSpec,proto3" json:"parallelism_spec,omitempty"`
	Egress                  *Egress          `protobuf:"bytes,3,opt,name=egress,proto3" json:"egress,omitempty"`
	Service                 *Service         `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	Spout                   *Spout           `protobuf:"bytes,5,opt,name=spout,proto3" json:"spout,omitempty"`
	WorkerStatus            []*WorkerStatus  `protobuf:"bytes,6,rep,name=worker_status,json=workerStatus,proto3" json:"worker_status,omitempty"`
	ResourceRequests        *ResourceSpec    `protobuf:"bytes,7,opt,name=resource_requests,json=resourceRequests,proto3" json:"resource_requests,omitempty"`
	ResourceLimits          *ResourceSpec    `protobuf:"bytes,8,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"`
	SidecarResourceLimits   *ResourceSpec    `` /* 126-byte string literal not displayed */
	Input                   *Input           `protobuf:"bytes,10,opt,name=input,proto3" json:"input,omitempty"`
	Salt                    string           `protobuf:"bytes,11,opt,name=salt,proto3" json:"salt,omitempty"`
	DatumSetSpec            *DatumSetSpec    `protobuf:"bytes,12,opt,name=datum_set_spec,json=datumSetSpec,proto3" json:"datum_set_spec,omitempty"`
	DatumTimeout            *types.Duration  `protobuf:"bytes,13,opt,name=datum_timeout,json=datumTimeout,proto3" json:"datum_timeout,omitempty"`
	JobTimeout              *types.Duration  `protobuf:"bytes,14,opt,name=job_timeout,json=jobTimeout,proto3" json:"job_timeout,omitempty"`
	DatumTries              int64            `protobuf:"varint,15,opt,name=datum_tries,json=datumTries,proto3" json:"datum_tries,omitempty"`
	SchedulingSpec          *SchedulingSpec  `protobuf:"bytes,16,opt,name=scheduling_spec,json=schedulingSpec,proto3" json:"scheduling_spec,omitempty"`
	PodSpec                 string           `protobuf:"bytes,17,opt,name=pod_spec,json=podSpec,proto3" json:"pod_spec,omitempty"`
	PodPatch                string           `protobuf:"bytes,18,opt,name=pod_patch,json=podPatch,proto3" json:"pod_patch,omitempty"`
	SidecarResourceRequests *ResourceSpec    `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}         `json:"-"`
	XXX_unrecognized        []byte           `json:"-"`
	XXX_sizecache           int32            `json:"-"`
}

func (*JobInfo_Details) Descriptor 

func (*JobInfo_Details) Descriptor() ([]byte, []int)

func (*JobInfo_Details) GetDatumSetSpec 

func (m *JobInfo_Details) GetDatumSetSpec() *DatumSetSpec

func (*JobInfo_Details) GetDatumTimeout 

func (m *JobInfo_Details) GetDatumTimeout() *types.Duration

func (*JobInfo_Details) GetDatumTries 

func (m *JobInfo_Details) GetDatumTries() int64

func (*JobInfo_Details) GetEgress 

func (m *JobInfo_Details) GetEgress() *Egress

func (*JobInfo_Details) GetInput 

func (m *JobInfo_Details) GetInput() *Input

func (*JobInfo_Details) GetJobTimeout 

func (m *JobInfo_Details) GetJobTimeout() *types.Duration

func (*JobInfo_Details) GetParallelismSpec 

func (m *JobInfo_Details) GetParallelismSpec() *ParallelismSpec

func (*JobInfo_Details) GetPodPatch 

func (m *JobInfo_Details) GetPodPatch() string

func (*JobInfo_Details) GetPodSpec 

func (m *JobInfo_Details) GetPodSpec() string

func (*JobInfo_Details) GetResourceLimits 

func (m *JobInfo_Details) GetResourceLimits() *ResourceSpec

func (*JobInfo_Details) GetResourceRequests 

func (m *JobInfo_Details) GetResourceRequests() *ResourceSpec

func (*JobInfo_Details) GetSalt 

func (m *JobInfo_Details) GetSalt() string

func (*JobInfo_Details) GetSchedulingSpec 

func (m *JobInfo_Details) GetSchedulingSpec() *SchedulingSpec

func (*JobInfo_Details) GetService 

func (m *JobInfo_Details) GetService() *Service

func (*JobInfo_Details) GetSidecarResourceLimits 

func (m *JobInfo_Details) GetSidecarResourceLimits() *ResourceSpec

func (*JobInfo_Details) GetSidecarResourceRequests 

func (m *JobInfo_Details) GetSidecarResourceRequests() *ResourceSpec

func (*JobInfo_Details) GetSpout 

func (m *JobInfo_Details) GetSpout() *Spout

func (*JobInfo_Details) GetTransform 

func (m *JobInfo_Details) GetTransform() *Transform

func (*JobInfo_Details) GetWorkerStatus 

func (m *JobInfo_Details) GetWorkerStatus() []*WorkerStatus

func (*JobInfo_Details) Marshal 

func (m *JobInfo_Details) Marshal() (dAtA []byte, err error)

func (*JobInfo_Details) MarshalLogObject 

func (x *JobInfo_Details) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*JobInfo_Details) MarshalTo 

func (m *JobInfo_Details) MarshalTo(dAtA []byte) (int, error)

func (*JobInfo_Details) MarshalToSizedBuffer 

func (m *JobInfo_Details) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobInfo_Details) ProtoMessage 

func (*JobInfo_Details) ProtoMessage()

func (*JobInfo_Details) Reset 

func (m *JobInfo_Details) Reset()

func (*JobInfo_Details) Size 

func (m *JobInfo_Details) Size() (n int)

func (*JobInfo_Details) String 

func (m *JobInfo_Details) String() string

func (*JobInfo_Details) Unmarshal 

func (m *JobInfo_Details) Unmarshal(dAtA []byte) error

func (*JobInfo_Details) XXX_DiscardUnknown 

func (m *JobInfo_Details) XXX_DiscardUnknown()

func (*JobInfo_Details) XXX_Marshal 

func (m *JobInfo_Details) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobInfo_Details) XXX_Merge 

func (m *JobInfo_Details) XXX_Merge(src proto.Message)

func (*JobInfo_Details) XXX_Size 

func (m *JobInfo_Details) XXX_Size() int

func (*JobInfo_Details) XXX_Unmarshal 

func (m *JobInfo_Details) XXX_Unmarshal(b []byte) error

type JobInput 

type JobInput struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Commit               *pfs.Commit `protobuf:"bytes,2,opt,name=commit,proto3" json:"commit,omitempty"`
	Glob                 string      `protobuf:"bytes,3,opt,name=glob,proto3" json:"glob,omitempty"`
	Lazy                 bool        `protobuf:"varint,4,opt,name=lazy,proto3" json:"lazy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*JobInput) Descriptor 

func (*JobInput) Descriptor() ([]byte, []int)

func (*JobInput) GetCommit 

func (m *JobInput) GetCommit() *pfs.Commit

func (*JobInput) GetGlob 

func (m *JobInput) GetGlob() string

func (*JobInput) GetLazy 

func (m *JobInput) GetLazy() bool

func (*JobInput) GetName 

func (m *JobInput) GetName() string

func (*JobInput) Marshal 

func (m *JobInput) Marshal() (dAtA []byte, err error)

func (*JobInput) MarshalLogObject 

func (x *JobInput) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*JobInput) MarshalTo 

func (m *JobInput) MarshalTo(dAtA []byte) (int, error)

func (*JobInput) MarshalToSizedBuffer 

func (m *JobInput) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobInput) ProtoMessage 

func (*JobInput) ProtoMessage()

func (*JobInput) Reset 

func (m *JobInput) Reset()

func (*JobInput) Size 

func (m *JobInput) Size() (n int)

func (*JobInput) String 

func (m *JobInput) String() string

func (*JobInput) Unmarshal 

func (m *JobInput) Unmarshal(dAtA []byte) error

func (*JobInput) XXX_DiscardUnknown 

func (m *JobInput) XXX_DiscardUnknown()

func (*JobInput) XXX_Marshal 

func (m *JobInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobInput) XXX_Merge 

func (m *JobInput) XXX_Merge(src proto.Message)

func (*JobInput) XXX_Size 

func (m *JobInput) XXX_Size() int

func (*JobInput) XXX_Unmarshal 

func (m *JobInput) XXX_Unmarshal(b []byte) error

type JobSet 

type JobSet struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobSet) Descriptor 

func (*JobSet) Descriptor() ([]byte, []int)

func (*JobSet) GetID 

func (m *JobSet) GetID() string

func (*JobSet) Marshal 

func (m *JobSet) Marshal() (dAtA []byte, err error)

func (*JobSet) MarshalLogObject 

func (x *JobSet) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*JobSet) MarshalTo 

func (m *JobSet) MarshalTo(dAtA []byte) (int, error)

func (*JobSet) MarshalToSizedBuffer 

func (m *JobSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSet) ProtoMessage 

func (*JobSet) ProtoMessage()

func (*JobSet) Reset 

func (m *JobSet) Reset()

func (*JobSet) Size 

func (m *JobSet) Size() (n int)

func (*JobSet) String 

func (m *JobSet) String() string

func (*JobSet) Unmarshal 

func (m *JobSet) Unmarshal(dAtA []byte) error

func (*JobSet) XXX_DiscardUnknown 

func (m *JobSet) XXX_DiscardUnknown()

func (*JobSet) XXX_Marshal 

func (m *JobSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSet) XXX_Merge 

func (m *JobSet) XXX_Merge(src proto.Message)

func (*JobSet) XXX_Size 

func (m *JobSet) XXX_Size() int

func (*JobSet) XXX_Unmarshal 

func (m *JobSet) XXX_Unmarshal(b []byte) error

type JobSetInfo 

type JobSetInfo struct {
	JobSet               *JobSet    `protobuf:"bytes,1,opt,name=job_set,json=jobSet,proto3" json:"job_set,omitempty"`
	Jobs                 []*JobInfo `protobuf:"bytes,2,rep,name=jobs,proto3" json:"jobs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*JobSetInfo) Descriptor 

func (*JobSetInfo) Descriptor() ([]byte, []int)

func (*JobSetInfo) GetJobSet 

func (m *JobSetInfo) GetJobSet() *JobSet

func (*JobSetInfo) GetJobs 

func (m *JobSetInfo) GetJobs() []*JobInfo

func (*JobSetInfo) Marshal 

func (m *JobSetInfo) Marshal() (dAtA []byte, err error)

func (*JobSetInfo) MarshalLogObject 

func (x *JobSetInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*JobSetInfo) MarshalTo 

func (m *JobSetInfo) MarshalTo(dAtA []byte) (int, error)

func (*JobSetInfo) MarshalToSizedBuffer 

func (m *JobSetInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSetInfo) ProtoMessage 

func (*JobSetInfo) ProtoMessage()

func (*JobSetInfo) Reset 

func (m *JobSetInfo) Reset()

func (*JobSetInfo) Size 

func (m *JobSetInfo) Size() (n int)

func (*JobSetInfo) String 

func (m *JobSetInfo) String() string

func (*JobSetInfo) Unmarshal 

func (m *JobSetInfo) Unmarshal(dAtA []byte) error

func (*JobSetInfo) XXX_DiscardUnknown 

func (m *JobSetInfo) XXX_DiscardUnknown()

func (*JobSetInfo) XXX_Marshal 

func (m *JobSetInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSetInfo) XXX_Merge 

func (m *JobSetInfo) XXX_Merge(src proto.Message)

func (*JobSetInfo) XXX_Size 

func (m *JobSetInfo) XXX_Size() int

func (*JobSetInfo) XXX_Unmarshal 

func (m *JobSetInfo) XXX_Unmarshal(b []byte) error

type JobState 

type JobState int32
const (
	JobState_JOB_STATE_UNKNOWN JobState = 0
	JobState_JOB_CREATED       JobState = 1
	JobState_JOB_STARTING      JobState = 2
	JobState_JOB_RUNNING       JobState = 3
	JobState_JOB_FAILURE       JobState = 4
	JobState_JOB_SUCCESS       JobState = 5
	JobState_JOB_KILLED        JobState = 6
	JobState_JOB_EGRESSING     JobState = 7
	JobState_JOB_FINISHING     JobState = 8
	JobState_JOB_UNRUNNABLE    JobState = 9
)

func JobStateFromName 

func JobStateFromName(name string) (JobState, error)

JobStateFromName attempts to interpret a string as a JobState, accepting either the enum names or the pretty printed state names

func (JobState) EnumDescriptor 

func (JobState) EnumDescriptor() ([]byte, []int)

func (JobState) String 

func (x JobState) String() string

type ListDatumRequest 

type ListDatumRequest struct {
	// Job and Input are two different ways to specify the datums you want.
	// Only one can be set.
	// Job is the job to list datums from.
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// Input is the input to list datums from.
	// The datums listed are the ones that would be run if a pipeline was created
	// with the provided input.
	Input  *Input                   `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	Filter *ListDatumRequest_Filter `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// datum id to start from. we do not include this datum in the response
	PaginationMarker string `protobuf:"bytes,4,opt,name=paginationMarker,proto3" json:"paginationMarker,omitempty"`
	// Number of datums to return
	Number int64 `protobuf:"varint,5,opt,name=number,proto3" json:"number,omitempty"`
	// If true, return datums in reverse order
	Reverse              bool     `protobuf:"varint,6,opt,name=reverse,proto3" json:"reverse,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListDatumRequest) Descriptor 

func (*ListDatumRequest) Descriptor() ([]byte, []int)

func (*ListDatumRequest) GetFilter 

func (m *ListDatumRequest) GetFilter() *ListDatumRequest_Filter

func (*ListDatumRequest) GetInput 

func (m *ListDatumRequest) GetInput() *Input

func (*ListDatumRequest) GetJob 

func (m *ListDatumRequest) GetJob() *Job

func (*ListDatumRequest) GetNumber 

func (m *ListDatumRequest) GetNumber() int64

func (*ListDatumRequest) GetPaginationMarker 

func (m *ListDatumRequest) GetPaginationMarker() string

func (*ListDatumRequest) GetReverse 

func (m *ListDatumRequest) GetReverse() bool

func (*ListDatumRequest) Marshal 

func (m *ListDatumRequest) Marshal() (dAtA []byte, err error)

func (*ListDatumRequest) MarshalLogObject 

func (x *ListDatumRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListDatumRequest) MarshalTo 

func (m *ListDatumRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListDatumRequest) MarshalToSizedBuffer 

func (m *ListDatumRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListDatumRequest) ProtoMessage 

func (*ListDatumRequest) ProtoMessage()

func (*ListDatumRequest) Reset 

func (m *ListDatumRequest) Reset()

func (*ListDatumRequest) Size 

func (m *ListDatumRequest) Size() (n int)

func (*ListDatumRequest) String 

func (m *ListDatumRequest) String() string

func (*ListDatumRequest) Unmarshal 

func (m *ListDatumRequest) Unmarshal(dAtA []byte) error

func (*ListDatumRequest) XXX_DiscardUnknown 

func (m *ListDatumRequest) XXX_DiscardUnknown()

func (*ListDatumRequest) XXX_Marshal 

func (m *ListDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDatumRequest) XXX_Merge 

func (m *ListDatumRequest) XXX_Merge(src proto.Message)

func (*ListDatumRequest) XXX_Size 

func (m *ListDatumRequest) XXX_Size() int

func (*ListDatumRequest) XXX_Unmarshal 

func (m *ListDatumRequest) XXX_Unmarshal(b []byte) error

type ListDatumRequest_Filter 

type ListDatumRequest_Filter struct {
	State                []DatumState `protobuf:"varint,1,rep,packed,name=state,proto3,enum=pps_v2.DatumState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Filter restricts returned DatumInfo messages to those which match all of the filtered attributes.

func (*ListDatumRequest_Filter) Allow 

func (r *ListDatumRequest_Filter) Allow(item *DatumInfo) bool

Allow returns true if the filter allows the item. Currently, this means if the item’s state matches one of the states given in the filter.

func (*ListDatumRequest_Filter) Descriptor 

func (*ListDatumRequest_Filter) Descriptor() ([]byte, []int)

func (*ListDatumRequest_Filter) GetState 

func (m *ListDatumRequest_Filter) GetState() []DatumState

func (*ListDatumRequest_Filter) Marshal 

func (m *ListDatumRequest_Filter) Marshal() (dAtA []byte, err error)

func (*ListDatumRequest_Filter) MarshalLogObject 

func (x *ListDatumRequest_Filter) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListDatumRequest_Filter) MarshalTo 

func (m *ListDatumRequest_Filter) MarshalTo(dAtA []byte) (int, error)

func (*ListDatumRequest_Filter) MarshalToSizedBuffer 

func (m *ListDatumRequest_Filter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListDatumRequest_Filter) ProtoMessage 

func (*ListDatumRequest_Filter) ProtoMessage()

func (*ListDatumRequest_Filter) Reset 

func (m *ListDatumRequest_Filter) Reset()

func (*ListDatumRequest_Filter) Size 

func (m *ListDatumRequest_Filter) Size() (n int)

func (*ListDatumRequest_Filter) String 

func (m *ListDatumRequest_Filter) String() string

func (*ListDatumRequest_Filter) Unmarshal 

func (m *ListDatumRequest_Filter) Unmarshal(dAtA []byte) error

func (*ListDatumRequest_Filter) XXX_DiscardUnknown 

func (m *ListDatumRequest_Filter) XXX_DiscardUnknown()

func (*ListDatumRequest_Filter) XXX_Marshal 

func (m *ListDatumRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDatumRequest_Filter) XXX_Merge 

func (m *ListDatumRequest_Filter) XXX_Merge(src proto.Message)

func (*ListDatumRequest_Filter) XXX_Size 

func (m *ListDatumRequest_Filter) XXX_Size() int

func (*ListDatumRequest_Filter) XXX_Unmarshal 

func (m *ListDatumRequest_Filter) XXX_Unmarshal(b []byte) error

type ListJobRequest 

type ListJobRequest struct {
	// A list of projects to filter jobs on, nil means don't filter.
	Projects    []*pfs.Project `protobuf:"bytes,7,rep,name=projects,proto3" json:"projects,omitempty"`
	Pipeline    *Pipeline      `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	InputCommit []*pfs.Commit  `protobuf:"bytes,2,rep,name=input_commit,json=inputCommit,proto3" json:"input_commit,omitempty"`
	// History indicates return jobs from historical versions of pipelines
	// semantics are:
	// 0: Return jobs from the current version of the pipeline or pipelines.
	// 1: Return the above and jobs from the next most recent version
	// 2: etc.
	// -1: Return jobs from all historical versions.
	History int64 `protobuf:"varint,4,opt,name=history,proto3" json:"history,omitempty"`
	// Details indicates whether the result should include all pipeline details in
	// each JobInfo, or limited information including name and status, but
	// excluding information in the pipeline spec. Leaving this "false" can make
	// the call significantly faster in clusters with a large number of pipelines
	// and jobs.
	// Note that if 'input_commit' is set, this field is coerced to "true"
	Details bool `protobuf:"varint,5,opt,name=details,proto3" json:"details,omitempty"`
	// A jq program string for additional result filtering
	JqFilter string `protobuf:"bytes,6,opt,name=jqFilter,proto3" json:"jqFilter,omitempty"`
	// timestamp that is pagination marker
	PaginationMarker *types.Timestamp `protobuf:"bytes,8,opt,name=paginationMarker,proto3" json:"paginationMarker,omitempty"`
	// number of results to return
	Number int64 `protobuf:"varint,9,opt,name=number,proto3" json:"number,omitempty"`
	// flag to indicated if results should be returned in reverse order
	Reverse              bool     `protobuf:"varint,10,opt,name=reverse,proto3" json:"reverse,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListJobRequest) Descriptor 

func (*ListJobRequest) Descriptor() ([]byte, []int)

func (*ListJobRequest) GetDetails 

func (m *ListJobRequest) GetDetails() bool

func (*ListJobRequest) GetHistory 

func (m *ListJobRequest) GetHistory() int64

func (*ListJobRequest) GetInputCommit 

func (m *ListJobRequest) GetInputCommit() []*pfs.Commit

func (*ListJobRequest) GetJqFilter 

func (m *ListJobRequest) GetJqFilter() string

func (*ListJobRequest) GetNumber 

func (m *ListJobRequest) GetNumber() int64

func (*ListJobRequest) GetPaginationMarker 

func (m *ListJobRequest) GetPaginationMarker() *types.Timestamp

func (*ListJobRequest) GetPipeline 

func (m *ListJobRequest) GetPipeline() *Pipeline

func (*ListJobRequest) GetProjects 

func (m *ListJobRequest) GetProjects() []*pfs.Project

func (*ListJobRequest) GetReverse 

func (m *ListJobRequest) GetReverse() bool

func (*ListJobRequest) Marshal 

func (m *ListJobRequest) Marshal() (dAtA []byte, err error)

func (*ListJobRequest) MarshalLogObject 

func (x *ListJobRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListJobRequest) MarshalTo 

func (m *ListJobRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListJobRequest) MarshalToSizedBuffer 

func (m *ListJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListJobRequest) ProtoMessage 

func (*ListJobRequest) ProtoMessage()

func (*ListJobRequest) Reset 

func (m *ListJobRequest) Reset()

func (*ListJobRequest) Size 

func (m *ListJobRequest) Size() (n int)

func (*ListJobRequest) String 

func (m *ListJobRequest) String() string

func (*ListJobRequest) Unmarshal 

func (m *ListJobRequest) Unmarshal(dAtA []byte) error

func (*ListJobRequest) XXX_DiscardUnknown 

func (m *ListJobRequest) XXX_DiscardUnknown()

func (*ListJobRequest) XXX_Marshal 

func (m *ListJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobRequest) XXX_Merge 

func (m *ListJobRequest) XXX_Merge(src proto.Message)

func (*ListJobRequest) XXX_Size 

func (m *ListJobRequest) XXX_Size() int

func (*ListJobRequest) XXX_Unmarshal 

func (m *ListJobRequest) XXX_Unmarshal(b []byte) error

type ListJobSetRequest 

type ListJobSetRequest struct {
	Details bool `protobuf:"varint,1,opt,name=details,proto3" json:"details,omitempty"`
	// A list of projects to filter jobs on, nil means don't filter.
	Projects []*pfs.Project `protobuf:"bytes,2,rep,name=projects,proto3" json:"projects,omitempty"`
	// we return job sets created before or after this time based on the reverse flag
	PaginationMarker *types.Timestamp `protobuf:"bytes,3,opt,name=paginationMarker,proto3" json:"paginationMarker,omitempty"`
	// number of results to return
	Number int64 `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
	// if true, return results in reverse order
	Reverse              bool     `protobuf:"varint,5,opt,name=reverse,proto3" json:"reverse,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListJobSetRequest) Descriptor 

func (*ListJobSetRequest) Descriptor() ([]byte, []int)

func (*ListJobSetRequest) GetDetails 

func (m *ListJobSetRequest) GetDetails() bool

func (*ListJobSetRequest) GetNumber 

func (m *ListJobSetRequest) GetNumber() int64

func (*ListJobSetRequest) GetPaginationMarker 

func (m *ListJobSetRequest) GetPaginationMarker() *types.Timestamp

func (*ListJobSetRequest) GetProjects 

func (m *ListJobSetRequest) GetProjects() []*pfs.Project

func (*ListJobSetRequest) GetReverse 

func (m *ListJobSetRequest) GetReverse() bool

func (*ListJobSetRequest) Marshal 

func (m *ListJobSetRequest) Marshal() (dAtA []byte, err error)

func (*ListJobSetRequest) MarshalLogObject 

func (x *ListJobSetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListJobSetRequest) MarshalTo 

func (m *ListJobSetRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListJobSetRequest) MarshalToSizedBuffer 

func (m *ListJobSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListJobSetRequest) ProtoMessage 

func (*ListJobSetRequest) ProtoMessage()

func (*ListJobSetRequest) Reset 

func (m *ListJobSetRequest) Reset()

func (*ListJobSetRequest) Size 

func (m *ListJobSetRequest) Size() (n int)

func (*ListJobSetRequest) String 

func (m *ListJobSetRequest) String() string

func (*ListJobSetRequest) Unmarshal 

func (m *ListJobSetRequest) Unmarshal(dAtA []byte) error

func (*ListJobSetRequest) XXX_DiscardUnknown 

func (m *ListJobSetRequest) XXX_DiscardUnknown()

func (*ListJobSetRequest) XXX_Marshal 

func (m *ListJobSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobSetRequest) XXX_Merge 

func (m *ListJobSetRequest) XXX_Merge(src proto.Message)

func (*ListJobSetRequest) XXX_Size 

func (m *ListJobSetRequest) XXX_Size() int

func (*ListJobSetRequest) XXX_Unmarshal 

func (m *ListJobSetRequest) XXX_Unmarshal(b []byte) error

type ListPipelineRequest 

type ListPipelineRequest struct {
	// If non-nil, only return info about a single pipeline, this is redundant
	// with InspectPipeline unless history is non-zero.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// History indicates how many historical versions you want returned. Its
	// semantics are:
	// 0: Return the current version of the pipeline or pipelines.
	// 1: Return the above and the next most recent version
	// 2: etc.
	// -1: Return all historical versions.
	History int64 `protobuf:"varint,2,opt,name=history,proto3" json:"history,omitempty"`
	// When true, return PipelineInfos with the details field, which requires
	// loading the pipeline spec from PFS.
	Details bool `protobuf:"varint,3,opt,name=details,proto3" json:"details,omitempty"`
	// A jq program string for additional result filtering
	JqFilter string `protobuf:"bytes,4,opt,name=jqFilter,proto3" json:"jqFilter,omitempty"`
	// If non-nil, will return all the pipeline infos at this commit set
	CommitSet *pfs.CommitSet `protobuf:"bytes,5,opt,name=commit_set,json=commitSet,proto3" json:"commit_set,omitempty"`
	// Projects to filter on. Empty list means no filter, so return all pipelines.
	Projects             []*pfs.Project `protobuf:"bytes,6,rep,name=projects,proto3" json:"projects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ListPipelineRequest) Descriptor 

func (*ListPipelineRequest) Descriptor() ([]byte, []int)

func (*ListPipelineRequest) GetCommitSet 

func (m *ListPipelineRequest) GetCommitSet() *pfs.CommitSet

func (*ListPipelineRequest) GetDetails 

func (m *ListPipelineRequest) GetDetails() bool

func (*ListPipelineRequest) GetHistory 

func (m *ListPipelineRequest) GetHistory() int64

func (*ListPipelineRequest) GetJqFilter 

func (m *ListPipelineRequest) GetJqFilter() string

func (*ListPipelineRequest) GetPipeline 

func (m *ListPipelineRequest) GetPipeline() *Pipeline

func (*ListPipelineRequest) GetProjects 

func (m *ListPipelineRequest) GetProjects() []*pfs.Project

func (*ListPipelineRequest) Marshal 

func (m *ListPipelineRequest) Marshal() (dAtA []byte, err error)

func (*ListPipelineRequest) MarshalLogObject 

func (x *ListPipelineRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListPipelineRequest) MarshalTo 

func (m *ListPipelineRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListPipelineRequest) MarshalToSizedBuffer 

func (m *ListPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListPipelineRequest) ProtoMessage 

func (*ListPipelineRequest) ProtoMessage()

func (*ListPipelineRequest) Reset 

func (m *ListPipelineRequest) Reset()

func (*ListPipelineRequest) Size 

func (m *ListPipelineRequest) Size() (n int)

func (*ListPipelineRequest) String 

func (m *ListPipelineRequest) String() string

func (*ListPipelineRequest) Unmarshal 

func (m *ListPipelineRequest) Unmarshal(dAtA []byte) error

func (*ListPipelineRequest) XXX_DiscardUnknown 

func (m *ListPipelineRequest) XXX_DiscardUnknown()

func (*ListPipelineRequest) XXX_Marshal 

func (m *ListPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListPipelineRequest) XXX_Merge 

func (m *ListPipelineRequest) XXX_Merge(src proto.Message)

func (*ListPipelineRequest) XXX_Size 

func (m *ListPipelineRequest) XXX_Size() int

func (*ListPipelineRequest) XXX_Unmarshal 

func (m *ListPipelineRequest) XXX_Unmarshal(b []byte) error

type LogMessage 

type LogMessage struct {
	// The job and pipeline for which a PFS file is being processed (if the job
	// is an orphan job, pipeline name and ID will be unset)
	ProjectName  string `protobuf:"bytes,10,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	PipelineName string `protobuf:"bytes,1,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"`
	JobID        string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	WorkerID     string `protobuf:"bytes,3,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	DatumID      string `protobuf:"bytes,4,opt,name=datum_id,json=datumId,proto3" json:"datum_id,omitempty"`
	Master       bool   `protobuf:"varint,5,opt,name=master,proto3" json:"master,omitempty"`
	// The PFS files being processed (one per pipeline/job input)
	Data []*InputFile `protobuf:"bytes,6,rep,name=data,proto3" json:"data,omitempty"`
	// User is true if log message comes from the users code.
	User bool `protobuf:"varint,7,opt,name=user,proto3" json:"user,omitempty"`
	// The message logged, and the time at which it was logged
	Ts                   *types.Timestamp `protobuf:"bytes,8,opt,name=ts,proto3" json:"ts,omitempty"`
	Message              string           `protobuf:"bytes,9,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

LogMessage is a log line from a PPS worker, annotated with metadata indicating when and why the line was logged.

func (*LogMessage) Descriptor 

func (*LogMessage) Descriptor() ([]byte, []int)

func (*LogMessage) GetData 

func (m *LogMessage) GetData() []*InputFile

func (*LogMessage) GetDatumID 

func (m *LogMessage) GetDatumID() string

func (*LogMessage) GetJobID 

func (m *LogMessage) GetJobID() string

func (*LogMessage) GetMaster 

func (m *LogMessage) GetMaster() bool

func (*LogMessage) GetMessage 

func (m *LogMessage) GetMessage() string

func (*LogMessage) GetPipelineName 

func (m *LogMessage) GetPipelineName() string

func (*LogMessage) GetProjectName 

func (m *LogMessage) GetProjectName() string

func (*LogMessage) GetTs 

func (m *LogMessage) GetTs() *types.Timestamp

func (*LogMessage) GetUser 

func (m *LogMessage) GetUser() bool

func (*LogMessage) GetWorkerID 

func (m *LogMessage) GetWorkerID() string

func (*LogMessage) Marshal 

func (m *LogMessage) Marshal() (dAtA []byte, err error)

func (*LogMessage) MarshalLogObject 

func (x *LogMessage) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*LogMessage) MarshalTo 

func (m *LogMessage) MarshalTo(dAtA []byte) (int, error)

func (*LogMessage) MarshalToSizedBuffer 

func (m *LogMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogMessage) ProtoMessage 

func (*LogMessage) ProtoMessage()

func (*LogMessage) Reset 

func (m *LogMessage) Reset()

func (*LogMessage) Size 

func (m *LogMessage) Size() (n int)

func (*LogMessage) String 

func (m *LogMessage) String() string

func (*LogMessage) Unmarshal 

func (m *LogMessage) Unmarshal(dAtA []byte) error

func (*LogMessage) XXX_DiscardUnknown 

func (m *LogMessage) XXX_DiscardUnknown()

func (*LogMessage) XXX_Marshal 

func (m *LogMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogMessage) XXX_Merge 

func (m *LogMessage) XXX_Merge(src proto.Message)

func (*LogMessage) XXX_Size 

func (m *LogMessage) XXX_Size() int

func (*LogMessage) XXX_Unmarshal 

func (m *LogMessage) XXX_Unmarshal(b []byte) error

type LokiLogMessage 

type LokiLogMessage struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LokiLogMessage) Descriptor 

func (*LokiLogMessage) Descriptor() ([]byte, []int)

func (*LokiLogMessage) GetMessage 

func (m *LokiLogMessage) GetMessage() string

func (*LokiLogMessage) Marshal 

func (m *LokiLogMessage) Marshal() (dAtA []byte, err error)

func (*LokiLogMessage) MarshalLogObject 

func (x *LokiLogMessage) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*LokiLogMessage) MarshalTo 

func (m *LokiLogMessage) MarshalTo(dAtA []byte) (int, error)

func (*LokiLogMessage) MarshalToSizedBuffer 

func (m *LokiLogMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LokiLogMessage) ProtoMessage 

func (*LokiLogMessage) ProtoMessage()

func (*LokiLogMessage) Reset 

func (m *LokiLogMessage) Reset()

func (*LokiLogMessage) Size 

func (m *LokiLogMessage) Size() (n int)

func (*LokiLogMessage) String 

func (m *LokiLogMessage) String() string

func (*LokiLogMessage) Unmarshal 

func (m *LokiLogMessage) Unmarshal(dAtA []byte) error

func (*LokiLogMessage) XXX_DiscardUnknown 

func (m *LokiLogMessage) XXX_DiscardUnknown()

func (*LokiLogMessage) XXX_Marshal 

func (m *LokiLogMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LokiLogMessage) XXX_Merge 

func (m *LokiLogMessage) XXX_Merge(src proto.Message)

func (*LokiLogMessage) XXX_Size 

func (m *LokiLogMessage) XXX_Size() int

func (*LokiLogMessage) XXX_Unmarshal 

func (m *LokiLogMessage) XXX_Unmarshal(b []byte) error

type LokiRequest 

type LokiRequest struct {
	Since                *types.Duration `protobuf:"bytes,1,opt,name=since,proto3" json:"since,omitempty"`
	Query                string          `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*LokiRequest) Descriptor 

func (*LokiRequest) Descriptor() ([]byte, []int)

func (*LokiRequest) GetQuery 

func (m *LokiRequest) GetQuery() string

func (*LokiRequest) GetSince 

func (m *LokiRequest) GetSince() *types.Duration

func (*LokiRequest) Marshal 

func (m *LokiRequest) Marshal() (dAtA []byte, err error)

func (*LokiRequest) MarshalLogObject 

func (x *LokiRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*LokiRequest) MarshalTo 

func (m *LokiRequest) MarshalTo(dAtA []byte) (int, error)

func (*LokiRequest) MarshalToSizedBuffer 

func (m *LokiRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LokiRequest) ProtoMessage 

func (*LokiRequest) ProtoMessage()

func (*LokiRequest) Reset 

func (m *LokiRequest) Reset()

func (*LokiRequest) Size 

func (m *LokiRequest) Size() (n int)

func (*LokiRequest) String 

func (m *LokiRequest) String() string

func (*LokiRequest) Unmarshal 

func (m *LokiRequest) Unmarshal(dAtA []byte) error

func (*LokiRequest) XXX_DiscardUnknown 

func (m *LokiRequest) XXX_DiscardUnknown()

func (*LokiRequest) XXX_Marshal 

func (m *LokiRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LokiRequest) XXX_Merge 

func (m *LokiRequest) XXX_Merge(src proto.Message)

func (*LokiRequest) XXX_Size 

func (m *LokiRequest) XXX_Size() int

func (*LokiRequest) XXX_Unmarshal 

func (m *LokiRequest) XXX_Unmarshal(b []byte) error

type Metadata 

type Metadata struct {
	Annotations          map[string]string `` /* 163-byte string literal not displayed */
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Metadata) Descriptor 

func (*Metadata) Descriptor() ([]byte, []int)

func (*Metadata) GetAnnotations 

func (m *Metadata) GetAnnotations() map[string]string

func (*Metadata) GetLabels 

func (m *Metadata) GetLabels() map[string]string

func (*Metadata) Marshal 

func (m *Metadata) Marshal() (dAtA []byte, err error)

func (*Metadata) MarshalLogObject 

func (x *Metadata) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Metadata) MarshalTo 

func (m *Metadata) MarshalTo(dAtA []byte) (int, error)

func (*Metadata) MarshalToSizedBuffer 

func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

func (m *Metadata) Size() (n int)

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) Unmarshal 

func (m *Metadata) Unmarshal(dAtA []byte) error

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metadata) XXX_Merge 

func (m *Metadata) XXX_Merge(src proto.Message)

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

func (m *Metadata) XXX_Unmarshal(b []byte) error

type PFSInput 

type PFSInput struct {
	Project   string `protobuf:"bytes,14,opt,name=project,proto3" json:"project,omitempty"`
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Repo      string `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	RepoType  string `protobuf:"bytes,13,opt,name=repo_type,json=repoType,proto3" json:"repo_type,omitempty"`
	Branch    string `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"`
	Commit    string `protobuf:"bytes,4,opt,name=commit,proto3" json:"commit,omitempty"`
	Glob      string `protobuf:"bytes,5,opt,name=glob,proto3" json:"glob,omitempty"`
	JoinOn    string `protobuf:"bytes,6,opt,name=join_on,json=joinOn,proto3" json:"join_on,omitempty"`
	OuterJoin bool   `protobuf:"varint,7,opt,name=outer_join,json=outerJoin,proto3" json:"outer_join,omitempty"`
	GroupBy   string `protobuf:"bytes,8,opt,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"`
	Lazy      bool   `protobuf:"varint,9,opt,name=lazy,proto3" json:"lazy,omitempty"`
	// EmptyFiles, if true, will cause files from this PFS input to be
	// presented as empty files. This is useful in shuffle pipelines where you
	// want to read the names of files and reorganize them using symlinks.
	EmptyFiles bool `protobuf:"varint,10,opt,name=empty_files,json=emptyFiles,proto3" json:"empty_files,omitempty"`
	// S3, if true, will cause the worker to NOT download or link files from this
	// input into the /pfs_v2 directory. Instead, an instance of our S3 gateway
	// service will run on each of the sidecars, and data can be retrieved from
	// this input by querying
	// http://<pipeline>-s3.<namespace>/<job id>.<input>/my/file
	S3 bool `protobuf:"varint,11,opt,name=s3,proto3" json:"s3,omitempty"`
	// Trigger defines when this input is processed by the pipeline, if it's nil
	// the input is processed anytime something is committed to the input branch.
	Trigger              *pfs.Trigger `protobuf:"bytes,12,opt,name=trigger,proto3" json:"trigger,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PFSInput) Descriptor 

func (*PFSInput) Descriptor() ([]byte, []int)

func (*PFSInput) GetBranch 

func (m *PFSInput) GetBranch() string

func (*PFSInput) GetCommit 

func (m *PFSInput) GetCommit() string

func (*PFSInput) GetEmptyFiles 

func (m *PFSInput) GetEmptyFiles() bool

func (*PFSInput) GetGlob 

func (m *PFSInput) GetGlob() string

func (*PFSInput) GetGroupBy 

func (m *PFSInput) GetGroupBy() string

func (*PFSInput) GetJoinOn 

func (m *PFSInput) GetJoinOn() string

func (*PFSInput) GetLazy 

func (m *PFSInput) GetLazy() bool

func (*PFSInput) GetName 

func (m *PFSInput) GetName() string

func (*PFSInput) GetOuterJoin 

func (m *PFSInput) GetOuterJoin() bool

func (*PFSInput) GetProject 

func (m *PFSInput) GetProject() string

func (*PFSInput) GetRepo 

func (m *PFSInput) GetRepo() string

func (*PFSInput) GetRepoType 

func (m *PFSInput) GetRepoType() string

func (*PFSInput) GetS3 

func (m *PFSInput) GetS3() bool

func (*PFSInput) GetTrigger 

func (m *PFSInput) GetTrigger() *pfs.Trigger

func (*PFSInput) Marshal 

func (m *PFSInput) Marshal() (dAtA []byte, err error)

func (*PFSInput) MarshalLogObject 

func (x *PFSInput) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*PFSInput) MarshalTo 

func (m *PFSInput) MarshalTo(dAtA []byte) (int, error)

func (*PFSInput) MarshalToSizedBuffer 

func (m *PFSInput) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PFSInput) ProtoMessage 

func (*PFSInput) ProtoMessage()

func (*PFSInput) Reset 

func (m *PFSInput) Reset()

func (*PFSInput) Size 

func (m *PFSInput) Size() (n int)

func (*PFSInput) String 

func (m *PFSInput) String() string

func (*PFSInput) Unmarshal 

func (m *PFSInput) Unmarshal(dAtA []byte) error

func (*PFSInput) XXX_DiscardUnknown 

func (m *PFSInput) XXX_DiscardUnknown()

func (*PFSInput) XXX_Marshal 

func (m *PFSInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PFSInput) XXX_Merge 

func (m *PFSInput) XXX_Merge(src proto.Message)

func (*PFSInput) XXX_Size 

func (m *PFSInput) XXX_Size() int

func (*PFSInput) XXX_Unmarshal 

func (m *PFSInput) XXX_Unmarshal(b []byte) error

type ParallelismSpec 

type ParallelismSpec struct {
	// Starts the pipeline/job with a 'constant' workers, unless 'constant' is
	// zero. If 'constant' is zero (which is the zero value of ParallelismSpec),
	// then Pachyderm will choose the number of workers that is started,
	// (currently it chooses the number of workers in the cluster)
	Constant             uint64   `protobuf:"varint,1,opt,name=constant,proto3" json:"constant,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ParallelismSpec) Descriptor 

func (*ParallelismSpec) Descriptor() ([]byte, []int)

func (*ParallelismSpec) GetConstant 

func (m *ParallelismSpec) GetConstant() uint64

func (*ParallelismSpec) Marshal 

func (m *ParallelismSpec) Marshal() (dAtA []byte, err error)

func (*ParallelismSpec) MarshalLogObject 

func (x *ParallelismSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ParallelismSpec) MarshalTo 

func (m *ParallelismSpec) MarshalTo(dAtA []byte) (int, error)

func (*ParallelismSpec) MarshalToSizedBuffer 

func (m *ParallelismSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ParallelismSpec) ProtoMessage 

func (*ParallelismSpec) ProtoMessage()

func (*ParallelismSpec) Reset 

func (m *ParallelismSpec) Reset()

func (*ParallelismSpec) Size 

func (m *ParallelismSpec) Size() (n int)

func (*ParallelismSpec) String 

func (m *ParallelismSpec) String() string

func (*ParallelismSpec) Unmarshal 

func (m *ParallelismSpec) Unmarshal(dAtA []byte) error

func (*ParallelismSpec) XXX_DiscardUnknown 

func (m *ParallelismSpec) XXX_DiscardUnknown()

func (*ParallelismSpec) XXX_Marshal 

func (m *ParallelismSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParallelismSpec) XXX_Merge 

func (m *ParallelismSpec) XXX_Merge(src proto.Message)

func (*ParallelismSpec) XXX_Size 

func (m *ParallelismSpec) XXX_Size() int

func (*ParallelismSpec) XXX_Unmarshal 

func (m *ParallelismSpec) XXX_Unmarshal(b []byte) error

type Pipeline 

type Pipeline struct {
	Project              *pfs.Project `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func RepoPipeline 

func RepoPipeline(r *pfs.Repo) *Pipeline

RepoPipeline returns a Pipeline with the same project and name as the repo.

func (*Pipeline) Descriptor 

func (*Pipeline) Descriptor() ([]byte, []int)

func (*Pipeline) GetName 

func (m *Pipeline) GetName() string

func (*Pipeline) GetProject 

func (m *Pipeline) GetProject() *pfs.Project

func (*Pipeline) Marshal 

func (m *Pipeline) Marshal() (dAtA []byte, err error)

func (*Pipeline) MarshalLogObject 

func (x *Pipeline) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Pipeline) MarshalTo 

func (m *Pipeline) MarshalTo(dAtA []byte) (int, error)

func (*Pipeline) MarshalToSizedBuffer 

func (m *Pipeline) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Pipeline) ProtoMessage 

func (*Pipeline) ProtoMessage()

func (*Pipeline) Reset 

func (m *Pipeline) Reset()

func (*Pipeline) Size 

func (m *Pipeline) Size() (n int)

func (*Pipeline) String 

func (p *Pipeline) String() string

func (*Pipeline) Unmarshal 

func (m *Pipeline) Unmarshal(dAtA []byte) error

func (*Pipeline) XXX_DiscardUnknown 

func (m *Pipeline) XXX_DiscardUnknown()

func (*Pipeline) XXX_Marshal 

func (m *Pipeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pipeline) XXX_Merge 

func (m *Pipeline) XXX_Merge(src proto.Message)

func (*Pipeline) XXX_Size 

func (m *Pipeline) XXX_Size() int

func (*Pipeline) XXX_Unmarshal 

func (m *Pipeline) XXX_Unmarshal(b []byte) error

type PipelineInfo 

type PipelineInfo struct {
	Pipeline   *Pipeline   `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Version    uint64      `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	SpecCommit *pfs.Commit `protobuf:"bytes,3,opt,name=spec_commit,json=specCommit,proto3" json:"spec_commit,omitempty"`
	Stopped    bool        `protobuf:"varint,4,opt,name=stopped,proto3" json:"stopped,omitempty"`
	// state indicates the current state of the pipeline
	State PipelineState `protobuf:"varint,5,opt,name=state,proto3,enum=pps_v2.PipelineState" json:"state,omitempty"`
	// reason includes any error messages associated with a failed pipeline
	Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	// last_job_state indicates the state of the most recently created job
	LastJobState JobState `protobuf:"varint,8,opt,name=last_job_state,json=lastJobState,proto3,enum=pps_v2.JobState" json:"last_job_state,omitempty"`
	// parallelism tracks the literal number of workers that this pipeline should
	// run.
	Parallelism          uint64                    `protobuf:"varint,9,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	Type                 PipelineInfo_PipelineType `protobuf:"varint,10,opt,name=type,proto3,enum=pps_v2.PipelineInfo_PipelineType" json:"type,omitempty"`
	AuthToken            string                    `protobuf:"bytes,11,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	Details              *PipelineInfo_Details     `protobuf:"bytes,12,opt,name=details,proto3" json:"details,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

PipelineInfo is proto for each pipeline that Pachd stores in the database. It tracks the state of the pipeline, and points to its metadata in PFS (and, by pointing to a PFS commit, de facto tracks the pipeline's version). Any information about the pipeline _not_ stored in the database is in the Details object, which requires fetching the spec from PFS or other potentially expensive operations.

func (*PipelineInfo) Descriptor 

func (*PipelineInfo) Descriptor() ([]byte, []int)

func (*PipelineInfo) GetAuthToken 

func (m *PipelineInfo) GetAuthToken() string

func (*PipelineInfo) GetDetails 

func (m *PipelineInfo) GetDetails() *PipelineInfo_Details

func (*PipelineInfo) GetLastJobState 

func (m *PipelineInfo) GetLastJobState() JobState

func (*PipelineInfo) GetParallelism 

func (m *PipelineInfo) GetParallelism() uint64

func (*PipelineInfo) GetPipeline 

func (m *PipelineInfo) GetPipeline() *Pipeline

func (*PipelineInfo) GetReason 

func (m *PipelineInfo) GetReason() string

func (*PipelineInfo) GetSpecCommit 

func (m *PipelineInfo) GetSpecCommit() *pfs.Commit

func (*PipelineInfo) GetState 

func (m *PipelineInfo) GetState() PipelineState

func (*PipelineInfo) GetStopped 

func (m *PipelineInfo) GetStopped() bool

func (*PipelineInfo) GetType 

func (m *PipelineInfo) GetType() PipelineInfo_PipelineType

func (*PipelineInfo) GetVersion 

func (m *PipelineInfo) GetVersion() uint64

func (*PipelineInfo) Marshal 

func (m *PipelineInfo) Marshal() (dAtA []byte, err error)

func (*PipelineInfo) MarshalLogObject 

func (x *PipelineInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*PipelineInfo) MarshalTo 

func (m *PipelineInfo) MarshalTo(dAtA []byte) (int, error)

func (*PipelineInfo) MarshalToSizedBuffer 

func (m *PipelineInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PipelineInfo) ProtoMessage 

func (*PipelineInfo) ProtoMessage()

func (*PipelineInfo) Reset 

func (m *PipelineInfo) Reset()

func (*PipelineInfo) Size 

func (m *PipelineInfo) Size() (n int)

func (*PipelineInfo) String 

func (m *PipelineInfo) String() string

func (*PipelineInfo) Unmarshal 

func (m *PipelineInfo) Unmarshal(dAtA []byte) error

func (*PipelineInfo) XXX_DiscardUnknown 

func (m *PipelineInfo) XXX_DiscardUnknown()

func (*PipelineInfo) XXX_Marshal 

func (m *PipelineInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineInfo) XXX_Merge 

func (m *PipelineInfo) XXX_Merge(src proto.Message)

func (*PipelineInfo) XXX_Size 

func (m *PipelineInfo) XXX_Size() int

func (*PipelineInfo) XXX_Unmarshal 

func (m *PipelineInfo) XXX_Unmarshal(b []byte) error

type PipelineInfo_Details 

type PipelineInfo_Details struct {
	Transform *Transform `protobuf:"bytes,1,opt,name=transform,proto3" json:"transform,omitempty"`
	// tf_job encodes a Kubeflow TFJob spec. Pachyderm uses this to create TFJobs
	// when running in a kubernetes cluster on which kubeflow has been installed.
	// Exactly one of 'tf_job' and 'transform' should be set
	TFJob                   *TFJob           `protobuf:"bytes,2,opt,name=tf_job,json=tfJob,proto3" json:"tf_job,omitempty"`
	ParallelismSpec         *ParallelismSpec `protobuf:"bytes,3,opt,name=parallelism_spec,json=parallelismSpec,proto3" json:"parallelism_spec,omitempty"`
	Egress                  *Egress          `protobuf:"bytes,4,opt,name=egress,proto3" json:"egress,omitempty"`
	CreatedAt               *types.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	RecentError             string           `protobuf:"bytes,6,opt,name=recent_error,json=recentError,proto3" json:"recent_error,omitempty"`
	WorkersRequested        int64            `protobuf:"varint,7,opt,name=workers_requested,json=workersRequested,proto3" json:"workers_requested,omitempty"`
	WorkersAvailable        int64            `protobuf:"varint,8,opt,name=workers_available,json=workersAvailable,proto3" json:"workers_available,omitempty"`
	OutputBranch            string           `protobuf:"bytes,9,opt,name=output_branch,json=outputBranch,proto3" json:"output_branch,omitempty"`
	ResourceRequests        *ResourceSpec    `protobuf:"bytes,10,opt,name=resource_requests,json=resourceRequests,proto3" json:"resource_requests,omitempty"`
	ResourceLimits          *ResourceSpec    `protobuf:"bytes,11,opt,name=resource_limits,json=resourceLimits,proto3" json:"resource_limits,omitempty"`
	SidecarResourceLimits   *ResourceSpec    `` /* 127-byte string literal not displayed */
	Input                   *Input           `protobuf:"bytes,13,opt,name=input,proto3" json:"input,omitempty"`
	Description             string           `protobuf:"bytes,14,opt,name=description,proto3" json:"description,omitempty"`
	Salt                    string           `protobuf:"bytes,16,opt,name=salt,proto3" json:"salt,omitempty"`
	Reason                  string           `protobuf:"bytes,17,opt,name=reason,proto3" json:"reason,omitempty"`
	Service                 *Service         `protobuf:"bytes,19,opt,name=service,proto3" json:"service,omitempty"`
	Spout                   *Spout           `protobuf:"bytes,20,opt,name=spout,proto3" json:"spout,omitempty"`
	DatumSetSpec            *DatumSetSpec    `protobuf:"bytes,21,opt,name=datum_set_spec,json=datumSetSpec,proto3" json:"datum_set_spec,omitempty"`
	DatumTimeout            *types.Duration  `protobuf:"bytes,22,opt,name=datum_timeout,json=datumTimeout,proto3" json:"datum_timeout,omitempty"`
	JobTimeout              *types.Duration  `protobuf:"bytes,23,opt,name=job_timeout,json=jobTimeout,proto3" json:"job_timeout,omitempty"`
	DatumTries              int64            `protobuf:"varint,24,opt,name=datum_tries,json=datumTries,proto3" json:"datum_tries,omitempty"`
	SchedulingSpec          *SchedulingSpec  `protobuf:"bytes,25,opt,name=scheduling_spec,json=schedulingSpec,proto3" json:"scheduling_spec,omitempty"`
	PodSpec                 string           `protobuf:"bytes,26,opt,name=pod_spec,json=podSpec,proto3" json:"pod_spec,omitempty"`
	PodPatch                string           `protobuf:"bytes,27,opt,name=pod_patch,json=podPatch,proto3" json:"pod_patch,omitempty"`
	S3Out                   bool             `protobuf:"varint,28,opt,name=s3_out,json=s3Out,proto3" json:"s3_out,omitempty"`
	Metadata                *Metadata        `protobuf:"bytes,29,opt,name=metadata,proto3" json:"metadata,omitempty"`
	ReprocessSpec           string           `protobuf:"bytes,30,opt,name=reprocess_spec,json=reprocessSpec,proto3" json:"reprocess_spec,omitempty"`
	UnclaimedTasks          int64            `protobuf:"varint,31,opt,name=unclaimed_tasks,json=unclaimedTasks,proto3" json:"unclaimed_tasks,omitempty"`
	WorkerRc                string           `protobuf:"bytes,32,opt,name=worker_rc,json=workerRc,proto3" json:"worker_rc,omitempty"`
	Autoscaling             bool             `protobuf:"varint,33,opt,name=autoscaling,proto3" json:"autoscaling,omitempty"`
	Tolerations             []*Toleration    `protobuf:"bytes,34,rep,name=tolerations,proto3" json:"tolerations,omitempty"`
	SidecarResourceRequests *ResourceSpec    `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}         `json:"-"`
	XXX_unrecognized        []byte           `json:"-"`
	XXX_sizecache           int32            `json:"-"`
}

func (*PipelineInfo_Details) Descriptor 

func (*PipelineInfo_Details) Descriptor() ([]byte, []int)

func (*PipelineInfo_Details) GetAutoscaling 

func (m *PipelineInfo_Details) GetAutoscaling() bool

func (*PipelineInfo_Details) GetCreatedAt 

func (m *PipelineInfo_Details) GetCreatedAt() *types.Timestamp

func (*PipelineInfo_Details) GetDatumSetSpec 

func (m *PipelineInfo_Details) GetDatumSetSpec() *DatumSetSpec

func (*PipelineInfo_Details) GetDatumTimeout 

func (m *PipelineInfo_Details) GetDatumTimeout() *types.Duration

func (*PipelineInfo_Details) GetDatumTries 

func (m *PipelineInfo_Details) GetDatumTries() int64

func (*PipelineInfo_Details) GetDescription 

func (m *PipelineInfo_Details) GetDescription() string

func (*PipelineInfo_Details) GetEgress 

func (m *PipelineInfo_Details) GetEgress() *Egress

func (*PipelineInfo_Details) GetInput 

func (m *PipelineInfo_Details) GetInput() *Input

func (*PipelineInfo_Details) GetJobTimeout 

func (m *PipelineInfo_Details) GetJobTimeout() *types.Duration

func (*PipelineInfo_Details) GetMetadata 

func (m *PipelineInfo_Details) GetMetadata() *Metadata

func (*PipelineInfo_Details) GetOutputBranch 

func (m *PipelineInfo_Details) GetOutputBranch() string

func (*PipelineInfo_Details) GetParallelismSpec 

func (m *PipelineInfo_Details) GetParallelismSpec() *ParallelismSpec

func (*PipelineInfo_Details) GetPodPatch 

func (m *PipelineInfo_Details) GetPodPatch() string

func (*PipelineInfo_Details) GetPodSpec 

func (m *PipelineInfo_Details) GetPodSpec() string

func (*PipelineInfo_Details) GetReason 

func (m *PipelineInfo_Details) GetReason() string

func (*PipelineInfo_Details) GetRecentError 

func (m *PipelineInfo_Details) GetRecentError() string

func (*PipelineInfo_Details) GetReprocessSpec 

func (m *PipelineInfo_Details) GetReprocessSpec() string

func (*PipelineInfo_Details) GetResourceLimits 

func (m *PipelineInfo_Details) GetResourceLimits() *ResourceSpec

func (*PipelineInfo_Details) GetResourceRequests 

func (m *PipelineInfo_Details) GetResourceRequests() *ResourceSpec

func (*PipelineInfo_Details) GetS3Out 

func (m *PipelineInfo_Details) GetS3Out() bool

func (*PipelineInfo_Details) GetSalt 

func (m *PipelineInfo_Details) GetSalt() string

func (*PipelineInfo_Details) GetSchedulingSpec 

func (m *PipelineInfo_Details) GetSchedulingSpec() *SchedulingSpec

func (*PipelineInfo_Details) GetService 

func (m *PipelineInfo_Details) GetService() *Service

func (*PipelineInfo_Details) GetSidecarResourceLimits 

func (m *PipelineInfo_Details) GetSidecarResourceLimits() *ResourceSpec

func (*PipelineInfo_Details) GetSidecarResourceRequests 

func (m *PipelineInfo_Details) GetSidecarResourceRequests() *ResourceSpec

func (*PipelineInfo_Details) GetSpout 

func (m *PipelineInfo_Details) GetSpout() *Spout

func (*PipelineInfo_Details) GetTFJob 

func (m *PipelineInfo_Details) GetTFJob() *TFJob

func (*PipelineInfo_Details) GetTolerations 

func (m *PipelineInfo_Details) GetTolerations() []*Toleration

func (*PipelineInfo_Details) GetTransform 

func (m *PipelineInfo_Details) GetTransform() *Transform

func (*PipelineInfo_Details) GetUnclaimedTasks 

func (m *PipelineInfo_Details) GetUnclaimedTasks() int64

func (*PipelineInfo_Details) GetWorkerRc 

func (m *PipelineInfo_Details) GetWorkerRc() string

func (*PipelineInfo_Details) GetWorkersAvailable 

func (m *PipelineInfo_Details) GetWorkersAvailable() int64

func (*PipelineInfo_Details) GetWorkersRequested 

func (m *PipelineInfo_Details) GetWorkersRequested() int64

func (*PipelineInfo_Details) Marshal 

func (m *PipelineInfo_Details) Marshal() (dAtA []byte, err error)

func (*PipelineInfo_Details) MarshalLogObject 

func (x *PipelineInfo_Details) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*PipelineInfo_Details) MarshalTo 

func (m *PipelineInfo_Details) MarshalTo(dAtA []byte) (int, error)

func (*PipelineInfo_Details) MarshalToSizedBuffer 

func (m *PipelineInfo_Details) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PipelineInfo_Details) ProtoMessage 

func (*PipelineInfo_Details) ProtoMessage()

func (*PipelineInfo_Details) Reset 

func (m *PipelineInfo_Details) Reset()

func (*PipelineInfo_Details) Size 

func (m *PipelineInfo_Details) Size() (n int)

func (*PipelineInfo_Details) String 

func (m *PipelineInfo_Details) String() string

func (*PipelineInfo_Details) Unmarshal 

func (m *PipelineInfo_Details) Unmarshal(dAtA []byte) error

func (*PipelineInfo_Details) XXX_DiscardUnknown 

func (m *PipelineInfo_Details) XXX_DiscardUnknown()

func (*PipelineInfo_Details) XXX_Marshal 

func (m *PipelineInfo_Details) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineInfo_Details) XXX_Merge 

func (m *PipelineInfo_Details) XXX_Merge(src proto.Message)

func (*PipelineInfo_Details) XXX_Size 

func (m *PipelineInfo_Details) XXX_Size() int

func (*PipelineInfo_Details) XXX_Unmarshal 

func (m *PipelineInfo_Details) XXX_Unmarshal(b []byte) error

type PipelineInfo_PipelineType 

type PipelineInfo_PipelineType int32

The pipeline type is stored here so that we can internally know the type of the pipeline without loading the spec from PFS. 

const (
	PipelineInfo_PIPELINT_TYPE_UNKNOWN   PipelineInfo_PipelineType = 0
	PipelineInfo_PIPELINE_TYPE_TRANSFORM PipelineInfo_PipelineType = 1
	PipelineInfo_PIPELINE_TYPE_SPOUT     PipelineInfo_PipelineType = 2
	PipelineInfo_PIPELINE_TYPE_SERVICE   PipelineInfo_PipelineType = 3
)

func (PipelineInfo_PipelineType) EnumDescriptor 

func (PipelineInfo_PipelineType) EnumDescriptor() ([]byte, []int)

func (PipelineInfo_PipelineType) String 

func (x PipelineInfo_PipelineType) String() string

type PipelineInfos 

type PipelineInfos struct {
	PipelineInfo         []*PipelineInfo `protobuf:"bytes,1,rep,name=pipeline_info,json=pipelineInfo,proto3" json:"pipeline_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PipelineInfos) Descriptor 

func (*PipelineInfos) Descriptor() ([]byte, []int)

func (*PipelineInfos) GetPipelineInfo 

func (m *PipelineInfos) GetPipelineInfo() []*PipelineInfo

func (*PipelineInfos) Marshal 

func (m *PipelineInfos) Marshal() (dAtA []byte, err error)

func (*PipelineInfos) MarshalLogObject 

func (x *PipelineInfos) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*PipelineInfos) MarshalTo 

func (m *PipelineInfos) MarshalTo(dAtA []byte) (int, error)

func (*PipelineInfos) MarshalToSizedBuffer 

func (m *PipelineInfos) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PipelineInfos) ProtoMessage 

func (*PipelineInfos) ProtoMessage()

func (*PipelineInfos) Reset 

func (m *PipelineInfos) Reset()

func (*PipelineInfos) Size 

func (m *PipelineInfos) Size() (n int)

func (*PipelineInfos) String 

func (m *PipelineInfos) String() string

func (*PipelineInfos) Unmarshal 

func (m *PipelineInfos) Unmarshal(dAtA []byte) error

func (*PipelineInfos) XXX_DiscardUnknown 

func (m *PipelineInfos) XXX_DiscardUnknown()

func (*PipelineInfos) XXX_Marshal 

func (m *PipelineInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineInfos) XXX_Merge 

func (m *PipelineInfos) XXX_Merge(src proto.Message)

func (*PipelineInfos) XXX_Size 

func (m *PipelineInfos) XXX_Size() int

func (*PipelineInfos) XXX_Unmarshal 

func (m *PipelineInfos) XXX_Unmarshal(b []byte) error

type PipelineState 

type PipelineState int32
const (
	PipelineState_PIPELINE_STATE_UNKNOWN PipelineState = 0
	// There is a PipelineInfo + spec commit, but no RC
	// This happens when a pipeline has been created but not yet picked up by a
	// PPS server.
	PipelineState_PIPELINE_STARTING PipelineState = 1
	// A pipeline has a spec commit and a service + RC
	// This is the normal state of a pipeline.
	PipelineState_PIPELINE_RUNNING PipelineState = 2
	// Equivalent to STARTING (there is a PipelineInfo + commit, but no RC)
	// After some error caused runPipeline to exit, but before the pipeline is
	// re-run. This is when the exponential backoff is in effect.
	PipelineState_PIPELINE_RESTARTING PipelineState = 3
	// The pipeline has encountered unrecoverable errors and is no longer being
	// retried. It won't leave this state until the pipeline is updated.
	PipelineState_PIPELINE_FAILURE PipelineState = 4
	// The pipeline has been explicitly paused by the user (the pipeline spec's
	// Stopped field should be true if the pipeline is in this state)
	PipelineState_PIPELINE_PAUSED PipelineState = 5
	// The pipeline is fully functional, but there are no commits to process.
	PipelineState_PIPELINE_STANDBY PipelineState = 6
	// The pipeline's workers are crashing, or failing to come up, this may
	// resolve itself, the pipeline may make progress while in this state if the
	// problem is only being experienced by some workers.
	PipelineState_PIPELINE_CRASHING PipelineState = 7
)

func PipelineStateFromName 

func PipelineStateFromName(name string) (PipelineState, error)

PipelineStateFromName attempts to interpret a string as a PipelineState, accepting either the enum names or the pretty printed state names

func (PipelineState) EnumDescriptor 

func (PipelineState) EnumDescriptor() ([]byte, []int)

func (PipelineState) String 

func (x PipelineState) String() string

type ProcessStats 

type ProcessStats struct {
	DownloadTime         *types.Duration `protobuf:"bytes,1,opt,name=download_time,json=downloadTime,proto3" json:"download_time,omitempty"`
	ProcessTime          *types.Duration `protobuf:"bytes,2,opt,name=process_time,json=processTime,proto3" json:"process_time,omitempty"`
	UploadTime           *types.Duration `protobuf:"bytes,3,opt,name=upload_time,json=uploadTime,proto3" json:"upload_time,omitempty"`
	DownloadBytes        int64           `protobuf:"varint,4,opt,name=download_bytes,json=downloadBytes,proto3" json:"download_bytes,omitempty"`
	UploadBytes          int64           `protobuf:"varint,5,opt,name=upload_bytes,json=uploadBytes,proto3" json:"upload_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ProcessStats) Descriptor 

func (*ProcessStats) Descriptor() ([]byte, []int)

func (*ProcessStats) GetDownloadBytes 

func (m *ProcessStats) GetDownloadBytes() int64

func (*ProcessStats) GetDownloadTime 

func (m *ProcessStats) GetDownloadTime() *types.Duration

func (*ProcessStats) GetProcessTime 

func (m *ProcessStats) GetProcessTime() *types.Duration

func (*ProcessStats) GetUploadBytes 

func (m *ProcessStats) GetUploadBytes() int64

func (*ProcessStats) GetUploadTime 

func (m *ProcessStats) GetUploadTime() *types.Duration

func (*ProcessStats) Marshal 

func (m *ProcessStats) Marshal() (dAtA []byte, err error)

func (*ProcessStats) MarshalLogObject 

func (x *ProcessStats) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ProcessStats) MarshalTo 

func (m *ProcessStats) MarshalTo(dAtA []byte) (int, error)

func (*ProcessStats) MarshalToSizedBuffer 

func (m *ProcessStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProcessStats) ProtoMessage 

func (*ProcessStats) ProtoMessage()

func (*ProcessStats) Reset 

func (m *ProcessStats) Reset()

func (*ProcessStats) Size 

func (m *ProcessStats) Size() (n int)

func (*ProcessStats) String 

func (m *ProcessStats) String() string

func (*ProcessStats) Unmarshal 

func (m *ProcessStats) Unmarshal(dAtA []byte) error

func (*ProcessStats) XXX_DiscardUnknown 

func (m *ProcessStats) XXX_DiscardUnknown()

func (*ProcessStats) XXX_Marshal 

func (m *ProcessStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessStats) XXX_Merge 

func (m *ProcessStats) XXX_Merge(src proto.Message)

func (*ProcessStats) XXX_Size 

func (m *ProcessStats) XXX_Size() int

func (*ProcessStats) XXX_Unmarshal 

func (m *ProcessStats) XXX_Unmarshal(b []byte) error

type RenderTemplateRequest 

type RenderTemplateRequest struct {
	Template             string            `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	Args                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RenderTemplateRequest) Descriptor 

func (*RenderTemplateRequest) Descriptor() ([]byte, []int)

func (*RenderTemplateRequest) GetArgs 

func (m *RenderTemplateRequest) GetArgs() map[string]string

func (*RenderTemplateRequest) GetTemplate 

func (m *RenderTemplateRequest) GetTemplate() string

func (*RenderTemplateRequest) Marshal 

func (m *RenderTemplateRequest) Marshal() (dAtA []byte, err error)

func (*RenderTemplateRequest) MarshalLogObject 

func (x *RenderTemplateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RenderTemplateRequest) MarshalTo 

func (m *RenderTemplateRequest) MarshalTo(dAtA []byte) (int, error)

func (*RenderTemplateRequest) MarshalToSizedBuffer 

func (m *RenderTemplateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RenderTemplateRequest) ProtoMessage 

func (*RenderTemplateRequest) ProtoMessage()

func (*RenderTemplateRequest) Reset 

func (m *RenderTemplateRequest) Reset()

func (*RenderTemplateRequest) Size 

func (m *RenderTemplateRequest) Size() (n int)

func (*RenderTemplateRequest) String 

func (m *RenderTemplateRequest) String() string

func (*RenderTemplateRequest) Unmarshal 

func (m *RenderTemplateRequest) Unmarshal(dAtA []byte) error

func (*RenderTemplateRequest) XXX_DiscardUnknown 

func (m *RenderTemplateRequest) XXX_DiscardUnknown()

func (*RenderTemplateRequest) XXX_Marshal 

func (m *RenderTemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RenderTemplateRequest) XXX_Merge 

func (m *RenderTemplateRequest) XXX_Merge(src proto.Message)

func (*RenderTemplateRequest) XXX_Size 

func (m *RenderTemplateRequest) XXX_Size() int

func (*RenderTemplateRequest) XXX_Unmarshal 

func (m *RenderTemplateRequest) XXX_Unmarshal(b []byte) error

type RenderTemplateResponse 

type RenderTemplateResponse struct {
	Json                 string                   `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"`
	Specs                []*CreatePipelineRequest `protobuf:"bytes,2,rep,name=specs,proto3" json:"specs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*RenderTemplateResponse) Descriptor 

func (*RenderTemplateResponse) Descriptor() ([]byte, []int)

func (*RenderTemplateResponse) GetJson 

func (m *RenderTemplateResponse) GetJson() string

func (*RenderTemplateResponse) GetSpecs 

func (m *RenderTemplateResponse) GetSpecs() []*CreatePipelineRequest

func (*RenderTemplateResponse) Marshal 

func (m *RenderTemplateResponse) Marshal() (dAtA []byte, err error)

func (*RenderTemplateResponse) MarshalLogObject 

func (x *RenderTemplateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RenderTemplateResponse) MarshalTo 

func (m *RenderTemplateResponse) MarshalTo(dAtA []byte) (int, error)

func (*RenderTemplateResponse) MarshalToSizedBuffer 

func (m *RenderTemplateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RenderTemplateResponse) ProtoMessage 

func (*RenderTemplateResponse) ProtoMessage()

func (*RenderTemplateResponse) Reset 

func (m *RenderTemplateResponse) Reset()

func (*RenderTemplateResponse) Size 

func (m *RenderTemplateResponse) Size() (n int)

func (*RenderTemplateResponse) String 

func (m *RenderTemplateResponse) String() string

func (*RenderTemplateResponse) Unmarshal 

func (m *RenderTemplateResponse) Unmarshal(dAtA []byte) error

func (*RenderTemplateResponse) XXX_DiscardUnknown 

func (m *RenderTemplateResponse) XXX_DiscardUnknown()

func (*RenderTemplateResponse) XXX_Marshal 

func (m *RenderTemplateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RenderTemplateResponse) XXX_Merge 

func (m *RenderTemplateResponse) XXX_Merge(src proto.Message)

func (*RenderTemplateResponse) XXX_Size 

func (m *RenderTemplateResponse) XXX_Size() int

func (*RenderTemplateResponse) XXX_Unmarshal 

func (m *RenderTemplateResponse) XXX_Unmarshal(b []byte) error

type ResourceSpec 

type ResourceSpec struct {
	// The number of CPUs each worker needs (partial values are allowed, and
	// encouraged)
	Cpu float32 `protobuf:"fixed32,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// The amount of memory each worker needs (in bytes, with allowed
	// SI suffixes (M, K, G, Mi, Ki, Gi, etc).
	Memory string `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"`
	// The spec for GPU resources.
	Gpu *GPUSpec `protobuf:"bytes,3,opt,name=gpu,proto3" json:"gpu,omitempty"`
	// The amount of ephemeral storage each worker needs (in bytes, with allowed
	// SI suffixes (M, K, G, Mi, Ki, Gi, etc).
	Disk                 string   `protobuf:"bytes,4,opt,name=disk,proto3" json:"disk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ResourceSpec describes the amount of resources that pipeline pods should request from kubernetes, for scheduling.

func (*ResourceSpec) Descriptor 

func (*ResourceSpec) Descriptor() ([]byte, []int)

func (*ResourceSpec) GetCpu 

func (m *ResourceSpec) GetCpu() float32

func (*ResourceSpec) GetDisk 

func (m *ResourceSpec) GetDisk() string

func (*ResourceSpec) GetGpu 

func (m *ResourceSpec) GetGpu() *GPUSpec

func (*ResourceSpec) GetMemory 

func (m *ResourceSpec) GetMemory() string

func (*ResourceSpec) Marshal 

func (m *ResourceSpec) Marshal() (dAtA []byte, err error)

func (*ResourceSpec) MarshalLogObject 

func (x *ResourceSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ResourceSpec) MarshalTo 

func (m *ResourceSpec) MarshalTo(dAtA []byte) (int, error)

func (*ResourceSpec) MarshalToSizedBuffer 

func (m *ResourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResourceSpec) ProtoMessage 

func (*ResourceSpec) ProtoMessage()

func (*ResourceSpec) Reset 

func (m *ResourceSpec) Reset()

func (*ResourceSpec) Size 

func (m *ResourceSpec) Size() (n int)

func (*ResourceSpec) String 

func (m *ResourceSpec) String() string

func (*ResourceSpec) Unmarshal 

func (m *ResourceSpec) Unmarshal(dAtA []byte) error

func (*ResourceSpec) XXX_DiscardUnknown 

func (m *ResourceSpec) XXX_DiscardUnknown()

func (*ResourceSpec) XXX_Marshal 

func (m *ResourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourceSpec) XXX_Merge 

func (m *ResourceSpec) XXX_Merge(src proto.Message)

func (*ResourceSpec) XXX_Size 

func (m *ResourceSpec) XXX_Size() int

func (*ResourceSpec) XXX_Unmarshal 

func (m *ResourceSpec) XXX_Unmarshal(b []byte) error

type RestartDatumRequest 

type RestartDatumRequest struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	DataFilters          []string `protobuf:"bytes,2,rep,name=data_filters,json=dataFilters,proto3" json:"data_filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestartDatumRequest) Descriptor 

func (*RestartDatumRequest) Descriptor() ([]byte, []int)

func (*RestartDatumRequest) GetDataFilters 

func (m *RestartDatumRequest) GetDataFilters() []string

func (*RestartDatumRequest) GetJob 

func (m *RestartDatumRequest) GetJob() *Job

func (*RestartDatumRequest) Marshal 

func (m *RestartDatumRequest) Marshal() (dAtA []byte, err error)

func (*RestartDatumRequest) MarshalLogObject 

func (x *RestartDatumRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RestartDatumRequest) MarshalTo 

func (m *RestartDatumRequest) MarshalTo(dAtA []byte) (int, error)

func (*RestartDatumRequest) MarshalToSizedBuffer 

func (m *RestartDatumRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RestartDatumRequest) ProtoMessage 

func (*RestartDatumRequest) ProtoMessage()

func (*RestartDatumRequest) Reset 

func (m *RestartDatumRequest) Reset()

func (*RestartDatumRequest) Size 

func (m *RestartDatumRequest) Size() (n int)

func (*RestartDatumRequest) String 

func (m *RestartDatumRequest) String() string

func (*RestartDatumRequest) Unmarshal 

func (m *RestartDatumRequest) Unmarshal(dAtA []byte) error

func (*RestartDatumRequest) XXX_DiscardUnknown 

func (m *RestartDatumRequest) XXX_DiscardUnknown()

func (*RestartDatumRequest) XXX_Marshal 

func (m *RestartDatumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestartDatumRequest) XXX_Merge 

func (m *RestartDatumRequest) XXX_Merge(src proto.Message)

func (*RestartDatumRequest) XXX_Size 

func (m *RestartDatumRequest) XXX_Size() int

func (*RestartDatumRequest) XXX_Unmarshal 

func (m *RestartDatumRequest) XXX_Unmarshal(b []byte) error

type RunCronRequest 

type RunCronRequest struct {
	Pipeline             *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RunCronRequest) Descriptor 

func (*RunCronRequest) Descriptor() ([]byte, []int)

func (*RunCronRequest) GetPipeline 

func (m *RunCronRequest) GetPipeline() *Pipeline

func (*RunCronRequest) Marshal 

func (m *RunCronRequest) Marshal() (dAtA []byte, err error)

func (*RunCronRequest) MarshalLogObject 

func (x *RunCronRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RunCronRequest) MarshalTo 

func (m *RunCronRequest) MarshalTo(dAtA []byte) (int, error)

func (*RunCronRequest) MarshalToSizedBuffer 

func (m *RunCronRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RunCronRequest) ProtoMessage 

func (*RunCronRequest) ProtoMessage()

func (*RunCronRequest) Reset 

func (m *RunCronRequest) Reset()

func (*RunCronRequest) Size 

func (m *RunCronRequest) Size() (n int)

func (*RunCronRequest) String 

func (m *RunCronRequest) String() string

func (*RunCronRequest) Unmarshal 

func (m *RunCronRequest) Unmarshal(dAtA []byte) error

func (*RunCronRequest) XXX_DiscardUnknown 

func (m *RunCronRequest) XXX_DiscardUnknown()

func (*RunCronRequest) XXX_Marshal 

func (m *RunCronRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunCronRequest) XXX_Merge 

func (m *RunCronRequest) XXX_Merge(src proto.Message)

func (*RunCronRequest) XXX_Size 

func (m *RunCronRequest) XXX_Size() int

func (*RunCronRequest) XXX_Unmarshal 

func (m *RunCronRequest) XXX_Unmarshal(b []byte) error

type RunLoadTestRequest 

type RunLoadTestRequest struct {
	DagSpec              string   `protobuf:"bytes,1,opt,name=dag_spec,json=dagSpec,proto3" json:"dag_spec,omitempty"`
	LoadSpec             string   `protobuf:"bytes,2,opt,name=load_spec,json=loadSpec,proto3" json:"load_spec,omitempty"`
	Seed                 int64    `protobuf:"varint,3,opt,name=seed,proto3" json:"seed,omitempty"`
	Parallelism          int64    `protobuf:"varint,4,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	PodPatch             string   `protobuf:"bytes,5,opt,name=pod_patch,json=podPatch,proto3" json:"pod_patch,omitempty"`
	StateId              string   `protobuf:"bytes,6,opt,name=state_id,json=stateId,proto3" json:"state_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunLoadTestRequest) Descriptor 

func (*RunLoadTestRequest) Descriptor() ([]byte, []int)

func (*RunLoadTestRequest) GetDagSpec 

func (m *RunLoadTestRequest) GetDagSpec() string

func (*RunLoadTestRequest) GetLoadSpec 

func (m *RunLoadTestRequest) GetLoadSpec() string

func (*RunLoadTestRequest) GetParallelism 

func (m *RunLoadTestRequest) GetParallelism() int64

func (*RunLoadTestRequest) GetPodPatch 

func (m *RunLoadTestRequest) GetPodPatch() string

func (*RunLoadTestRequest) GetSeed 

func (m *RunLoadTestRequest) GetSeed() int64

func (*RunLoadTestRequest) GetStateId 

func (m *RunLoadTestRequest) GetStateId() string

func (*RunLoadTestRequest) Marshal 

func (m *RunLoadTestRequest) Marshal() (dAtA []byte, err error)

func (*RunLoadTestRequest) MarshalLogObject 

func (x *RunLoadTestRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RunLoadTestRequest) MarshalTo 

func (m *RunLoadTestRequest) MarshalTo(dAtA []byte) (int, error)

func (*RunLoadTestRequest) MarshalToSizedBuffer 

func (m *RunLoadTestRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RunLoadTestRequest) ProtoMessage 

func (*RunLoadTestRequest) ProtoMessage()

func (*RunLoadTestRequest) Reset 

func (m *RunLoadTestRequest) Reset()

func (*RunLoadTestRequest) Size 

func (m *RunLoadTestRequest) Size() (n int)

func (*RunLoadTestRequest) String 

func (m *RunLoadTestRequest) String() string

func (*RunLoadTestRequest) Unmarshal 

func (m *RunLoadTestRequest) Unmarshal(dAtA []byte) error

func (*RunLoadTestRequest) XXX_DiscardUnknown 

func (m *RunLoadTestRequest) XXX_DiscardUnknown()

func (*RunLoadTestRequest) XXX_Marshal 

func (m *RunLoadTestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunLoadTestRequest) XXX_Merge 

func (m *RunLoadTestRequest) XXX_Merge(src proto.Message)

func (*RunLoadTestRequest) XXX_Size 

func (m *RunLoadTestRequest) XXX_Size() int

func (*RunLoadTestRequest) XXX_Unmarshal 

func (m *RunLoadTestRequest) XXX_Unmarshal(b []byte) error

type RunLoadTestResponse 

type RunLoadTestResponse struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	StateId              string   `protobuf:"bytes,2,opt,name=state_id,json=stateId,proto3" json:"state_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunLoadTestResponse) Descriptor 

func (*RunLoadTestResponse) Descriptor() ([]byte, []int)

func (*RunLoadTestResponse) GetError 

func (m *RunLoadTestResponse) GetError() string

func (*RunLoadTestResponse) GetStateId 

func (m *RunLoadTestResponse) GetStateId() string

func (*RunLoadTestResponse) Marshal 

func (m *RunLoadTestResponse) Marshal() (dAtA []byte, err error)

func (*RunLoadTestResponse) MarshalLogObject 

func (x *RunLoadTestResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RunLoadTestResponse) MarshalTo 

func (m *RunLoadTestResponse) MarshalTo(dAtA []byte) (int, error)

func (*RunLoadTestResponse) MarshalToSizedBuffer 

func (m *RunLoadTestResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RunLoadTestResponse) ProtoMessage 

func (*RunLoadTestResponse) ProtoMessage()

func (*RunLoadTestResponse) Reset 

func (m *RunLoadTestResponse) Reset()

func (*RunLoadTestResponse) Size 

func (m *RunLoadTestResponse) Size() (n int)

func (*RunLoadTestResponse) String 

func (m *RunLoadTestResponse) String() string

func (*RunLoadTestResponse) Unmarshal 

func (m *RunLoadTestResponse) Unmarshal(dAtA []byte) error

func (*RunLoadTestResponse) XXX_DiscardUnknown 

func (m *RunLoadTestResponse) XXX_DiscardUnknown()

func (*RunLoadTestResponse) XXX_Marshal 

func (m *RunLoadTestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunLoadTestResponse) XXX_Merge 

func (m *RunLoadTestResponse) XXX_Merge(src proto.Message)

func (*RunLoadTestResponse) XXX_Size 

func (m *RunLoadTestResponse) XXX_Size() int

func (*RunLoadTestResponse) XXX_Unmarshal 

func (m *RunLoadTestResponse) XXX_Unmarshal(b []byte) error

type RunPipelineRequest 

type RunPipelineRequest struct {
	Pipeline             *Pipeline     `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Provenance           []*pfs.Commit `protobuf:"bytes,2,rep,name=provenance,proto3" json:"provenance,omitempty"`
	JobID                string        `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*RunPipelineRequest) Descriptor 

func (*RunPipelineRequest) Descriptor() ([]byte, []int)

func (*RunPipelineRequest) GetJobID 

func (m *RunPipelineRequest) GetJobID() string

func (*RunPipelineRequest) GetPipeline 

func (m *RunPipelineRequest) GetPipeline() *Pipeline

func (*RunPipelineRequest) GetProvenance 

func (m *RunPipelineRequest) GetProvenance() []*pfs.Commit

func (*RunPipelineRequest) Marshal 

func (m *RunPipelineRequest) Marshal() (dAtA []byte, err error)

func (*RunPipelineRequest) MarshalLogObject 

func (x *RunPipelineRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RunPipelineRequest) MarshalTo 

func (m *RunPipelineRequest) MarshalTo(dAtA []byte) (int, error)

func (*RunPipelineRequest) MarshalToSizedBuffer 

func (m *RunPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RunPipelineRequest) ProtoMessage 

func (*RunPipelineRequest) ProtoMessage()

func (*RunPipelineRequest) Reset 

func (m *RunPipelineRequest) Reset()

func (*RunPipelineRequest) Size 

func (m *RunPipelineRequest) Size() (n int)

func (*RunPipelineRequest) String 

func (m *RunPipelineRequest) String() string

func (*RunPipelineRequest) Unmarshal 

func (m *RunPipelineRequest) Unmarshal(dAtA []byte) error

func (*RunPipelineRequest) XXX_DiscardUnknown 

func (m *RunPipelineRequest) XXX_DiscardUnknown()

func (*RunPipelineRequest) XXX_Marshal 

func (m *RunPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunPipelineRequest) XXX_Merge 

func (m *RunPipelineRequest) XXX_Merge(src proto.Message)

func (*RunPipelineRequest) XXX_Size 

func (m *RunPipelineRequest) XXX_Size() int

func (*RunPipelineRequest) XXX_Unmarshal 

func (m *RunPipelineRequest) XXX_Unmarshal(b []byte) error

type SchedulingSpec 

type SchedulingSpec struct {
	NodeSelector         map[string]string `` /* 185-byte string literal not displayed */
	PriorityClassName    string            `protobuf:"bytes,2,opt,name=priority_class_name,json=priorityClassName,proto3" json:"priority_class_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SchedulingSpec) Descriptor 

func (*SchedulingSpec) Descriptor() ([]byte, []int)

func (*SchedulingSpec) GetNodeSelector 

func (m *SchedulingSpec) GetNodeSelector() map[string]string

func (*SchedulingSpec) GetPriorityClassName 

func (m *SchedulingSpec) GetPriorityClassName() string

func (*SchedulingSpec) Marshal 

func (m *SchedulingSpec) Marshal() (dAtA []byte, err error)

func (*SchedulingSpec) MarshalLogObject 

func (x *SchedulingSpec) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SchedulingSpec) MarshalTo 

func (m *SchedulingSpec) MarshalTo(dAtA []byte) (int, error)

func (*SchedulingSpec) MarshalToSizedBuffer 

func (m *SchedulingSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SchedulingSpec) ProtoMessage 

func (*SchedulingSpec) ProtoMessage()

func (*SchedulingSpec) Reset 

func (m *SchedulingSpec) Reset()

func (*SchedulingSpec) Size 

func (m *SchedulingSpec) Size() (n int)

func (*SchedulingSpec) String 

func (m *SchedulingSpec) String() string

func (*SchedulingSpec) Unmarshal 

func (m *SchedulingSpec) Unmarshal(dAtA []byte) error

func (*SchedulingSpec) XXX_DiscardUnknown 

func (m *SchedulingSpec) XXX_DiscardUnknown()

func (*SchedulingSpec) XXX_Marshal 

func (m *SchedulingSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchedulingSpec) XXX_Merge 

func (m *SchedulingSpec) XXX_Merge(src proto.Message)

func (*SchedulingSpec) XXX_Size 

func (m *SchedulingSpec) XXX_Size() int

func (*SchedulingSpec) XXX_Unmarshal 

func (m *SchedulingSpec) XXX_Unmarshal(b []byte) error

type Secret 

type Secret struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Secret) Descriptor 

func (*Secret) Descriptor() ([]byte, []int)

func (*Secret) GetName 

func (m *Secret) GetName() string

func (*Secret) Marshal 

func (m *Secret) Marshal() (dAtA []byte, err error)

func (*Secret) MarshalLogObject 

func (x *Secret) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Secret) MarshalTo 

func (m *Secret) MarshalTo(dAtA []byte) (int, error)

func (*Secret) MarshalToSizedBuffer 

func (m *Secret) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) Reset 

func (m *Secret) Reset()

func (*Secret) Size 

func (m *Secret) Size() (n int)

func (*Secret) String 

func (m *Secret) String() string

func (*Secret) Unmarshal 

func (m *Secret) Unmarshal(dAtA []byte) error

func (*Secret) XXX_DiscardUnknown 

func (m *Secret) XXX_DiscardUnknown()

func (*Secret) XXX_Marshal 

func (m *Secret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Secret) XXX_Merge 

func (m *Secret) XXX_Merge(src proto.Message)

func (*Secret) XXX_Size 

func (m *Secret) XXX_Size() int

func (*Secret) XXX_Unmarshal 

func (m *Secret) XXX_Unmarshal(b []byte) error

type SecretInfo 

type SecretInfo struct {
	Secret               *Secret          `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	Type                 string           `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	CreationTimestamp    *types.Timestamp `protobuf:"bytes,3,opt,name=creation_timestamp,json=creationTimestamp,proto3" json:"creation_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SecretInfo) Descriptor 

func (*SecretInfo) Descriptor() ([]byte, []int)

func (*SecretInfo) GetCreationTimestamp 

func (m *SecretInfo) GetCreationTimestamp() *types.Timestamp

func (*SecretInfo) GetSecret 

func (m *SecretInfo) GetSecret() *Secret

func (*SecretInfo) GetType 

func (m *SecretInfo) GetType() string

func (*SecretInfo) Marshal 

func (m *SecretInfo) Marshal() (dAtA []byte, err error)

func (*SecretInfo) MarshalLogObject 

func (x *SecretInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SecretInfo) MarshalTo 

func (m *SecretInfo) MarshalTo(dAtA []byte) (int, error)

func (*SecretInfo) MarshalToSizedBuffer 

func (m *SecretInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SecretInfo) ProtoMessage 

func (*SecretInfo) ProtoMessage()

func (*SecretInfo) Reset 

func (m *SecretInfo) Reset()

func (*SecretInfo) Size 

func (m *SecretInfo) Size() (n int)

func (*SecretInfo) String 

func (m *SecretInfo) String() string

func (*SecretInfo) Unmarshal 

func (m *SecretInfo) Unmarshal(dAtA []byte) error

func (*SecretInfo) XXX_DiscardUnknown 

func (m *SecretInfo) XXX_DiscardUnknown()

func (*SecretInfo) XXX_Marshal 

func (m *SecretInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecretInfo) XXX_Merge 

func (m *SecretInfo) XXX_Merge(src proto.Message)

func (*SecretInfo) XXX_Size 

func (m *SecretInfo) XXX_Size() int

func (*SecretInfo) XXX_Unmarshal 

func (m *SecretInfo) XXX_Unmarshal(b []byte) error

type SecretInfos 

type SecretInfos struct {
	SecretInfo           []*SecretInfo `protobuf:"bytes,1,rep,name=secret_info,json=secretInfo,proto3" json:"secret_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*SecretInfos) Descriptor 

func (*SecretInfos) Descriptor() ([]byte, []int)

func (*SecretInfos) GetSecretInfo 

func (m *SecretInfos) GetSecretInfo() []*SecretInfo

func (*SecretInfos) Marshal 

func (m *SecretInfos) Marshal() (dAtA []byte, err error)

func (*SecretInfos) MarshalLogObject 

func (x *SecretInfos) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SecretInfos) MarshalTo 

func (m *SecretInfos) MarshalTo(dAtA []byte) (int, error)

func (*SecretInfos) MarshalToSizedBuffer 

func (m *SecretInfos) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SecretInfos) ProtoMessage 

func (*SecretInfos) ProtoMessage()

func (*SecretInfos) Reset 

func (m *SecretInfos) Reset()

func (*SecretInfos) Size 

func (m *SecretInfos) Size() (n int)

func (*SecretInfos) String 

func (m *SecretInfos) String() string

func (*SecretInfos) Unmarshal 

func (m *SecretInfos) Unmarshal(dAtA []byte) error

func (*SecretInfos) XXX_DiscardUnknown 

func (m *SecretInfos) XXX_DiscardUnknown()

func (*SecretInfos) XXX_Marshal 

func (m *SecretInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecretInfos) XXX_Merge 

func (m *SecretInfos) XXX_Merge(src proto.Message)

func (*SecretInfos) XXX_Size 

func (m *SecretInfos) XXX_Size() int

func (*SecretInfos) XXX_Unmarshal 

func (m *SecretInfos) XXX_Unmarshal(b []byte) error

type SecretMount 

type SecretMount struct {
	// Name must be the name of the secret in kubernetes.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Key of the secret to load into env_var, this field only has meaning if EnvVar != "".
	Key                  string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	MountPath            string   `protobuf:"bytes,3,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
	EnvVar               string   `protobuf:"bytes,4,opt,name=env_var,json=envVar,proto3" json:"env_var,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SecretMount) Descriptor 

func (*SecretMount) Descriptor() ([]byte, []int)

func (*SecretMount) GetEnvVar 

func (m *SecretMount) GetEnvVar() string

func (*SecretMount) GetKey 

func (m *SecretMount) GetKey() string

func (*SecretMount) GetMountPath 

func (m *SecretMount) GetMountPath() string

func (*SecretMount) GetName 

func (m *SecretMount) GetName() string

func (*SecretMount) Marshal 

func (m *SecretMount) Marshal() (dAtA []byte, err error)

func (*SecretMount) MarshalLogObject 

func (x *SecretMount) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SecretMount) MarshalTo 

func (m *SecretMount) MarshalTo(dAtA []byte) (int, error)

func (*SecretMount) MarshalToSizedBuffer 

func (m *SecretMount) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SecretMount) ProtoMessage 

func (*SecretMount) ProtoMessage()

func (*SecretMount) Reset 

func (m *SecretMount) Reset()

func (*SecretMount) Size 

func (m *SecretMount) Size() (n int)

func (*SecretMount) String 

func (m *SecretMount) String() string

func (*SecretMount) Unmarshal 

func (m *SecretMount) Unmarshal(dAtA []byte) error

func (*SecretMount) XXX_DiscardUnknown 

func (m *SecretMount) XXX_DiscardUnknown()

func (*SecretMount) XXX_Marshal 

func (m *SecretMount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SecretMount) XXX_Merge 

func (m *SecretMount) XXX_Merge(src proto.Message)

func (*SecretMount) XXX_Size 

func (m *SecretMount) XXX_Size() int

func (*SecretMount) XXX_Unmarshal 

func (m *SecretMount) XXX_Unmarshal(b []byte) error

type Service 

type Service struct {
	InternalPort         int32    `protobuf:"varint,1,opt,name=internal_port,json=internalPort,proto3" json:"internal_port,omitempty"`
	ExternalPort         int32    `protobuf:"varint,2,opt,name=external_port,json=externalPort,proto3" json:"external_port,omitempty"`
	IP                   string   `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	Type                 string   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Service) Descriptor 

func (*Service) Descriptor() ([]byte, []int)

func (*Service) GetExternalPort 

func (m *Service) GetExternalPort() int32

func (*Service) GetIP 

func (m *Service) GetIP() string

func (*Service) GetInternalPort 

func (m *Service) GetInternalPort() int32

func (*Service) GetType 

func (m *Service) GetType() string

func (*Service) Marshal 

func (m *Service) Marshal() (dAtA []byte, err error)

func (*Service) MarshalLogObject 

func (x *Service) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Service) MarshalTo 

func (m *Service) MarshalTo(dAtA []byte) (int, error)

func (*Service) MarshalToSizedBuffer 

func (m *Service) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) Size 

func (m *Service) Size() (n int)

func (*Service) String 

func (m *Service) String() string

func (*Service) Unmarshal 

func (m *Service) Unmarshal(dAtA []byte) error

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge 

func (m *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

func (m *Service) XXX_Unmarshal(b []byte) error

type Spout 

type Spout struct {
	Service              *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Spout) Descriptor 

func (*Spout) Descriptor() ([]byte, []int)

func (*Spout) GetService 

func (m *Spout) GetService() *Service

func (*Spout) Marshal 

func (m *Spout) Marshal() (dAtA []byte, err error)

func (*Spout) MarshalLogObject 

func (x *Spout) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Spout) MarshalTo 

func (m *Spout) MarshalTo(dAtA []byte) (int, error)

func (*Spout) MarshalToSizedBuffer 

func (m *Spout) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Spout) ProtoMessage 

func (*Spout) ProtoMessage()

func (*Spout) Reset 

func (m *Spout) Reset()

func (*Spout) Size 

func (m *Spout) Size() (n int)

func (*Spout) String 

func (m *Spout) String() string

func (*Spout) Unmarshal 

func (m *Spout) Unmarshal(dAtA []byte) error

func (*Spout) XXX_DiscardUnknown 

func (m *Spout) XXX_DiscardUnknown()

func (*Spout) XXX_Marshal 

func (m *Spout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Spout) XXX_Merge 

func (m *Spout) XXX_Merge(src proto.Message)

func (*Spout) XXX_Size 

func (m *Spout) XXX_Size() int

func (*Spout) XXX_Unmarshal 

func (m *Spout) XXX_Unmarshal(b []byte) error

type StartPipelineRequest 

type StartPipelineRequest struct {
	Pipeline             *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*StartPipelineRequest) Descriptor 

func (*StartPipelineRequest) Descriptor() ([]byte, []int)

func (*StartPipelineRequest) GetPipeline 

func (m *StartPipelineRequest) GetPipeline() *Pipeline

func (*StartPipelineRequest) Marshal 

func (m *StartPipelineRequest) Marshal() (dAtA []byte, err error)

func (*StartPipelineRequest) MarshalLogObject 

func (x *StartPipelineRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*StartPipelineRequest) MarshalTo 

func (m *StartPipelineRequest) MarshalTo(dAtA []byte) (int, error)

func (*StartPipelineRequest) MarshalToSizedBuffer 

func (m *StartPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartPipelineRequest) ProtoMessage 

func (*StartPipelineRequest) ProtoMessage()

func (*StartPipelineRequest) Reset 

func (m *StartPipelineRequest) Reset()

func (*StartPipelineRequest) Size 

func (m *StartPipelineRequest) Size() (n int)

func (*StartPipelineRequest) String 

func (m *StartPipelineRequest) String() string

func (*StartPipelineRequest) Unmarshal 

func (m *StartPipelineRequest) Unmarshal(dAtA []byte) error

func (*StartPipelineRequest) XXX_DiscardUnknown 

func (m *StartPipelineRequest) XXX_DiscardUnknown()

func (*StartPipelineRequest) XXX_Marshal 

func (m *StartPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartPipelineRequest) XXX_Merge 

func (m *StartPipelineRequest) XXX_Merge(src proto.Message)

func (*StartPipelineRequest) XXX_Size 

func (m *StartPipelineRequest) XXX_Size() int

func (*StartPipelineRequest) XXX_Unmarshal 

func (m *StartPipelineRequest) XXX_Unmarshal(b []byte) error

type StopJobRequest 

type StopJobRequest struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Reason               string   `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopJobRequest) Descriptor 

func (*StopJobRequest) Descriptor() ([]byte, []int)

func (*StopJobRequest) GetJob 

func (m *StopJobRequest) GetJob() *Job

func (*StopJobRequest) GetReason 

func (m *StopJobRequest) GetReason() string

func (*StopJobRequest) Marshal 

func (m *StopJobRequest) Marshal() (dAtA []byte, err error)

func (*StopJobRequest) MarshalLogObject 

func (x *StopJobRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*StopJobRequest) MarshalTo 

func (m *StopJobRequest) MarshalTo(dAtA []byte) (int, error)

func (*StopJobRequest) MarshalToSizedBuffer 

func (m *StopJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StopJobRequest) ProtoMessage 

func (*StopJobRequest) ProtoMessage()

func (*StopJobRequest) Reset 

func (m *StopJobRequest) Reset()

func (*StopJobRequest) Size 

func (m *StopJobRequest) Size() (n int)

func (*StopJobRequest) String 

func (m *StopJobRequest) String() string

func (*StopJobRequest) Unmarshal 

func (m *StopJobRequest) Unmarshal(dAtA []byte) error

func (*StopJobRequest) XXX_DiscardUnknown 

func (m *StopJobRequest) XXX_DiscardUnknown()

func (*StopJobRequest) XXX_Marshal 

func (m *StopJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopJobRequest) XXX_Merge 

func (m *StopJobRequest) XXX_Merge(src proto.Message)

func (*StopJobRequest) XXX_Size 

func (m *StopJobRequest) XXX_Size() int

func (*StopJobRequest) XXX_Unmarshal 

func (m *StopJobRequest) XXX_Unmarshal(b []byte) error

type StopPipelineRequest 

type StopPipelineRequest struct {
	Pipeline             *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*StopPipelineRequest) Descriptor 

func (*StopPipelineRequest) Descriptor() ([]byte, []int)

func (*StopPipelineRequest) GetPipeline 

func (m *StopPipelineRequest) GetPipeline() *Pipeline

func (*StopPipelineRequest) Marshal 

func (m *StopPipelineRequest) Marshal() (dAtA []byte, err error)

func (*StopPipelineRequest) MarshalLogObject 

func (x *StopPipelineRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*StopPipelineRequest) MarshalTo 

func (m *StopPipelineRequest) MarshalTo(dAtA []byte) (int, error)

func (*StopPipelineRequest) MarshalToSizedBuffer 

func (m *StopPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StopPipelineRequest) ProtoMessage 

func (*StopPipelineRequest) ProtoMessage()

func (*StopPipelineRequest) Reset 

func (m *StopPipelineRequest) Reset()

func (*StopPipelineRequest) Size 

func (m *StopPipelineRequest) Size() (n int)

func (*StopPipelineRequest) String 

func (m *StopPipelineRequest) String() string

func (*StopPipelineRequest) Unmarshal 

func (m *StopPipelineRequest) Unmarshal(dAtA []byte) error

func (*StopPipelineRequest) XXX_DiscardUnknown 

func (m *StopPipelineRequest) XXX_DiscardUnknown()

func (*StopPipelineRequest) XXX_Marshal 

func (m *StopPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopPipelineRequest) XXX_Merge 

func (m *StopPipelineRequest) XXX_Merge(src proto.Message)

func (*StopPipelineRequest) XXX_Size 

func (m *StopPipelineRequest) XXX_Size() int

func (*StopPipelineRequest) XXX_Unmarshal 

func (m *StopPipelineRequest) XXX_Unmarshal(b []byte) error

type SubscribeJobRequest 

type SubscribeJobRequest struct {
	Pipeline             *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Details              bool      `protobuf:"varint,2,opt,name=details,proto3" json:"details,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Streams open jobs until canceled

func (*SubscribeJobRequest) Descriptor 

func (*SubscribeJobRequest) Descriptor() ([]byte, []int)

func (*SubscribeJobRequest) GetDetails 

func (m *SubscribeJobRequest) GetDetails() bool

func (*SubscribeJobRequest) GetPipeline 

func (m *SubscribeJobRequest) GetPipeline() *Pipeline

func (*SubscribeJobRequest) Marshal 

func (m *SubscribeJobRequest) Marshal() (dAtA []byte, err error)

func (*SubscribeJobRequest) MarshalLogObject 

func (x *SubscribeJobRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*SubscribeJobRequest) MarshalTo 

func (m *SubscribeJobRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeJobRequest) MarshalToSizedBuffer 

func (m *SubscribeJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeJobRequest) ProtoMessage 

func (*SubscribeJobRequest) ProtoMessage()

func (*SubscribeJobRequest) Reset 

func (m *SubscribeJobRequest) Reset()

func (*SubscribeJobRequest) Size 

func (m *SubscribeJobRequest) Size() (n int)

func (*SubscribeJobRequest) String 

func (m *SubscribeJobRequest) String() string

func (*SubscribeJobRequest) Unmarshal 

func (m *SubscribeJobRequest) Unmarshal(dAtA []byte) error

func (*SubscribeJobRequest) XXX_DiscardUnknown 

func (m *SubscribeJobRequest) XXX_DiscardUnknown()

func (*SubscribeJobRequest) XXX_Marshal 

func (m *SubscribeJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeJobRequest) XXX_Merge 

func (m *SubscribeJobRequest) XXX_Merge(src proto.Message)

func (*SubscribeJobRequest) XXX_Size 

func (m *SubscribeJobRequest) XXX_Size() int

func (*SubscribeJobRequest) XXX_Unmarshal 

func (m *SubscribeJobRequest) XXX_Unmarshal(b []byte) error

type TFJob 

type TFJob struct {
	// tf_job  is a serialized Kubeflow TFJob spec. Pachyderm sends this directly
	// to a kubernetes cluster on which kubeflow has been installed, instead of
	// creating a pipeline ReplicationController as it normally would.
	TFJob                string   `protobuf:"bytes,1,opt,name=tf_job,json=tfJob,proto3" json:"tf_job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TFJob) Descriptor 

func (*TFJob) Descriptor() ([]byte, []int)

func (*TFJob) GetTFJob 

func (m *TFJob) GetTFJob() string

func (*TFJob) Marshal 

func (m *TFJob) Marshal() (dAtA []byte, err error)

func (*TFJob) MarshalLogObject 

func (x *TFJob) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*TFJob) MarshalTo 

func (m *TFJob) MarshalTo(dAtA []byte) (int, error)

func (*TFJob) MarshalToSizedBuffer 

func (m *TFJob) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TFJob) ProtoMessage 

func (*TFJob) ProtoMessage()

func (*TFJob) Reset 

func (m *TFJob) Reset()

func (*TFJob) Size 

func (m *TFJob) Size() (n int)

func (*TFJob) String 

func (m *TFJob) String() string

func (*TFJob) Unmarshal 

func (m *TFJob) Unmarshal(dAtA []byte) error

func (*TFJob) XXX_DiscardUnknown 

func (m *TFJob) XXX_DiscardUnknown()

func (*TFJob) XXX_Marshal 

func (m *TFJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TFJob) XXX_Merge 

func (m *TFJob) XXX_Merge(src proto.Message)

func (*TFJob) XXX_Size 

func (m *TFJob) XXX_Size() int

func (*TFJob) XXX_Unmarshal 

func (m *TFJob) XXX_Unmarshal(b []byte) error

type TaintEffect 

type TaintEffect int32

TaintEffect is an effect that can be matched by a toleration. 

const (
	TaintEffect_ALL_EFFECTS        TaintEffect = 0
	TaintEffect_NO_SCHEDULE        TaintEffect = 1
	TaintEffect_PREFER_NO_SCHEDULE TaintEffect = 2
	TaintEffect_NO_EXECUTE         TaintEffect = 3
)

func (TaintEffect) EnumDescriptor 

func (TaintEffect) EnumDescriptor() ([]byte, []int)

func (TaintEffect) String 

func (x TaintEffect) String() string

type Toleration 

type Toleration struct {
	// key is the taint key that the toleration applies to.  Empty means match all taint keys.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// operator represents a key's relationship to the value.
	Operator TolerationOperator `protobuf:"varint,2,opt,name=operator,proto3,enum=pps_v2.TolerationOperator" json:"operator,omitempty"`
	// value is the taint value the toleration matches to.
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// effect indicates the taint effect to match.  Empty means match all taint effects.
	Effect TaintEffect `protobuf:"varint,4,opt,name=effect,proto3,enum=pps_v2.TaintEffect" json:"effect,omitempty"`
	// toleration_seconds represents the period of time the toleration (which must be of effect
	// NoExecute, otherwise this field is ignored) tolerates the taint.  If not set, tolerate the
	// taint forever.
	TolerationSeconds    *types.Int64Value `protobuf:"bytes,5,opt,name=toleration_seconds,json=tolerationSeconds,proto3" json:"toleration_seconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Toleration is a Kubernetes toleration.

func (*Toleration) Descriptor 

func (*Toleration) Descriptor() ([]byte, []int)

func (*Toleration) GetEffect 

func (m *Toleration) GetEffect() TaintEffect

func (*Toleration) GetKey 

func (m *Toleration) GetKey() string

func (*Toleration) GetOperator 

func (m *Toleration) GetOperator() TolerationOperator

func (*Toleration) GetTolerationSeconds 

func (m *Toleration) GetTolerationSeconds() *types.Int64Value

func (*Toleration) GetValue 

func (m *Toleration) GetValue() string

func (*Toleration) Marshal 

func (m *Toleration) Marshal() (dAtA []byte, err error)

func (*Toleration) MarshalLogObject 

func (x *Toleration) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Toleration) MarshalTo 

func (m *Toleration) MarshalTo(dAtA []byte) (int, error)

func (*Toleration) MarshalToSizedBuffer 

func (m *Toleration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Toleration) ProtoMessage 

func (*Toleration) ProtoMessage()

func (*Toleration) Reset 

func (m *Toleration) Reset()

func (*Toleration) Size 

func (m *Toleration) Size() (n int)

func (*Toleration) String 

func (m *Toleration) String() string

func (*Toleration) Unmarshal 

func (m *Toleration) Unmarshal(dAtA []byte) error

func (*Toleration) XXX_DiscardUnknown 

func (m *Toleration) XXX_DiscardUnknown()

func (*Toleration) XXX_Marshal 

func (m *Toleration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Toleration) XXX_Merge 

func (m *Toleration) XXX_Merge(src proto.Message)

func (*Toleration) XXX_Size 

func (m *Toleration) XXX_Size() int

func (*Toleration) XXX_Unmarshal 

func (m *Toleration) XXX_Unmarshal(b []byte) error

type TolerationOperator 

type TolerationOperator int32

TolerationOperator relates a Toleration's key to its value. 

const (
	TolerationOperator_EMPTY  TolerationOperator = 0
	TolerationOperator_EXISTS TolerationOperator = 1
	TolerationOperator_EQUAL  TolerationOperator = 2
)

func (TolerationOperator) EnumDescriptor 

func (TolerationOperator) EnumDescriptor() ([]byte, []int)

func (TolerationOperator) String 

func (x TolerationOperator) String() string

type Transform 

type Transform struct {
	Image                string            `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	Cmd                  []string          `protobuf:"bytes,2,rep,name=cmd,proto3" json:"cmd,omitempty"`
	ErrCmd               []string          `protobuf:"bytes,3,rep,name=err_cmd,json=errCmd,proto3" json:"err_cmd,omitempty"`
	Env                  map[string]string `` /* 147-byte string literal not displayed */
	Secrets              []*SecretMount    `protobuf:"bytes,5,rep,name=secrets,proto3" json:"secrets,omitempty"`
	ImagePullSecrets     []string          `protobuf:"bytes,6,rep,name=image_pull_secrets,json=imagePullSecrets,proto3" json:"image_pull_secrets,omitempty"`
	Stdin                []string          `protobuf:"bytes,7,rep,name=stdin,proto3" json:"stdin,omitempty"`
	ErrStdin             []string          `protobuf:"bytes,8,rep,name=err_stdin,json=errStdin,proto3" json:"err_stdin,omitempty"`
	AcceptReturnCode     []int64           `protobuf:"varint,9,rep,packed,name=accept_return_code,json=acceptReturnCode,proto3" json:"accept_return_code,omitempty"`
	Debug                bool              `protobuf:"varint,10,opt,name=debug,proto3" json:"debug,omitempty"`
	User                 string            `protobuf:"bytes,11,opt,name=user,proto3" json:"user,omitempty"`
	WorkingDir           string            `protobuf:"bytes,12,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
	Dockerfile           string            `protobuf:"bytes,13,opt,name=dockerfile,proto3" json:"dockerfile,omitempty"`
	MemoryVolume         bool              `protobuf:"varint,14,opt,name=memory_volume,json=memoryVolume,proto3" json:"memory_volume,omitempty"`
	DatumBatching        bool              `protobuf:"varint,15,opt,name=datum_batching,json=datumBatching,proto3" json:"datum_batching,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Transform) Descriptor 

func (*Transform) Descriptor() ([]byte, []int)

func (*Transform) GetAcceptReturnCode 

func (m *Transform) GetAcceptReturnCode() []int64

func (*Transform) GetCmd 

func (m *Transform) GetCmd() []string

func (*Transform) GetDatumBatching 

func (m *Transform) GetDatumBatching() bool

func (*Transform) GetDebug 

func (m *Transform) GetDebug() bool

func (*Transform) GetDockerfile 

func (m *Transform) GetDockerfile() string

func (*Transform) GetEnv 

func (m *Transform) GetEnv() map[string]string

func (*Transform) GetErrCmd 

func (m *Transform) GetErrCmd() []string

func (*Transform) GetErrStdin 

func (m *Transform) GetErrStdin() []string

func (*Transform) GetImage 

func (m *Transform) GetImage() string

func (*Transform) GetImagePullSecrets 

func (m *Transform) GetImagePullSecrets() []string

func (*Transform) GetMemoryVolume 

func (m *Transform) GetMemoryVolume() bool

func (*Transform) GetSecrets 

func (m *Transform) GetSecrets() []*SecretMount

func (*Transform) GetStdin 

func (m *Transform) GetStdin() []string

func (*Transform) GetUser 

func (m *Transform) GetUser() string

func (*Transform) GetWorkingDir 

func (m *Transform) GetWorkingDir() string

func (*Transform) Marshal 

func (m *Transform) Marshal() (dAtA []byte, err error)

func (*Transform) MarshalLogObject 

func (x *Transform) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Transform) MarshalTo 

func (m *Transform) MarshalTo(dAtA []byte) (int, error)

func (*Transform) MarshalToSizedBuffer 

func (m *Transform) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Transform) ProtoMessage 

func (*Transform) ProtoMessage()

func (*Transform) Reset 

func (m *Transform) Reset()

func (*Transform) Size 

func (m *Transform) Size() (n int)

func (*Transform) String 

func (m *Transform) String() string

func (*Transform) Unmarshal 

func (m *Transform) Unmarshal(dAtA []byte) error

func (*Transform) XXX_DiscardUnknown 

func (m *Transform) XXX_DiscardUnknown()

func (*Transform) XXX_Marshal 

func (m *Transform) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Transform) XXX_Merge 

func (m *Transform) XXX_Merge(src proto.Message)

func (*Transform) XXX_Size 

func (m *Transform) XXX_Size() int

func (*Transform) XXX_Unmarshal 

func (m *Transform) XXX_Unmarshal(b []byte) error

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) ActivateAuth 

func (*UnimplementedAPIServer) ActivateAuth(ctx context.Context, req *ActivateAuthRequest) (*ActivateAuthResponse, error)

func (*UnimplementedAPIServer) CreatePipeline 

func (*UnimplementedAPIServer) CreatePipeline(ctx context.Context, req *CreatePipelineRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) CreateSecret 

func (*UnimplementedAPIServer) CreateSecret(ctx context.Context, req *CreateSecretRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) DeleteAll 

func (*UnimplementedAPIServer) DeleteAll(ctx context.Context, req *types.Empty) (*types.Empty, error)

func (*UnimplementedAPIServer) DeleteJob 

func (*UnimplementedAPIServer) DeleteJob(ctx context.Context, req *DeleteJobRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) DeletePipeline 

func (*UnimplementedAPIServer) DeletePipeline(ctx context.Context, req *DeletePipelineRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) DeletePipelines 

func (*UnimplementedAPIServer) DeletePipelines(ctx context.Context, req *DeletePipelinesRequest) (*DeletePipelinesResponse, error)

func (*UnimplementedAPIServer) DeleteSecret 

func (*UnimplementedAPIServer) DeleteSecret(ctx context.Context, req *DeleteSecretRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) GetKubeEvents 

func (*UnimplementedAPIServer) GetKubeEvents(req *LokiRequest, srv API_GetKubeEventsServer) error

func (*UnimplementedAPIServer) GetLogs 

func (*UnimplementedAPIServer) GetLogs(req *GetLogsRequest, srv API_GetLogsServer) error

func (*UnimplementedAPIServer) InspectDatum 

func (*UnimplementedAPIServer) InspectDatum(ctx context.Context, req *InspectDatumRequest) (*DatumInfo, error)

func (*UnimplementedAPIServer) InspectJob 

func (*UnimplementedAPIServer) InspectJob(ctx context.Context, req *InspectJobRequest) (*JobInfo, error)

func (*UnimplementedAPIServer) InspectJobSet 

func (*UnimplementedAPIServer) InspectJobSet(req *InspectJobSetRequest, srv API_InspectJobSetServer) error

func (*UnimplementedAPIServer) InspectPipeline 

func (*UnimplementedAPIServer) InspectPipeline(ctx context.Context, req *InspectPipelineRequest) (*PipelineInfo, error)

func (*UnimplementedAPIServer) InspectSecret 

func (*UnimplementedAPIServer) InspectSecret(ctx context.Context, req *InspectSecretRequest) (*SecretInfo, error)

func (*UnimplementedAPIServer) ListDatum 

func (*UnimplementedAPIServer) ListDatum(req *ListDatumRequest, srv API_ListDatumServer) error

func (*UnimplementedAPIServer) ListJob 

func (*UnimplementedAPIServer) ListJob(req *ListJobRequest, srv API_ListJobServer) error

func (*UnimplementedAPIServer) ListJobSet 

func (*UnimplementedAPIServer) ListJobSet(req *ListJobSetRequest, srv API_ListJobSetServer) error

func (*UnimplementedAPIServer) ListPipeline 

func (*UnimplementedAPIServer) ListPipeline(req *ListPipelineRequest, srv API_ListPipelineServer) error

func (*UnimplementedAPIServer) ListSecret 

func (*UnimplementedAPIServer) ListSecret(ctx context.Context, req *types.Empty) (*SecretInfos, error)

func (*UnimplementedAPIServer) ListTask 

func (*UnimplementedAPIServer) ListTask(req *task.ListTaskRequest, srv API_ListTaskServer) error

func (*UnimplementedAPIServer) QueryLoki 

func (*UnimplementedAPIServer) QueryLoki(req *LokiRequest, srv API_QueryLokiServer) error

func (*UnimplementedAPIServer) RenderTemplate 

func (*UnimplementedAPIServer) RenderTemplate(ctx context.Context, req *RenderTemplateRequest) (*RenderTemplateResponse, error)

func (*UnimplementedAPIServer) RestartDatum 

func (*UnimplementedAPIServer) RestartDatum(ctx context.Context, req *RestartDatumRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) RunCron 

func (*UnimplementedAPIServer) RunCron(ctx context.Context, req *RunCronRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) RunLoadTest 

func (*UnimplementedAPIServer) RunLoadTest(ctx context.Context, req *RunLoadTestRequest) (*RunLoadTestResponse, error)

func (*UnimplementedAPIServer) RunLoadTestDefault 

func (*UnimplementedAPIServer) RunLoadTestDefault(ctx context.Context, req *types.Empty) (*RunLoadTestResponse, error)

func (*UnimplementedAPIServer) RunPipeline 

func (*UnimplementedAPIServer) RunPipeline(ctx context.Context, req *RunPipelineRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) StartPipeline 

func (*UnimplementedAPIServer) StartPipeline(ctx context.Context, req *StartPipelineRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) StopJob 

func (*UnimplementedAPIServer) StopJob(ctx context.Context, req *StopJobRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) StopPipeline 

func (*UnimplementedAPIServer) StopPipeline(ctx context.Context, req *StopPipelineRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) SubscribeJob 

func (*UnimplementedAPIServer) SubscribeJob(req *SubscribeJobRequest, srv API_SubscribeJobServer) error

func (*UnimplementedAPIServer) UpdateJobState 

func (*UnimplementedAPIServer) UpdateJobState(ctx context.Context, req *UpdateJobStateRequest) (*types.Empty, error)

type UpdateJobStateRequest 

type UpdateJobStateRequest struct {
	Job                  *Job          `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	State                JobState      `protobuf:"varint,2,opt,name=state,proto3,enum=pps_v2.JobState" json:"state,omitempty"`
	Reason               string        `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	Restart              uint64        `protobuf:"varint,5,opt,name=restart,proto3" json:"restart,omitempty"`
	DataProcessed        int64         `protobuf:"varint,6,opt,name=data_processed,json=dataProcessed,proto3" json:"data_processed,omitempty"`
	DataSkipped          int64         `protobuf:"varint,7,opt,name=data_skipped,json=dataSkipped,proto3" json:"data_skipped,omitempty"`
	DataFailed           int64         `protobuf:"varint,8,opt,name=data_failed,json=dataFailed,proto3" json:"data_failed,omitempty"`
	DataRecovered        int64         `protobuf:"varint,9,opt,name=data_recovered,json=dataRecovered,proto3" json:"data_recovered,omitempty"`
	DataTotal            int64         `protobuf:"varint,10,opt,name=data_total,json=dataTotal,proto3" json:"data_total,omitempty"`
	Stats                *ProcessStats `protobuf:"bytes,11,opt,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*UpdateJobStateRequest) Descriptor 

func (*UpdateJobStateRequest) Descriptor() ([]byte, []int)

func (*UpdateJobStateRequest) GetDataFailed 

func (m *UpdateJobStateRequest) GetDataFailed() int64

func (*UpdateJobStateRequest) GetDataProcessed 

func (m *UpdateJobStateRequest) GetDataProcessed() int64

func (*UpdateJobStateRequest) GetDataRecovered 

func (m *UpdateJobStateRequest) GetDataRecovered() int64

func (*UpdateJobStateRequest) GetDataSkipped 

func (m *UpdateJobStateRequest) GetDataSkipped() int64

func (*UpdateJobStateRequest) GetDataTotal 

func (m *UpdateJobStateRequest) GetDataTotal() int64

func (*UpdateJobStateRequest) GetJob 

func (m *UpdateJobStateRequest) GetJob() *Job

func (*UpdateJobStateRequest) GetReason 

func (m *UpdateJobStateRequest) GetReason() string

func (*UpdateJobStateRequest) GetRestart 

func (m *UpdateJobStateRequest) GetRestart() uint64

func (*UpdateJobStateRequest) GetState 

func (m *UpdateJobStateRequest) GetState() JobState

func (*UpdateJobStateRequest) GetStats 

func (m *UpdateJobStateRequest) GetStats() *ProcessStats

func (*UpdateJobStateRequest) Marshal 

func (m *UpdateJobStateRequest) Marshal() (dAtA []byte, err error)

func (*UpdateJobStateRequest) MarshalLogObject 

func (x *UpdateJobStateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*UpdateJobStateRequest) MarshalTo 

func (m *UpdateJobStateRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateJobStateRequest) MarshalToSizedBuffer 

func (m *UpdateJobStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateJobStateRequest) ProtoMessage 

func (*UpdateJobStateRequest) ProtoMessage()

func (*UpdateJobStateRequest) Reset 

func (m *UpdateJobStateRequest) Reset()

func (*UpdateJobStateRequest) Size 

func (m *UpdateJobStateRequest) Size() (n int)

func (*UpdateJobStateRequest) String 

func (m *UpdateJobStateRequest) String() string

func (*UpdateJobStateRequest) Unmarshal 

func (m *UpdateJobStateRequest) Unmarshal(dAtA []byte) error

func (*UpdateJobStateRequest) XXX_DiscardUnknown 

func (m *UpdateJobStateRequest) XXX_DiscardUnknown()

func (*UpdateJobStateRequest) XXX_Marshal 

func (m *UpdateJobStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateJobStateRequest) XXX_Merge 

func (m *UpdateJobStateRequest) XXX_Merge(src proto.Message)

func (*UpdateJobStateRequest) XXX_Size 

func (m *UpdateJobStateRequest) XXX_Size() int

func (*UpdateJobStateRequest) XXX_Unmarshal 

func (m *UpdateJobStateRequest) XXX_Unmarshal(b []byte) error

type Worker 

type Worker struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	State                WorkerState `protobuf:"varint,2,opt,name=state,proto3,enum=pps_v2.WorkerState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Worker) Descriptor 

func (*Worker) Descriptor() ([]byte, []int)

func (*Worker) GetName 

func (m *Worker) GetName() string

func (*Worker) GetState 

func (m *Worker) GetState() WorkerState

func (*Worker) Marshal 

func (m *Worker) Marshal() (dAtA []byte, err error)

func (*Worker) MarshalLogObject 

func (x *Worker) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Worker) MarshalTo 

func (m *Worker) MarshalTo(dAtA []byte) (int, error)

func (*Worker) MarshalToSizedBuffer 

func (m *Worker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Worker) ProtoMessage 

func (*Worker) ProtoMessage()

func (*Worker) Reset 

func (m *Worker) Reset()

func (*Worker) Size 

func (m *Worker) Size() (n int)

func (*Worker) String 

func (m *Worker) String() string

func (*Worker) Unmarshal 

func (m *Worker) Unmarshal(dAtA []byte) error

func (*Worker) XXX_DiscardUnknown 

func (m *Worker) XXX_DiscardUnknown()

func (*Worker) XXX_Marshal 

func (m *Worker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Worker) XXX_Merge 

func (m *Worker) XXX_Merge(src proto.Message)

func (*Worker) XXX_Size 

func (m *Worker) XXX_Size() int

func (*Worker) XXX_Unmarshal 

func (m *Worker) XXX_Unmarshal(b []byte) error

type WorkerState 

type WorkerState int32
const (
	WorkerState_WORKER_STATE_UNKNOWN WorkerState = 0
	WorkerState_POD_RUNNING          WorkerState = 1
	WorkerState_POD_SUCCESS          WorkerState = 2
	WorkerState_POD_FAILED           WorkerState = 3
)

func (WorkerState) EnumDescriptor 

func (WorkerState) EnumDescriptor() ([]byte, []int)

func (WorkerState) String 

func (x WorkerState) String() string

type WorkerStatus 

type WorkerStatus struct {
	WorkerID             string       `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	JobID                string       `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	DatumStatus          *DatumStatus `protobuf:"bytes,3,opt,name=datum_status,json=datumStatus,proto3" json:"datum_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*WorkerStatus) Descriptor 

func (*WorkerStatus) Descriptor() ([]byte, []int)

func (*WorkerStatus) GetDatumStatus 

func (m *WorkerStatus) GetDatumStatus() *DatumStatus

func (*WorkerStatus) GetJobID 

func (m *WorkerStatus) GetJobID() string

func (*WorkerStatus) GetWorkerID 

func (m *WorkerStatus) GetWorkerID() string

func (*WorkerStatus) Marshal 

func (m *WorkerStatus) Marshal() (dAtA []byte, err error)

func (*WorkerStatus) MarshalLogObject 

func (x *WorkerStatus) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*WorkerStatus) MarshalTo 

func (m *WorkerStatus) MarshalTo(dAtA []byte) (int, error)

func (*WorkerStatus) MarshalToSizedBuffer 

func (m *WorkerStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkerStatus) ProtoMessage 

func (*WorkerStatus) ProtoMessage()

func (*WorkerStatus) Reset 

func (m *WorkerStatus) Reset()

func (*WorkerStatus) Size 

func (m *WorkerStatus) Size() (n int)

func (*WorkerStatus) String 

func (m *WorkerStatus) String() string

func (*WorkerStatus) Unmarshal 

func (m *WorkerStatus) Unmarshal(dAtA []byte) error

func (*WorkerStatus) XXX_DiscardUnknown 

func (m *WorkerStatus) XXX_DiscardUnknown()

func (*WorkerStatus) XXX_Marshal 

func (m *WorkerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerStatus) XXX_Merge 

func (m *WorkerStatus) XXX_Merge(src proto.Message)

func (*WorkerStatus) XXX_Size 

func (m *WorkerStatus) XXX_Size() int

func (*WorkerStatus) XXX_Unmarshal 

func (m *WorkerStatus) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.