pps

Aug 7, 2024

Changes in this version

type CreatePipelineTransaction

+ CreatedBy string

+ func (x *CreatePipelineTransaction) GetCreatedBy() string

type GetProjectDefaultsResponse

+ CreatedAt *timestamppb.Timestamp

+ CreatedBy string

+ func (x *GetProjectDefaultsResponse) GetCreatedAt() *timestamppb.Timestamp

+ func (x *GetProjectDefaultsResponse) GetCreatedBy() string

type PipelineInfo

+ Metadata map[string]string

+ func (x *PipelineInfo) GetMetadata() map[string]string

type PipelineInfo_Details

+ CreatedBy string

+ UpdatedAt *timestamppb.Timestamp

+ func (x *PipelineInfo_Details) GetCreatedBy() string

+ func (x *PipelineInfo_Details) GetUpdatedAt() *timestamppb.Timestamp

+ type PipelinePicker struct

+ Picker isPipelinePicker_Picker

+ func (*PipelinePicker) Descriptor() ([]byte, []int)

+ func (*PipelinePicker) ProtoMessage()

+ func (m *PipelinePicker) GetPicker() isPipelinePicker_Picker

+ func (m *PipelinePicker) Validate() error

+ func (m *PipelinePicker) ValidateAll() error

+ func (p *PipelinePicker) UnmarshalText(b []byte) error

+ func (x *PipelinePicker) GetName() *PipelinePicker_PipelineName

+ func (x *PipelinePicker) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *PipelinePicker) ProtoReflect() protoreflect.Message

+ func (x *PipelinePicker) Reset()

+ func (x *PipelinePicker) String() string

+ type PipelinePickerMultiError []error

+ func (m PipelinePickerMultiError) AllErrors() []error

+ func (m PipelinePickerMultiError) Error() string

+ type PipelinePickerValidationError struct

+ func (e PipelinePickerValidationError) Cause() error

+ func (e PipelinePickerValidationError) Error() string

+ func (e PipelinePickerValidationError) ErrorName() string

+ func (e PipelinePickerValidationError) Field() string

+ func (e PipelinePickerValidationError) Key() bool

+ func (e PipelinePickerValidationError) Reason() string

+ type PipelinePicker_Name struct

+ Name *PipelinePicker_PipelineName

+ type PipelinePicker_PipelineName struct

+ Name string

+ Project *pfs.ProjectPicker

+ func (*PipelinePicker_PipelineName) Descriptor() ([]byte, []int)

+ func (*PipelinePicker_PipelineName) ProtoMessage()

+ func (m *PipelinePicker_PipelineName) Validate() error

+ func (m *PipelinePicker_PipelineName) ValidateAll() error

+ func (x *PipelinePicker_PipelineName) GetName() string

+ func (x *PipelinePicker_PipelineName) GetProject() *pfs.ProjectPicker

+ func (x *PipelinePicker_PipelineName) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *PipelinePicker_PipelineName) ProtoReflect() protoreflect.Message

+ func (x *PipelinePicker_PipelineName) Reset()

+ func (x *PipelinePicker_PipelineName) String() string

+ type PipelinePicker_PipelineNameMultiError []error

+ func (m PipelinePicker_PipelineNameMultiError) AllErrors() []error

+ func (m PipelinePicker_PipelineNameMultiError) Error() string

+ type PipelinePicker_PipelineNameValidationError struct

+ func (e PipelinePicker_PipelineNameValidationError) Cause() error

+ func (e PipelinePicker_PipelineNameValidationError) Error() string

+ func (e PipelinePicker_PipelineNameValidationError) ErrorName() string

+ func (e PipelinePicker_PipelineNameValidationError) Field() string

+ func (e PipelinePicker_PipelineNameValidationError) Key() bool

+ func (e PipelinePicker_PipelineNameValidationError) Reason() string

May 15, 2024

Changes in this version

+ const API_PipelinesSummary_FullMethodName

+ var PipelinePage_Ordering_name = map[int32]string

+ var PipelinePage_Ordering_value = map[string]int32

type APIClient

+ PipelinesSummary func(ctx context.Context, in *PipelinesSummaryRequest, opts ...grpc.CallOption) (*PipelinesSummaryResponse, error)

type APIServer

+ PipelinesSummary func(context.Context, *PipelinesSummaryRequest) (*PipelinesSummaryResponse, error)

type ListPipelineRequest

+ Page *PipelinePage

+ func (x *ListPipelineRequest) GetPage() *PipelinePage

+ type PipelinePage struct

+ Order PipelinePage_Ordering

+ PageIndex int64

+ PageSize int64

+ func (*PipelinePage) Descriptor() ([]byte, []int)

+ func (*PipelinePage) ProtoMessage()

+ func (m *PipelinePage) Validate() error

+ func (m *PipelinePage) ValidateAll() error

+ func (x *PipelinePage) GetOrder() PipelinePage_Ordering

+ func (x *PipelinePage) GetPageIndex() int64

+ func (x *PipelinePage) GetPageSize() int64

+ func (x *PipelinePage) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *PipelinePage) ProtoReflect() protoreflect.Message

+ func (x *PipelinePage) Reset()

+ func (x *PipelinePage) String() string

+ type PipelinePageMultiError []error

+ func (m PipelinePageMultiError) AllErrors() []error

+ func (m PipelinePageMultiError) Error() string

+ type PipelinePageValidationError struct

+ func (e PipelinePageValidationError) Cause() error

+ func (e PipelinePageValidationError) Error() string

+ func (e PipelinePageValidationError) ErrorName() string

+ func (e PipelinePageValidationError) Field() string

+ func (e PipelinePageValidationError) Key() bool

+ func (e PipelinePageValidationError) Reason() string

+ type PipelinePage_Ordering int32

+ const PipelinePage_RECENT

+ func (PipelinePage_Ordering) Descriptor() protoreflect.EnumDescriptor

+ func (PipelinePage_Ordering) EnumDescriptor() ([]byte, []int)

+ func (PipelinePage_Ordering) Type() protoreflect.EnumType

+ func (x PipelinePage_Ordering) Enum() *PipelinePage_Ordering

+ func (x PipelinePage_Ordering) Number() protoreflect.EnumNumber

+ func (x PipelinePage_Ordering) String() string

+ type PipelinesSummary struct

+ ActivePipelines int64

+ FailedPipelines int64

+ PausedPipelines int64

+ Project *pfs.Project

+ UnhealthyPipelines int64

+ func (*PipelinesSummary) Descriptor() ([]byte, []int)

+ func (*PipelinesSummary) ProtoMessage()

+ func (m *PipelinesSummary) Validate() error

+ func (m *PipelinesSummary) ValidateAll() error

+ func (x *PipelinesSummary) GetActivePipelines() int64

+ func (x *PipelinesSummary) GetFailedPipelines() int64

+ func (x *PipelinesSummary) GetPausedPipelines() int64

+ func (x *PipelinesSummary) GetProject() *pfs.Project

+ func (x *PipelinesSummary) GetUnhealthyPipelines() int64

+ func (x *PipelinesSummary) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *PipelinesSummary) ProtoReflect() protoreflect.Message

+ func (x *PipelinesSummary) Reset()

+ func (x *PipelinesSummary) String() string

+ type PipelinesSummaryMultiError []error

+ func (m PipelinesSummaryMultiError) AllErrors() []error

+ func (m PipelinesSummaryMultiError) Error() string

+ type PipelinesSummaryRequest struct

+ Projects []*pfs.ProjectPicker

+ func (*PipelinesSummaryRequest) Descriptor() ([]byte, []int)

+ func (*PipelinesSummaryRequest) ProtoMessage()

+ func (m *PipelinesSummaryRequest) Validate() error

+ func (m *PipelinesSummaryRequest) ValidateAll() error

+ func (x *PipelinesSummaryRequest) GetProjects() []*pfs.ProjectPicker

+ func (x *PipelinesSummaryRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *PipelinesSummaryRequest) ProtoReflect() protoreflect.Message

+ func (x *PipelinesSummaryRequest) Reset()

+ func (x *PipelinesSummaryRequest) String() string

+ type PipelinesSummaryRequestMultiError []error

+ func (m PipelinesSummaryRequestMultiError) AllErrors() []error

+ func (m PipelinesSummaryRequestMultiError) Error() string

+ type PipelinesSummaryRequestValidationError struct

+ func (e PipelinesSummaryRequestValidationError) Cause() error

+ func (e PipelinesSummaryRequestValidationError) Error() string

+ func (e PipelinesSummaryRequestValidationError) ErrorName() string

+ func (e PipelinesSummaryRequestValidationError) Field() string

+ func (e PipelinesSummaryRequestValidationError) Key() bool

+ func (e PipelinesSummaryRequestValidationError) Reason() string

+ type PipelinesSummaryResponse struct

+ Summaries []*PipelinesSummary

+ func (*PipelinesSummaryResponse) Descriptor() ([]byte, []int)

+ func (*PipelinesSummaryResponse) ProtoMessage()

+ func (m *PipelinesSummaryResponse) Validate() error

+ func (m *PipelinesSummaryResponse) ValidateAll() error

+ func (x *PipelinesSummaryResponse) GetSummaries() []*PipelinesSummary

+ func (x *PipelinesSummaryResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *PipelinesSummaryResponse) ProtoReflect() protoreflect.Message

+ func (x *PipelinesSummaryResponse) Reset()

+ func (x *PipelinesSummaryResponse) String() string

+ type PipelinesSummaryResponseMultiError []error

+ func (m PipelinesSummaryResponseMultiError) AllErrors() []error

+ func (m PipelinesSummaryResponseMultiError) Error() string

+ type PipelinesSummaryResponseValidationError struct

+ func (e PipelinesSummaryResponseValidationError) Cause() error

+ func (e PipelinesSummaryResponseValidationError) Error() string

+ func (e PipelinesSummaryResponseValidationError) ErrorName() string

+ func (e PipelinesSummaryResponseValidationError) Field() string

+ func (e PipelinesSummaryResponseValidationError) Key() bool

+ func (e PipelinesSummaryResponseValidationError) Reason() string

+ type PipelinesSummaryValidationError struct

+ func (e PipelinesSummaryValidationError) Cause() error

+ func (e PipelinesSummaryValidationError) Error() string

+ func (e PipelinesSummaryValidationError) ErrorName() string

+ func (e PipelinesSummaryValidationError) Field() string

+ func (e PipelinesSummaryValidationError) Key() bool

+ func (e PipelinesSummaryValidationError) Reason() string

type UnimplementedAPIServer

+ func (UnimplementedAPIServer) PipelinesSummary(context.Context, *PipelinesSummaryRequest) (*PipelinesSummaryResponse, error)

Mar 12, 2024

Changes in this version

+ type ContinueCreateDatumRequest struct

+ Number int32

+ func (*ContinueCreateDatumRequest) Descriptor() ([]byte, []int)

+ func (*ContinueCreateDatumRequest) ProtoMessage()

+ func (m *ContinueCreateDatumRequest) Validate() error

+ func (m *ContinueCreateDatumRequest) ValidateAll() error

+ func (x *ContinueCreateDatumRequest) GetNumber() int32

+ func (x *ContinueCreateDatumRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *ContinueCreateDatumRequest) ProtoReflect() protoreflect.Message

+ func (x *ContinueCreateDatumRequest) Reset()

+ func (x *ContinueCreateDatumRequest) String() string

+ type ContinueCreateDatumRequestMultiError []error

+ func (m ContinueCreateDatumRequestMultiError) AllErrors() []error

+ func (m ContinueCreateDatumRequestMultiError) Error() string

+ type ContinueCreateDatumRequestValidationError struct

+ func (e ContinueCreateDatumRequestValidationError) Cause() error

+ func (e ContinueCreateDatumRequestValidationError) Error() string

+ func (e ContinueCreateDatumRequestValidationError) ErrorName() string

+ func (e ContinueCreateDatumRequestValidationError) Field() string

+ func (e ContinueCreateDatumRequestValidationError) Key() bool

+ func (e ContinueCreateDatumRequestValidationError) Reason() string

type CreateDatumRequest

+ Body isCreateDatumRequest_Body

+ func (m *CreateDatumRequest) GetBody() isCreateDatumRequest_Body

+ func (x *CreateDatumRequest) GetContinue() *ContinueCreateDatumRequest

+ func (x *CreateDatumRequest) GetStart() *StartCreateDatumRequest

+ type CreateDatumRequest_Continue struct

+ Continue *ContinueCreateDatumRequest

+ type CreateDatumRequest_Start struct

+ Start *StartCreateDatumRequest

+ type StartCreateDatumRequest struct

+ Input *Input

+ Number int32

+ func (*StartCreateDatumRequest) Descriptor() ([]byte, []int)

+ func (*StartCreateDatumRequest) ProtoMessage()

+ func (m *StartCreateDatumRequest) Validate() error

+ func (m *StartCreateDatumRequest) ValidateAll() error

+ func (x *StartCreateDatumRequest) GetInput() *Input

+ func (x *StartCreateDatumRequest) GetNumber() int32

+ func (x *StartCreateDatumRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *StartCreateDatumRequest) ProtoReflect() protoreflect.Message

+ func (x *StartCreateDatumRequest) Reset()

+ func (x *StartCreateDatumRequest) String() string

+ type StartCreateDatumRequestMultiError []error

+ func (m StartCreateDatumRequestMultiError) AllErrors() []error

+ func (m StartCreateDatumRequestMultiError) Error() string

+ type StartCreateDatumRequestValidationError struct

+ func (e StartCreateDatumRequestValidationError) Cause() error

+ func (e StartCreateDatumRequestValidationError) Error() string

+ func (e StartCreateDatumRequestValidationError) ErrorName() string

+ func (e StartCreateDatumRequestValidationError) Field() string

+ func (e StartCreateDatumRequestValidationError) Key() bool

+ func (e StartCreateDatumRequestValidationError) Reason() string

Feb 21, 2024

Changes in this version

+ const API_CheckStatus_FullMethodName

+ const API_CreateDatum_FullMethodName

+ func GetAlerts(pi *PipelineInfo) []string

type APIClient

+ CheckStatus func(ctx context.Context, in *CheckStatusRequest, opts ...grpc.CallOption) (API_CheckStatusClient, error)

+ CreateDatum func(ctx context.Context, opts ...grpc.CallOption) (API_CreateDatumClient, error)

type APIServer

+ CheckStatus func(*CheckStatusRequest, API_CheckStatusServer) error

+ CreateDatum func(API_CreateDatumServer) error

+ type API_CheckStatusClient interface

+ Recv func() (*CheckStatusResponse, error)

+ type API_CheckStatusServer interface

+ Send func(*CheckStatusResponse) error

+ type API_CreateDatumClient interface

+ Recv func() (*DatumInfo, error)

+ Send func(*CreateDatumRequest) error

+ type API_CreateDatumServer interface

+ Recv func() (*CreateDatumRequest, error)

+ Send func(*DatumInfo) error

+ type CheckStatusRequest struct

+ Context isCheckStatusRequest_Context

+ func (*CheckStatusRequest) Descriptor() ([]byte, []int)

+ func (*CheckStatusRequest) ProtoMessage()

+ func (m *CheckStatusRequest) GetContext() isCheckStatusRequest_Context

+ func (m *CheckStatusRequest) Validate() error

+ func (m *CheckStatusRequest) ValidateAll() error

+ func (x *CheckStatusRequest) GetAll() bool

+ func (x *CheckStatusRequest) GetProject() *pfs.Project

+ func (x *CheckStatusRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *CheckStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *CheckStatusRequest) Reset()

+ func (x *CheckStatusRequest) String() string

+ type CheckStatusRequestMultiError []error

+ func (m CheckStatusRequestMultiError) AllErrors() []error

+ func (m CheckStatusRequestMultiError) Error() string

+ type CheckStatusRequestValidationError struct

+ func (e CheckStatusRequestValidationError) Cause() error

+ func (e CheckStatusRequestValidationError) Error() string

+ func (e CheckStatusRequestValidationError) ErrorName() string

+ func (e CheckStatusRequestValidationError) Field() string

+ func (e CheckStatusRequestValidationError) Key() bool

+ func (e CheckStatusRequestValidationError) Reason() string

+ type CheckStatusRequest_All struct

+ All bool

+ type CheckStatusRequest_Project struct

+ Project *pfs.Project

+ type CheckStatusResponse struct

+ Alerts []string

+ Pipeline *Pipeline

+ Project *pfs.Project

+ func (*CheckStatusResponse) Descriptor() ([]byte, []int)

+ func (*CheckStatusResponse) ProtoMessage()

+ func (m *CheckStatusResponse) Validate() error

+ func (m *CheckStatusResponse) ValidateAll() error

+ func (x *CheckStatusResponse) GetAlerts() []string

+ func (x *CheckStatusResponse) GetPipeline() *Pipeline

+ func (x *CheckStatusResponse) GetProject() *pfs.Project

+ func (x *CheckStatusResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *CheckStatusResponse) ProtoReflect() protoreflect.Message

+ func (x *CheckStatusResponse) Reset()

+ func (x *CheckStatusResponse) String() string

+ type CheckStatusResponseMultiError []error

+ func (m CheckStatusResponseMultiError) AllErrors() []error

+ func (m CheckStatusResponseMultiError) Error() string

+ type CheckStatusResponseValidationError struct

+ func (e CheckStatusResponseValidationError) Cause() error

+ func (e CheckStatusResponseValidationError) Error() string

+ func (e CheckStatusResponseValidationError) ErrorName() string

+ func (e CheckStatusResponseValidationError) Field() string

+ func (e CheckStatusResponseValidationError) Key() bool

+ func (e CheckStatusResponseValidationError) Reason() string

+ type CreateDatumRequest struct

+ Input *Input

+ Number int64

+ func (*CreateDatumRequest) Descriptor() ([]byte, []int)

+ func (*CreateDatumRequest) ProtoMessage()

+ func (m *CreateDatumRequest) Validate() error

+ func (m *CreateDatumRequest) ValidateAll() error

+ func (x *CreateDatumRequest) GetInput() *Input

+ func (x *CreateDatumRequest) GetNumber() int64

+ func (x *CreateDatumRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *CreateDatumRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateDatumRequest) Reset()

+ func (x *CreateDatumRequest) String() string

+ type CreateDatumRequestMultiError []error

+ func (m CreateDatumRequestMultiError) AllErrors() []error

+ func (m CreateDatumRequestMultiError) Error() string

+ type CreateDatumRequestValidationError struct

+ func (e CreateDatumRequestValidationError) Cause() error

+ func (e CreateDatumRequestValidationError) Error() string

+ func (e CreateDatumRequestValidationError) ErrorName() string

+ func (e CreateDatumRequestValidationError) Field() string

+ func (e CreateDatumRequestValidationError) Key() bool

+ func (e CreateDatumRequestValidationError) Reason() string

type CreatePipelineRequest

+ MaximumExpectedUptime *durationpb.Duration

+ func (x *CreatePipelineRequest) GetMaximumExpectedUptime() *durationpb.Duration

type PipelineInfo_Details

+ MaximumExpectedUptime *durationpb.Duration

+ WorkersStartedAt *timestamppb.Timestamp

+ func (x *PipelineInfo_Details) GetMaximumExpectedUptime() *durationpb.Duration

+ func (x *PipelineInfo_Details) GetWorkersStartedAt() *timestamppb.Timestamp

type UnimplementedAPIServer

+ func (UnimplementedAPIServer) CheckStatus(*CheckStatusRequest, API_CheckStatusServer) error

+ func (UnimplementedAPIServer) CreateDatum(API_CreateDatumServer) error

Nov 29, 2023

Changes in this version

+ const API_CreatePipelineV2_FullMethodName

+ const API_GetClusterDefaults_FullMethodName

+ const API_GetProjectDefaults_FullMethodName

+ const API_RerunPipeline_FullMethodName

+ const API_SetClusterDefaults_FullMethodName

+ const API_SetProjectDefaults_FullMethodName

+ func RegisterAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client APIClient) error

+ func RegisterAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server APIServer) error

type APIClient

+ CreatePipelineV2 func(ctx context.Context, in *CreatePipelineV2Request, opts ...grpc.CallOption) (*CreatePipelineV2Response, error)

+ GetClusterDefaults func(ctx context.Context, in *GetClusterDefaultsRequest, opts ...grpc.CallOption) (*GetClusterDefaultsResponse, error)

+ GetProjectDefaults func(ctx context.Context, in *GetProjectDefaultsRequest, opts ...grpc.CallOption) (*GetProjectDefaultsResponse, error)

+ RerunPipeline func(ctx context.Context, in *RerunPipelineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ SetClusterDefaults func(ctx context.Context, in *SetClusterDefaultsRequest, opts ...grpc.CallOption) (*SetClusterDefaultsResponse, error)

+ SetProjectDefaults func(ctx context.Context, in *SetProjectDefaultsRequest, opts ...grpc.CallOption) (*SetProjectDefaultsResponse, error)

type APIServer

+ CreatePipelineV2 func(context.Context, *CreatePipelineV2Request) (*CreatePipelineV2Response, error)

+ GetClusterDefaults func(context.Context, *GetClusterDefaultsRequest) (*GetClusterDefaultsResponse, error)

+ GetProjectDefaults func(context.Context, *GetProjectDefaultsRequest) (*GetProjectDefaultsResponse, error)

+ RerunPipeline func(context.Context, *RerunPipelineRequest) (*emptypb.Empty, error)

+ SetClusterDefaults func(context.Context, *SetClusterDefaultsRequest) (*SetClusterDefaultsResponse, error)

+ SetProjectDefaults func(context.Context, *SetProjectDefaultsRequest) (*SetProjectDefaultsResponse, error)

type ActivateAuthRequest

+ func (m *ActivateAuthRequest) Validate() error

+ func (m *ActivateAuthRequest) ValidateAll() error

+ type ActivateAuthRequestMultiError []error

+ func (m ActivateAuthRequestMultiError) AllErrors() []error

+ func (m ActivateAuthRequestMultiError) Error() string

+ type ActivateAuthRequestValidationError struct

+ func (e ActivateAuthRequestValidationError) Cause() error

+ func (e ActivateAuthRequestValidationError) Error() string

+ func (e ActivateAuthRequestValidationError) ErrorName() string

+ func (e ActivateAuthRequestValidationError) Field() string

+ func (e ActivateAuthRequestValidationError) Key() bool

+ func (e ActivateAuthRequestValidationError) Reason() string

type ActivateAuthResponse

+ func (m *ActivateAuthResponse) Validate() error

+ func (m *ActivateAuthResponse) ValidateAll() error

+ type ActivateAuthResponseMultiError []error

+ func (m ActivateAuthResponseMultiError) AllErrors() []error

+ func (m ActivateAuthResponseMultiError) Error() string

+ type ActivateAuthResponseValidationError struct

+ func (e ActivateAuthResponseValidationError) Cause() error

+ func (e ActivateAuthResponseValidationError) Error() string

+ func (e ActivateAuthResponseValidationError) ErrorName() string

+ func (e ActivateAuthResponseValidationError) Field() string

+ func (e ActivateAuthResponseValidationError) Key() bool

+ func (e ActivateAuthResponseValidationError) Reason() string

type Aggregate

+ func (m *Aggregate) Validate() error

+ func (m *Aggregate) ValidateAll() error

+ type AggregateMultiError []error

+ func (m AggregateMultiError) AllErrors() []error

+ func (m AggregateMultiError) Error() string

type AggregateProcessStats

+ func (m *AggregateProcessStats) Validate() error

+ func (m *AggregateProcessStats) ValidateAll() error

+ type AggregateProcessStatsMultiError []error

+ func (m AggregateProcessStatsMultiError) AllErrors() []error

+ func (m AggregateProcessStatsMultiError) Error() string

+ type AggregateProcessStatsValidationError struct

+ func (e AggregateProcessStatsValidationError) Cause() error

+ func (e AggregateProcessStatsValidationError) Error() string

+ func (e AggregateProcessStatsValidationError) ErrorName() string

+ func (e AggregateProcessStatsValidationError) Field() string

+ func (e AggregateProcessStatsValidationError) Key() bool

+ func (e AggregateProcessStatsValidationError) Reason() string

+ type AggregateValidationError struct

+ func (e AggregateValidationError) Cause() error

+ func (e AggregateValidationError) Error() string

+ func (e AggregateValidationError) ErrorName() string

+ func (e AggregateValidationError) Field() string

+ func (e AggregateValidationError) Key() bool

+ func (e AggregateValidationError) Reason() string

type ClusterDefaults

+ CreatePipelineRequest *CreatePipelineRequest

+ func (m *ClusterDefaults) Validate() error

+ func (m *ClusterDefaults) ValidateAll() error

+ func (x *ClusterDefaults) GetCreatePipelineRequest() *CreatePipelineRequest

+ type ClusterDefaultsMultiError []error

+ func (m ClusterDefaultsMultiError) AllErrors() []error

+ func (m ClusterDefaultsMultiError) Error() string

+ type ClusterDefaultsValidationError struct

+ func (e ClusterDefaultsValidationError) Cause() error

+ func (e ClusterDefaultsValidationError) Error() string

+ func (e ClusterDefaultsValidationError) ErrorName() string

+ func (e ClusterDefaultsValidationError) Field() string

+ func (e ClusterDefaultsValidationError) Key() bool

+ func (e ClusterDefaultsValidationError) Reason() string

type CreatePipelineRequest

+ func (m *CreatePipelineRequest) Validate() error

+ func (m *CreatePipelineRequest) ValidateAll() error

+ type CreatePipelineRequestMultiError []error

+ func (m CreatePipelineRequestMultiError) AllErrors() []error

+ func (m CreatePipelineRequestMultiError) Error() string

+ type CreatePipelineRequestValidationError struct

+ func (e CreatePipelineRequestValidationError) Cause() error

+ func (e CreatePipelineRequestValidationError) Error() string

+ func (e CreatePipelineRequestValidationError) ErrorName() string

+ func (e CreatePipelineRequestValidationError) Field() string

+ func (e CreatePipelineRequestValidationError) Key() bool

+ func (e CreatePipelineRequestValidationError) Reason() string

+ type CreatePipelineTransaction struct

+ CreatePipelineRequest *CreatePipelineRequest

+ EffectiveJson string

+ UserJson string

+ func (*CreatePipelineTransaction) Descriptor() ([]byte, []int)

+ func (*CreatePipelineTransaction) ProtoMessage()

+ func (m *CreatePipelineTransaction) Validate() error

+ func (m *CreatePipelineTransaction) ValidateAll() error

+ func (x *CreatePipelineTransaction) GetCreatePipelineRequest() *CreatePipelineRequest

+ func (x *CreatePipelineTransaction) GetEffectiveJson() string

+ func (x *CreatePipelineTransaction) GetUserJson() string

+ func (x *CreatePipelineTransaction) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *CreatePipelineTransaction) ProtoReflect() protoreflect.Message

+ func (x *CreatePipelineTransaction) Reset()

+ func (x *CreatePipelineTransaction) String() string

+ type CreatePipelineTransactionMultiError []error

+ func (m CreatePipelineTransactionMultiError) AllErrors() []error

+ func (m CreatePipelineTransactionMultiError) Error() string

+ type CreatePipelineTransactionValidationError struct

+ func (e CreatePipelineTransactionValidationError) Cause() error

+ func (e CreatePipelineTransactionValidationError) Error() string

+ func (e CreatePipelineTransactionValidationError) ErrorName() string

+ func (e CreatePipelineTransactionValidationError) Field() string

+ func (e CreatePipelineTransactionValidationError) Key() bool

+ func (e CreatePipelineTransactionValidationError) Reason() string

+ type CreatePipelineV2Request struct

+ CreatePipelineRequestJson string

+ DryRun bool

+ Reprocess bool

+ Update bool

+ func (*CreatePipelineV2Request) Descriptor() ([]byte, []int)

+ func (*CreatePipelineV2Request) ProtoMessage()

+ func (m *CreatePipelineV2Request) Validate() error

+ func (m *CreatePipelineV2Request) ValidateAll() error

+ func (x *CreatePipelineV2Request) GetCreatePipelineRequestJson() string

+ func (x *CreatePipelineV2Request) GetDryRun() bool

+ func (x *CreatePipelineV2Request) GetReprocess() bool

+ func (x *CreatePipelineV2Request) GetUpdate() bool

+ func (x *CreatePipelineV2Request) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *CreatePipelineV2Request) ProtoReflect() protoreflect.Message

+ func (x *CreatePipelineV2Request) Reset()

+ func (x *CreatePipelineV2Request) String() string

+ type CreatePipelineV2RequestMultiError []error

+ func (m CreatePipelineV2RequestMultiError) AllErrors() []error

+ func (m CreatePipelineV2RequestMultiError) Error() string

+ type CreatePipelineV2RequestValidationError struct

+ func (e CreatePipelineV2RequestValidationError) Cause() error

+ func (e CreatePipelineV2RequestValidationError) Error() string

+ func (e CreatePipelineV2RequestValidationError) ErrorName() string

+ func (e CreatePipelineV2RequestValidationError) Field() string

+ func (e CreatePipelineV2RequestValidationError) Key() bool

+ func (e CreatePipelineV2RequestValidationError) Reason() string

+ type CreatePipelineV2Response struct

+ EffectiveCreatePipelineRequestJson string

+ func (*CreatePipelineV2Response) Descriptor() ([]byte, []int)

+ func (*CreatePipelineV2Response) ProtoMessage()

+ func (m *CreatePipelineV2Response) Validate() error

+ func (m *CreatePipelineV2Response) ValidateAll() error

+ func (x *CreatePipelineV2Response) GetEffectiveCreatePipelineRequestJson() string

+ func (x *CreatePipelineV2Response) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *CreatePipelineV2Response) ProtoReflect() protoreflect.Message

+ func (x *CreatePipelineV2Response) Reset()

+ func (x *CreatePipelineV2Response) String() string

+ type CreatePipelineV2ResponseMultiError []error

+ func (m CreatePipelineV2ResponseMultiError) AllErrors() []error

+ func (m CreatePipelineV2ResponseMultiError) Error() string

+ type CreatePipelineV2ResponseValidationError struct

+ func (e CreatePipelineV2ResponseValidationError) Cause() error

+ func (e CreatePipelineV2ResponseValidationError) Error() string

+ func (e CreatePipelineV2ResponseValidationError) ErrorName() string

+ func (e CreatePipelineV2ResponseValidationError) Field() string

+ func (e CreatePipelineV2ResponseValidationError) Key() bool

+ func (e CreatePipelineV2ResponseValidationError) Reason() string

type CreateSecretRequest

+ func (m *CreateSecretRequest) Validate() error

+ func (m *CreateSecretRequest) ValidateAll() error

+ type CreateSecretRequestMultiError []error

+ func (m CreateSecretRequestMultiError) AllErrors() []error

+ func (m CreateSecretRequestMultiError) Error() string

+ type CreateSecretRequestValidationError struct

+ func (e CreateSecretRequestValidationError) Cause() error

+ func (e CreateSecretRequestValidationError) Error() string

+ func (e CreateSecretRequestValidationError) ErrorName() string

+ func (e CreateSecretRequestValidationError) Field() string

+ func (e CreateSecretRequestValidationError) Key() bool

+ func (e CreateSecretRequestValidationError) Reason() string

type CronInput

+ func (m *CronInput) Validate() error

+ func (m *CronInput) ValidateAll() error

+ type CronInputMultiError []error

+ func (m CronInputMultiError) AllErrors() []error

+ func (m CronInputMultiError) Error() string

+ type CronInputValidationError struct

+ func (e CronInputValidationError) Cause() error

+ func (e CronInputValidationError) Error() string

+ func (e CronInputValidationError) ErrorName() string

+ func (e CronInputValidationError) Field() string

+ func (e CronInputValidationError) Key() bool

+ func (e CronInputValidationError) Reason() string

type Datum

+ func (m *Datum) Validate() error

+ func (m *Datum) ValidateAll() error

type DatumInfo

+ func (m *DatumInfo) Validate() error

+ func (m *DatumInfo) ValidateAll() error

+ type DatumInfoMultiError []error

+ func (m DatumInfoMultiError) AllErrors() []error

+ func (m DatumInfoMultiError) Error() string

+ type DatumInfoValidationError struct

+ func (e DatumInfoValidationError) Cause() error

+ func (e DatumInfoValidationError) Error() string

+ func (e DatumInfoValidationError) ErrorName() string

+ func (e DatumInfoValidationError) Field() string

+ func (e DatumInfoValidationError) Key() bool

+ func (e DatumInfoValidationError) Reason() string

+ type DatumMultiError []error

+ func (m DatumMultiError) AllErrors() []error

+ func (m DatumMultiError) Error() string

type DatumSetSpec

+ func (m *DatumSetSpec) Validate() error

+ func (m *DatumSetSpec) ValidateAll() error

+ type DatumSetSpecMultiError []error

+ func (m DatumSetSpecMultiError) AllErrors() []error

+ func (m DatumSetSpecMultiError) Error() string

+ type DatumSetSpecValidationError struct

+ func (e DatumSetSpecValidationError) Cause() error

+ func (e DatumSetSpecValidationError) Error() string

+ func (e DatumSetSpecValidationError) ErrorName() string

+ func (e DatumSetSpecValidationError) Field() string

+ func (e DatumSetSpecValidationError) Key() bool

+ func (e DatumSetSpecValidationError) Reason() string

type DatumStatus

+ func (m *DatumStatus) Validate() error

+ func (m *DatumStatus) ValidateAll() error

+ type DatumStatusMultiError []error

+ func (m DatumStatusMultiError) AllErrors() []error

+ func (m DatumStatusMultiError) Error() string

+ type DatumStatusValidationError struct

+ func (e DatumStatusValidationError) Cause() error

+ func (e DatumStatusValidationError) Error() string

+ func (e DatumStatusValidationError) ErrorName() string

+ func (e DatumStatusValidationError) Field() string

+ func (e DatumStatusValidationError) Key() bool

+ func (e DatumStatusValidationError) Reason() string

+ type DatumValidationError struct

+ func (e DatumValidationError) Cause() error

+ func (e DatumValidationError) Error() string

+ func (e DatumValidationError) ErrorName() string

+ func (e DatumValidationError) Field() string

+ func (e DatumValidationError) Key() bool

+ func (e DatumValidationError) Reason() string

type DeleteJobRequest

+ func (m *DeleteJobRequest) Validate() error

+ func (m *DeleteJobRequest) ValidateAll() error

+ type DeleteJobRequestMultiError []error

+ func (m DeleteJobRequestMultiError) AllErrors() []error

+ func (m DeleteJobRequestMultiError) Error() string

+ type DeleteJobRequestValidationError struct

+ func (e DeleteJobRequestValidationError) Cause() error

+ func (e DeleteJobRequestValidationError) Error() string

+ func (e DeleteJobRequestValidationError) ErrorName() string

+ func (e DeleteJobRequestValidationError) Field() string

+ func (e DeleteJobRequestValidationError) Key() bool

+ func (e DeleteJobRequestValidationError) Reason() string

type DeletePipelineRequest

+ MustExist bool

+ func (m *DeletePipelineRequest) Validate() error

+ func (m *DeletePipelineRequest) ValidateAll() error

+ func (x *DeletePipelineRequest) GetMustExist() bool

+ type DeletePipelineRequestMultiError []error

+ func (m DeletePipelineRequestMultiError) AllErrors() []error

+ func (m DeletePipelineRequestMultiError) Error() string

+ type DeletePipelineRequestValidationError struct

+ func (e DeletePipelineRequestValidationError) Cause() error

+ func (e DeletePipelineRequestValidationError) Error() string

+ func (e DeletePipelineRequestValidationError) ErrorName() string

+ func (e DeletePipelineRequestValidationError) Field() string

+ func (e DeletePipelineRequestValidationError) Key() bool

+ func (e DeletePipelineRequestValidationError) Reason() string

type DeletePipelinesRequest

+ func (m *DeletePipelinesRequest) Validate() error

+ func (m *DeletePipelinesRequest) ValidateAll() error

+ type DeletePipelinesRequestMultiError []error

+ func (m DeletePipelinesRequestMultiError) AllErrors() []error

+ func (m DeletePipelinesRequestMultiError) Error() string

+ type DeletePipelinesRequestValidationError struct

+ func (e DeletePipelinesRequestValidationError) Cause() error

+ func (e DeletePipelinesRequestValidationError) Error() string

+ func (e DeletePipelinesRequestValidationError) ErrorName() string

+ func (e DeletePipelinesRequestValidationError) Field() string

+ func (e DeletePipelinesRequestValidationError) Key() bool

+ func (e DeletePipelinesRequestValidationError) Reason() string

type DeletePipelinesResponse

+ func (m *DeletePipelinesResponse) Validate() error

+ func (m *DeletePipelinesResponse) ValidateAll() error

+ type DeletePipelinesResponseMultiError []error

+ func (m DeletePipelinesResponseMultiError) AllErrors() []error

+ func (m DeletePipelinesResponseMultiError) Error() string

+ type DeletePipelinesResponseValidationError struct

+ func (e DeletePipelinesResponseValidationError) Cause() error

+ func (e DeletePipelinesResponseValidationError) Error() string

+ func (e DeletePipelinesResponseValidationError) ErrorName() string

+ func (e DeletePipelinesResponseValidationError) Field() string

+ func (e DeletePipelinesResponseValidationError) Key() bool

+ func (e DeletePipelinesResponseValidationError) Reason() string

type DeleteSecretRequest

+ func (m *DeleteSecretRequest) Validate() error

+ func (m *DeleteSecretRequest) ValidateAll() error

+ type DeleteSecretRequestMultiError []error

+ func (m DeleteSecretRequestMultiError) AllErrors() []error

+ func (m DeleteSecretRequestMultiError) Error() string

+ type DeleteSecretRequestValidationError struct

+ func (e DeleteSecretRequestValidationError) Cause() error

+ func (e DeleteSecretRequestValidationError) Error() string

+ func (e DeleteSecretRequestValidationError) ErrorName() string

+ func (e DeleteSecretRequestValidationError) Field() string

+ func (e DeleteSecretRequestValidationError) Key() bool

+ func (e DeleteSecretRequestValidationError) Reason() string

type Determined

+ func (m *Determined) Validate() error

+ func (m *Determined) ValidateAll() error

+ type DeterminedMultiError []error

+ func (m DeterminedMultiError) AllErrors() []error

+ func (m DeterminedMultiError) Error() string

+ type DeterminedValidationError struct

+ func (e DeterminedValidationError) Cause() error

+ func (e DeterminedValidationError) Error() string

+ func (e DeterminedValidationError) ErrorName() string

+ func (e DeterminedValidationError) Field() string

+ func (e DeterminedValidationError) Key() bool

+ func (e DeterminedValidationError) Reason() string

type Egress

+ func (m *Egress) Validate() error

+ func (m *Egress) ValidateAll() error

+ type EgressMultiError []error

+ func (m EgressMultiError) AllErrors() []error

+ func (m EgressMultiError) Error() string

+ type EgressValidationError struct

+ func (e EgressValidationError) Cause() error

+ func (e EgressValidationError) Error() string

+ func (e EgressValidationError) ErrorName() string

+ func (e EgressValidationError) Field() string

+ func (e EgressValidationError) Key() bool

+ func (e EgressValidationError) Reason() string

type GPUSpec

+ func (m *GPUSpec) Validate() error

+ func (m *GPUSpec) ValidateAll() error

+ type GPUSpecMultiError []error

+ func (m GPUSpecMultiError) AllErrors() []error

+ func (m GPUSpecMultiError) Error() string

+ type GPUSpecValidationError struct

+ func (e GPUSpecValidationError) Cause() error

+ func (e GPUSpecValidationError) Error() string

+ func (e GPUSpecValidationError) ErrorName() string

+ func (e GPUSpecValidationError) Field() string

+ func (e GPUSpecValidationError) Key() bool

+ func (e GPUSpecValidationError) Reason() string

type GetClusterDefaultsRequest

+ func (m *GetClusterDefaultsRequest) Validate() error

+ func (m *GetClusterDefaultsRequest) ValidateAll() error

+ type GetClusterDefaultsRequestMultiError []error

+ func (m GetClusterDefaultsRequestMultiError) AllErrors() []error

+ func (m GetClusterDefaultsRequestMultiError) Error() string

+ type GetClusterDefaultsRequestValidationError struct

+ func (e GetClusterDefaultsRequestValidationError) Cause() error

+ func (e GetClusterDefaultsRequestValidationError) Error() string

+ func (e GetClusterDefaultsRequestValidationError) ErrorName() string

+ func (e GetClusterDefaultsRequestValidationError) Field() string

+ func (e GetClusterDefaultsRequestValidationError) Key() bool

+ func (e GetClusterDefaultsRequestValidationError) Reason() string

type GetClusterDefaultsResponse

+ ClusterDefaultsJson string

+ func (m *GetClusterDefaultsResponse) Validate() error

+ func (m *GetClusterDefaultsResponse) ValidateAll() error

+ func (x *GetClusterDefaultsResponse) GetClusterDefaultsJson() string

+ type GetClusterDefaultsResponseMultiError []error

+ func (m GetClusterDefaultsResponseMultiError) AllErrors() []error

+ func (m GetClusterDefaultsResponseMultiError) Error() string

+ type GetClusterDefaultsResponseValidationError struct

+ func (e GetClusterDefaultsResponseValidationError) Cause() error

+ func (e GetClusterDefaultsResponseValidationError) Error() string

+ func (e GetClusterDefaultsResponseValidationError) ErrorName() string

+ func (e GetClusterDefaultsResponseValidationError) Field() string

+ func (e GetClusterDefaultsResponseValidationError) Key() bool

+ func (e GetClusterDefaultsResponseValidationError) Reason() string

type GetLogsRequest

+ func (m *GetLogsRequest) Validate() error

+ func (m *GetLogsRequest) ValidateAll() error

+ type GetLogsRequestMultiError []error

+ func (m GetLogsRequestMultiError) AllErrors() []error

+ func (m GetLogsRequestMultiError) Error() string

+ type GetLogsRequestValidationError struct

+ func (e GetLogsRequestValidationError) Cause() error

+ func (e GetLogsRequestValidationError) Error() string

+ func (e GetLogsRequestValidationError) ErrorName() string

+ func (e GetLogsRequestValidationError) Field() string

+ func (e GetLogsRequestValidationError) Key() bool

+ func (e GetLogsRequestValidationError) Reason() string

+ type GetProjectDefaultsRequest struct

+ Project *pfs.Project

+ func (*GetProjectDefaultsRequest) Descriptor() ([]byte, []int)

+ func (*GetProjectDefaultsRequest) ProtoMessage()

+ func (m *GetProjectDefaultsRequest) Validate() error

+ func (m *GetProjectDefaultsRequest) ValidateAll() error

+ func (x *GetProjectDefaultsRequest) GetProject() *pfs.Project

+ func (x *GetProjectDefaultsRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *GetProjectDefaultsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetProjectDefaultsRequest) Reset()

+ func (x *GetProjectDefaultsRequest) String() string

+ type GetProjectDefaultsRequestMultiError []error

+ func (m GetProjectDefaultsRequestMultiError) AllErrors() []error

+ func (m GetProjectDefaultsRequestMultiError) Error() string

+ type GetProjectDefaultsRequestValidationError struct

+ func (e GetProjectDefaultsRequestValidationError) Cause() error

+ func (e GetProjectDefaultsRequestValidationError) Error() string

+ func (e GetProjectDefaultsRequestValidationError) ErrorName() string

+ func (e GetProjectDefaultsRequestValidationError) Field() string

+ func (e GetProjectDefaultsRequestValidationError) Key() bool

+ func (e GetProjectDefaultsRequestValidationError) Reason() string

+ type GetProjectDefaultsResponse struct

+ ProjectDefaultsJson string

+ func (*GetProjectDefaultsResponse) Descriptor() ([]byte, []int)

+ func (*GetProjectDefaultsResponse) ProtoMessage()

+ func (m *GetProjectDefaultsResponse) Validate() error

+ func (m *GetProjectDefaultsResponse) ValidateAll() error

+ func (x *GetProjectDefaultsResponse) GetProjectDefaultsJson() string

+ func (x *GetProjectDefaultsResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *GetProjectDefaultsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetProjectDefaultsResponse) Reset()

+ func (x *GetProjectDefaultsResponse) String() string

+ type GetProjectDefaultsResponseMultiError []error

+ func (m GetProjectDefaultsResponseMultiError) AllErrors() []error

+ func (m GetProjectDefaultsResponseMultiError) Error() string

+ type GetProjectDefaultsResponseValidationError struct

+ func (e GetProjectDefaultsResponseValidationError) Cause() error

+ func (e GetProjectDefaultsResponseValidationError) Error() string

+ func (e GetProjectDefaultsResponseValidationError) ErrorName() string

+ func (e GetProjectDefaultsResponseValidationError) Field() string

+ func (e GetProjectDefaultsResponseValidationError) Key() bool

+ func (e GetProjectDefaultsResponseValidationError) Reason() string

type Input

+ func (m *Input) Validate() error

+ func (m *Input) ValidateAll() error

type InputFile

+ func (m *InputFile) Validate() error

+ func (m *InputFile) ValidateAll() error

+ type InputFileMultiError []error

+ func (m InputFileMultiError) AllErrors() []error

+ func (m InputFileMultiError) Error() string

+ type InputFileValidationError struct

+ func (e InputFileValidationError) Cause() error

+ func (e InputFileValidationError) Error() string

+ func (e InputFileValidationError) ErrorName() string

+ func (e InputFileValidationError) Field() string

+ func (e InputFileValidationError) Key() bool

+ func (e InputFileValidationError) Reason() string

+ type InputMultiError []error

+ func (m InputMultiError) AllErrors() []error

+ func (m InputMultiError) Error() string

+ type InputValidationError struct

+ func (e InputValidationError) Cause() error

+ func (e InputValidationError) Error() string

+ func (e InputValidationError) ErrorName() string

+ func (e InputValidationError) Field() string

+ func (e InputValidationError) Key() bool

+ func (e InputValidationError) Reason() string

type InspectDatumRequest

+ func (m *InspectDatumRequest) Validate() error

+ func (m *InspectDatumRequest) ValidateAll() error

+ type InspectDatumRequestMultiError []error

+ func (m InspectDatumRequestMultiError) AllErrors() []error

+ func (m InspectDatumRequestMultiError) Error() string

+ type InspectDatumRequestValidationError struct

+ func (e InspectDatumRequestValidationError) Cause() error

+ func (e InspectDatumRequestValidationError) Error() string

+ func (e InspectDatumRequestValidationError) ErrorName() string

+ func (e InspectDatumRequestValidationError) Field() string

+ func (e InspectDatumRequestValidationError) Key() bool

+ func (e InspectDatumRequestValidationError) Reason() string

type InspectJobRequest

+ func (m *InspectJobRequest) Validate() error

+ func (m *InspectJobRequest) ValidateAll() error

+ type InspectJobRequestMultiError []error

+ func (m InspectJobRequestMultiError) AllErrors() []error

+ func (m InspectJobRequestMultiError) Error() string

+ type InspectJobRequestValidationError struct

+ func (e InspectJobRequestValidationError) Cause() error

+ func (e InspectJobRequestValidationError) Error() string

+ func (e InspectJobRequestValidationError) ErrorName() string

+ func (e InspectJobRequestValidationError) Field() string

+ func (e InspectJobRequestValidationError) Key() bool

+ func (e InspectJobRequestValidationError) Reason() string

type InspectJobSetRequest

+ func (m *InspectJobSetRequest) Validate() error

+ func (m *InspectJobSetRequest) ValidateAll() error

+ type InspectJobSetRequestMultiError []error

+ func (m InspectJobSetRequestMultiError) AllErrors() []error

+ func (m InspectJobSetRequestMultiError) Error() string

+ type InspectJobSetRequestValidationError struct

+ func (e InspectJobSetRequestValidationError) Cause() error

+ func (e InspectJobSetRequestValidationError) Error() string

+ func (e InspectJobSetRequestValidationError) ErrorName() string

+ func (e InspectJobSetRequestValidationError) Field() string

+ func (e InspectJobSetRequestValidationError) Key() bool

+ func (e InspectJobSetRequestValidationError) Reason() string

type InspectPipelineRequest

+ func (m *InspectPipelineRequest) Validate() error

+ func (m *InspectPipelineRequest) ValidateAll() error

+ type InspectPipelineRequestMultiError []error

+ func (m InspectPipelineRequestMultiError) AllErrors() []error

+ func (m InspectPipelineRequestMultiError) Error() string

+ type InspectPipelineRequestValidationError struct

+ func (e InspectPipelineRequestValidationError) Cause() error

+ func (e InspectPipelineRequestValidationError) Error() string

+ func (e InspectPipelineRequestValidationError) ErrorName() string

+ func (e InspectPipelineRequestValidationError) Field() string

+ func (e InspectPipelineRequestValidationError) Key() bool

+ func (e InspectPipelineRequestValidationError) Reason() string

type InspectSecretRequest

+ func (m *InspectSecretRequest) Validate() error

+ func (m *InspectSecretRequest) ValidateAll() error

+ type InspectSecretRequestMultiError []error

+ func (m InspectSecretRequestMultiError) AllErrors() []error

+ func (m InspectSecretRequestMultiError) Error() string

+ type InspectSecretRequestValidationError struct

+ func (e InspectSecretRequestValidationError) Cause() error

+ func (e InspectSecretRequestValidationError) Error() string

+ func (e InspectSecretRequestValidationError) ErrorName() string

+ func (e InspectSecretRequestValidationError) Field() string

+ func (e InspectSecretRequestValidationError) Key() bool

+ func (e InspectSecretRequestValidationError) Reason() string

type Job

+ func (m *Job) Validate() error

+ func (m *Job) ValidateAll() error

type JobInfo

+ func (m *JobInfo) Validate() error

+ func (m *JobInfo) ValidateAll() error

+ type JobInfoMultiError []error

+ func (m JobInfoMultiError) AllErrors() []error

+ func (m JobInfoMultiError) Error() string

+ type JobInfoValidationError struct

+ func (e JobInfoValidationError) Cause() error

+ func (e JobInfoValidationError) Error() string

+ func (e JobInfoValidationError) ErrorName() string

+ func (e JobInfoValidationError) Field() string

+ func (e JobInfoValidationError) Key() bool

+ func (e JobInfoValidationError) Reason() string

type JobInfo_Details

+ func (m *JobInfo_Details) Validate() error

+ func (m *JobInfo_Details) ValidateAll() error

+ type JobInfo_DetailsMultiError []error

+ func (m JobInfo_DetailsMultiError) AllErrors() []error

+ func (m JobInfo_DetailsMultiError) Error() string

+ type JobInfo_DetailsValidationError struct

+ func (e JobInfo_DetailsValidationError) Cause() error

+ func (e JobInfo_DetailsValidationError) Error() string

+ func (e JobInfo_DetailsValidationError) ErrorName() string

+ func (e JobInfo_DetailsValidationError) Field() string

+ func (e JobInfo_DetailsValidationError) Key() bool

+ func (e JobInfo_DetailsValidationError) Reason() string

type JobInput

+ func (m *JobInput) Validate() error

+ func (m *JobInput) ValidateAll() error

+ type JobInputMultiError []error

+ func (m JobInputMultiError) AllErrors() []error

+ func (m JobInputMultiError) Error() string

+ type JobInputValidationError struct

+ func (e JobInputValidationError) Cause() error

+ func (e JobInputValidationError) Error() string

+ func (e JobInputValidationError) ErrorName() string

+ func (e JobInputValidationError) Field() string

+ func (e JobInputValidationError) Key() bool

+ func (e JobInputValidationError) Reason() string

+ type JobMultiError []error

+ func (m JobMultiError) AllErrors() []error

+ func (m JobMultiError) Error() string

type JobSet

+ func (m *JobSet) Validate() error

+ func (m *JobSet) ValidateAll() error

type JobSetInfo

+ func (m *JobSetInfo) Validate() error

+ func (m *JobSetInfo) ValidateAll() error

+ type JobSetInfoMultiError []error

+ func (m JobSetInfoMultiError) AllErrors() []error

+ func (m JobSetInfoMultiError) Error() string

+ type JobSetInfoValidationError struct

+ func (e JobSetInfoValidationError) Cause() error

+ func (e JobSetInfoValidationError) Error() string

+ func (e JobSetInfoValidationError) ErrorName() string

+ func (e JobSetInfoValidationError) Field() string

+ func (e JobSetInfoValidationError) Key() bool

+ func (e JobSetInfoValidationError) Reason() string

+ type JobSetMultiError []error

+ func (m JobSetMultiError) AllErrors() []error

+ func (m JobSetMultiError) Error() string

+ type JobSetValidationError struct

+ func (e JobSetValidationError) Cause() error

+ func (e JobSetValidationError) Error() string

+ func (e JobSetValidationError) ErrorName() string

+ func (e JobSetValidationError) Field() string

+ func (e JobSetValidationError) Key() bool

+ func (e JobSetValidationError) Reason() string

+ type JobValidationError struct

+ func (e JobValidationError) Cause() error

+ func (e JobValidationError) Error() string

+ func (e JobValidationError) ErrorName() string

+ func (e JobValidationError) Field() string

+ func (e JobValidationError) Key() bool

+ func (e JobValidationError) Reason() string

type ListDatumRequest

+ func (m *ListDatumRequest) Validate() error

+ func (m *ListDatumRequest) ValidateAll() error

+ type ListDatumRequestMultiError []error

+ func (m ListDatumRequestMultiError) AllErrors() []error

+ func (m ListDatumRequestMultiError) Error() string

+ type ListDatumRequestValidationError struct

+ func (e ListDatumRequestValidationError) Cause() error

+ func (e ListDatumRequestValidationError) Error() string

+ func (e ListDatumRequestValidationError) ErrorName() string

+ func (e ListDatumRequestValidationError) Field() string

+ func (e ListDatumRequestValidationError) Key() bool

+ func (e ListDatumRequestValidationError) Reason() string

type ListDatumRequest_Filter

+ func (m *ListDatumRequest_Filter) Validate() error

+ func (m *ListDatumRequest_Filter) ValidateAll() error

+ type ListDatumRequest_FilterMultiError []error

+ func (m ListDatumRequest_FilterMultiError) AllErrors() []error

+ func (m ListDatumRequest_FilterMultiError) Error() string

+ type ListDatumRequest_FilterValidationError struct

+ func (e ListDatumRequest_FilterValidationError) Cause() error

+ func (e ListDatumRequest_FilterValidationError) Error() string

+ func (e ListDatumRequest_FilterValidationError) ErrorName() string

+ func (e ListDatumRequest_FilterValidationError) Field() string

+ func (e ListDatumRequest_FilterValidationError) Key() bool

+ func (e ListDatumRequest_FilterValidationError) Reason() string

type ListJobRequest

+ func (m *ListJobRequest) Validate() error

+ func (m *ListJobRequest) ValidateAll() error

+ type ListJobRequestMultiError []error

+ func (m ListJobRequestMultiError) AllErrors() []error

+ func (m ListJobRequestMultiError) Error() string

+ type ListJobRequestValidationError struct

+ func (e ListJobRequestValidationError) Cause() error

+ func (e ListJobRequestValidationError) Error() string

+ func (e ListJobRequestValidationError) ErrorName() string

+ func (e ListJobRequestValidationError) Field() string

+ func (e ListJobRequestValidationError) Key() bool

+ func (e ListJobRequestValidationError) Reason() string

type ListJobSetRequest

+ func (m *ListJobSetRequest) Validate() error

+ func (m *ListJobSetRequest) ValidateAll() error

+ type ListJobSetRequestMultiError []error

+ func (m ListJobSetRequestMultiError) AllErrors() []error

+ func (m ListJobSetRequestMultiError) Error() string

+ type ListJobSetRequestValidationError struct

+ func (e ListJobSetRequestValidationError) Cause() error

+ func (e ListJobSetRequestValidationError) Error() string

+ func (e ListJobSetRequestValidationError) ErrorName() string

+ func (e ListJobSetRequestValidationError) Field() string

+ func (e ListJobSetRequestValidationError) Key() bool

+ func (e ListJobSetRequestValidationError) Reason() string

type ListPipelineRequest

+ func (m *ListPipelineRequest) Validate() error

+ func (m *ListPipelineRequest) ValidateAll() error

+ type ListPipelineRequestMultiError []error

+ func (m ListPipelineRequestMultiError) AllErrors() []error

+ func (m ListPipelineRequestMultiError) Error() string

+ type ListPipelineRequestValidationError struct

+ func (e ListPipelineRequestValidationError) Cause() error

+ func (e ListPipelineRequestValidationError) Error() string

+ func (e ListPipelineRequestValidationError) ErrorName() string

+ func (e ListPipelineRequestValidationError) Field() string

+ func (e ListPipelineRequestValidationError) Key() bool

+ func (e ListPipelineRequestValidationError) Reason() string

type LogMessage

+ func (m *LogMessage) Validate() error

+ func (m *LogMessage) ValidateAll() error

+ type LogMessageMultiError []error

+ func (m LogMessageMultiError) AllErrors() []error

+ func (m LogMessageMultiError) Error() string

+ type LogMessageValidationError struct

+ func (e LogMessageValidationError) Cause() error

+ func (e LogMessageValidationError) Error() string

+ func (e LogMessageValidationError) ErrorName() string

+ func (e LogMessageValidationError) Field() string

+ func (e LogMessageValidationError) Key() bool

+ func (e LogMessageValidationError) Reason() string

type LokiLogMessage

+ func (m *LokiLogMessage) Validate() error

+ func (m *LokiLogMessage) ValidateAll() error

+ type LokiLogMessageMultiError []error

+ func (m LokiLogMessageMultiError) AllErrors() []error

+ func (m LokiLogMessageMultiError) Error() string

+ type LokiLogMessageValidationError struct

+ func (e LokiLogMessageValidationError) Cause() error

+ func (e LokiLogMessageValidationError) Error() string

+ func (e LokiLogMessageValidationError) ErrorName() string

+ func (e LokiLogMessageValidationError) Field() string

+ func (e LokiLogMessageValidationError) Key() bool

+ func (e LokiLogMessageValidationError) Reason() string

type LokiRequest

+ func (m *LokiRequest) Validate() error

+ func (m *LokiRequest) ValidateAll() error

+ type LokiRequestMultiError []error

+ func (m LokiRequestMultiError) AllErrors() []error

+ func (m LokiRequestMultiError) Error() string

+ type LokiRequestValidationError struct

+ func (e LokiRequestValidationError) Cause() error

+ func (e LokiRequestValidationError) Error() string

+ func (e LokiRequestValidationError) ErrorName() string

+ func (e LokiRequestValidationError) Field() string

+ func (e LokiRequestValidationError) Key() bool

+ func (e LokiRequestValidationError) Reason() string

type Metadata

+ func (m *Metadata) Validate() error

+ func (m *Metadata) ValidateAll() error

+ type MetadataMultiError []error

+ func (m MetadataMultiError) AllErrors() []error

+ func (m MetadataMultiError) Error() string

+ type MetadataValidationError struct

+ func (e MetadataValidationError) Cause() error

+ func (e MetadataValidationError) Error() string

+ func (e MetadataValidationError) ErrorName() string

+ func (e MetadataValidationError) Field() string

+ func (e MetadataValidationError) Key() bool

+ func (e MetadataValidationError) Reason() string

type PFSInput

+ func (m *PFSInput) Validate() error

+ func (m *PFSInput) ValidateAll() error

+ type PFSInputMultiError []error

+ func (m PFSInputMultiError) AllErrors() []error

+ func (m PFSInputMultiError) Error() string

+ type PFSInputValidationError struct

+ func (e PFSInputValidationError) Cause() error

+ func (e PFSInputValidationError) Error() string

+ func (e PFSInputValidationError) ErrorName() string

+ func (e PFSInputValidationError) Field() string

+ func (e PFSInputValidationError) Key() bool

+ func (e PFSInputValidationError) Reason() string

type ParallelismSpec

+ func (m *ParallelismSpec) Validate() error

+ func (m *ParallelismSpec) ValidateAll() error

+ type ParallelismSpecMultiError []error

+ func (m ParallelismSpecMultiError) AllErrors() []error

+ func (m ParallelismSpecMultiError) Error() string

+ type ParallelismSpecValidationError struct

+ func (e ParallelismSpecValidationError) Cause() error

+ func (e ParallelismSpecValidationError) Error() string

+ func (e ParallelismSpecValidationError) ErrorName() string

+ func (e ParallelismSpecValidationError) Field() string

+ func (e ParallelismSpecValidationError) Key() bool

+ func (e ParallelismSpecValidationError) Reason() string

type Pipeline

+ func (m *Pipeline) Validate() error

+ func (m *Pipeline) ValidateAll() error

type PipelineInfo

+ EffectiveSpecJson string

+ UserSpecJson string

+ func (m *PipelineInfo) Validate() error

+ func (m *PipelineInfo) ValidateAll() error

+ func (x *PipelineInfo) GetEffectiveSpecJson() string

+ func (x *PipelineInfo) GetUserSpecJson() string

+ type PipelineInfoMultiError []error

+ func (m PipelineInfoMultiError) AllErrors() []error

+ func (m PipelineInfoMultiError) Error() string

+ type PipelineInfoValidationError struct

+ func (e PipelineInfoValidationError) Cause() error

+ func (e PipelineInfoValidationError) Error() string

+ func (e PipelineInfoValidationError) ErrorName() string

+ func (e PipelineInfoValidationError) Field() string

+ func (e PipelineInfoValidationError) Key() bool

+ func (e PipelineInfoValidationError) Reason() string

type PipelineInfo_Details

+ func (m *PipelineInfo_Details) Validate() error

+ func (m *PipelineInfo_Details) ValidateAll() error

+ type PipelineInfo_DetailsMultiError []error

+ func (m PipelineInfo_DetailsMultiError) AllErrors() []error

+ func (m PipelineInfo_DetailsMultiError) Error() string

+ type PipelineInfo_DetailsValidationError struct

+ func (e PipelineInfo_DetailsValidationError) Cause() error

+ func (e PipelineInfo_DetailsValidationError) Error() string

+ func (e PipelineInfo_DetailsValidationError) ErrorName() string

+ func (e PipelineInfo_DetailsValidationError) Field() string

+ func (e PipelineInfo_DetailsValidationError) Key() bool

+ func (e PipelineInfo_DetailsValidationError) Reason() string

type PipelineInfos

+ func (m *PipelineInfos) Validate() error

+ func (m *PipelineInfos) ValidateAll() error

+ type PipelineInfosMultiError []error

+ func (m PipelineInfosMultiError) AllErrors() []error

+ func (m PipelineInfosMultiError) Error() string

+ type PipelineInfosValidationError struct

+ func (e PipelineInfosValidationError) Cause() error

+ func (e PipelineInfosValidationError) Error() string

+ func (e PipelineInfosValidationError) ErrorName() string

+ func (e PipelineInfosValidationError) Field() string

+ func (e PipelineInfosValidationError) Key() bool

+ func (e PipelineInfosValidationError) Reason() string

+ type PipelineMultiError []error

+ func (m PipelineMultiError) AllErrors() []error

+ func (m PipelineMultiError) Error() string

+ type PipelineValidationError struct

+ func (e PipelineValidationError) Cause() error

+ func (e PipelineValidationError) Error() string

+ func (e PipelineValidationError) ErrorName() string

+ func (e PipelineValidationError) Field() string

+ func (e PipelineValidationError) Key() bool

+ func (e PipelineValidationError) Reason() string

type ProcessStats

+ func (m *ProcessStats) Validate() error

+ func (m *ProcessStats) ValidateAll() error

+ type ProcessStatsMultiError []error

+ func (m ProcessStatsMultiError) AllErrors() []error

+ func (m ProcessStatsMultiError) Error() string

+ type ProcessStatsValidationError struct

+ func (e ProcessStatsValidationError) Cause() error

+ func (e ProcessStatsValidationError) Error() string

+ func (e ProcessStatsValidationError) ErrorName() string

+ func (e ProcessStatsValidationError) Field() string

+ func (e ProcessStatsValidationError) Key() bool

+ func (e ProcessStatsValidationError) Reason() string

+ type ProjectDefaults struct

+ CreatePipelineRequest *CreatePipelineRequest

+ func (*ProjectDefaults) Descriptor() ([]byte, []int)

+ func (*ProjectDefaults) ProtoMessage()

+ func (m *ProjectDefaults) Validate() error

+ func (m *ProjectDefaults) ValidateAll() error

+ func (x *ProjectDefaults) GetCreatePipelineRequest() *CreatePipelineRequest

+ func (x *ProjectDefaults) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *ProjectDefaults) ProtoReflect() protoreflect.Message

+ func (x *ProjectDefaults) Reset()

+ func (x *ProjectDefaults) String() string

+ type ProjectDefaultsMultiError []error

+ func (m ProjectDefaultsMultiError) AllErrors() []error

+ func (m ProjectDefaultsMultiError) Error() string

+ type ProjectDefaultsValidationError struct

+ func (e ProjectDefaultsValidationError) Cause() error

+ func (e ProjectDefaultsValidationError) Error() string

+ func (e ProjectDefaultsValidationError) ErrorName() string

+ func (e ProjectDefaultsValidationError) Field() string

+ func (e ProjectDefaultsValidationError) Key() bool

+ func (e ProjectDefaultsValidationError) Reason() string

type RenderTemplateRequest

+ func (m *RenderTemplateRequest) Validate() error

+ func (m *RenderTemplateRequest) ValidateAll() error

+ type RenderTemplateRequestMultiError []error

+ func (m RenderTemplateRequestMultiError) AllErrors() []error

+ func (m RenderTemplateRequestMultiError) Error() string

+ type RenderTemplateRequestValidationError struct

+ func (e RenderTemplateRequestValidationError) Cause() error

+ func (e RenderTemplateRequestValidationError) Error() string

+ func (e RenderTemplateRequestValidationError) ErrorName() string

+ func (e RenderTemplateRequestValidationError) Field() string

+ func (e RenderTemplateRequestValidationError) Key() bool

+ func (e RenderTemplateRequestValidationError) Reason() string

type RenderTemplateResponse

+ func (m *RenderTemplateResponse) Validate() error

+ func (m *RenderTemplateResponse) ValidateAll() error

+ type RenderTemplateResponseMultiError []error

+ func (m RenderTemplateResponseMultiError) AllErrors() []error

+ func (m RenderTemplateResponseMultiError) Error() string

+ type RenderTemplateResponseValidationError struct

+ func (e RenderTemplateResponseValidationError) Cause() error

+ func (e RenderTemplateResponseValidationError) Error() string

+ func (e RenderTemplateResponseValidationError) ErrorName() string

+ func (e RenderTemplateResponseValidationError) Field() string

+ func (e RenderTemplateResponseValidationError) Key() bool

+ func (e RenderTemplateResponseValidationError) Reason() string

+ type RerunPipelineRequest struct

+ Pipeline *Pipeline

+ Reprocess bool

+ func (*RerunPipelineRequest) Descriptor() ([]byte, []int)

+ func (*RerunPipelineRequest) ProtoMessage()

+ func (m *RerunPipelineRequest) Validate() error

+ func (m *RerunPipelineRequest) ValidateAll() error

+ func (x *RerunPipelineRequest) GetPipeline() *Pipeline

+ func (x *RerunPipelineRequest) GetReprocess() bool

+ func (x *RerunPipelineRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *RerunPipelineRequest) ProtoReflect() protoreflect.Message

+ func (x *RerunPipelineRequest) Reset()

+ func (x *RerunPipelineRequest) String() string

+ type RerunPipelineRequestMultiError []error

+ func (m RerunPipelineRequestMultiError) AllErrors() []error

+ func (m RerunPipelineRequestMultiError) Error() string

+ type RerunPipelineRequestValidationError struct

+ func (e RerunPipelineRequestValidationError) Cause() error

+ func (e RerunPipelineRequestValidationError) Error() string

+ func (e RerunPipelineRequestValidationError) ErrorName() string

+ func (e RerunPipelineRequestValidationError) Field() string

+ func (e RerunPipelineRequestValidationError) Key() bool

+ func (e RerunPipelineRequestValidationError) Reason() string

type ResourceSpec

+ func (m *ResourceSpec) Validate() error

+ func (m *ResourceSpec) ValidateAll() error

+ type ResourceSpecMultiError []error

+ func (m ResourceSpecMultiError) AllErrors() []error

+ func (m ResourceSpecMultiError) Error() string

+ type ResourceSpecValidationError struct

+ func (e ResourceSpecValidationError) Cause() error

+ func (e ResourceSpecValidationError) Error() string

+ func (e ResourceSpecValidationError) ErrorName() string

+ func (e ResourceSpecValidationError) Field() string

+ func (e ResourceSpecValidationError) Key() bool

+ func (e ResourceSpecValidationError) Reason() string

type RestartDatumRequest

+ func (m *RestartDatumRequest) Validate() error

+ func (m *RestartDatumRequest) ValidateAll() error

+ type RestartDatumRequestMultiError []error

+ func (m RestartDatumRequestMultiError) AllErrors() []error

+ func (m RestartDatumRequestMultiError) Error() string

+ type RestartDatumRequestValidationError struct

+ func (e RestartDatumRequestValidationError) Cause() error

+ func (e RestartDatumRequestValidationError) Error() string

+ func (e RestartDatumRequestValidationError) ErrorName() string

+ func (e RestartDatumRequestValidationError) Field() string

+ func (e RestartDatumRequestValidationError) Key() bool

+ func (e RestartDatumRequestValidationError) Reason() string

type RunCronRequest

+ func (m *RunCronRequest) Validate() error

+ func (m *RunCronRequest) ValidateAll() error

+ type RunCronRequestMultiError []error

+ func (m RunCronRequestMultiError) AllErrors() []error

+ func (m RunCronRequestMultiError) Error() string

+ type RunCronRequestValidationError struct

+ func (e RunCronRequestValidationError) Cause() error

+ func (e RunCronRequestValidationError) Error() string

+ func (e RunCronRequestValidationError) ErrorName() string

+ func (e RunCronRequestValidationError) Field() string

+ func (e RunCronRequestValidationError) Key() bool

+ func (e RunCronRequestValidationError) Reason() string

type RunLoadTestRequest

+ func (m *RunLoadTestRequest) Validate() error

+ func (m *RunLoadTestRequest) ValidateAll() error

+ type RunLoadTestRequestMultiError []error

+ func (m RunLoadTestRequestMultiError) AllErrors() []error

+ func (m RunLoadTestRequestMultiError) Error() string

+ type RunLoadTestRequestValidationError struct

+ func (e RunLoadTestRequestValidationError) Cause() error

+ func (e RunLoadTestRequestValidationError) Error() string

+ func (e RunLoadTestRequestValidationError) ErrorName() string

+ func (e RunLoadTestRequestValidationError) Field() string

+ func (e RunLoadTestRequestValidationError) Key() bool

+ func (e RunLoadTestRequestValidationError) Reason() string

type RunLoadTestResponse

+ func (m *RunLoadTestResponse) Validate() error

+ func (m *RunLoadTestResponse) ValidateAll() error

+ type RunLoadTestResponseMultiError []error

+ func (m RunLoadTestResponseMultiError) AllErrors() []error

+ func (m RunLoadTestResponseMultiError) Error() string

+ type RunLoadTestResponseValidationError struct

+ func (e RunLoadTestResponseValidationError) Cause() error

+ func (e RunLoadTestResponseValidationError) Error() string

+ func (e RunLoadTestResponseValidationError) ErrorName() string

+ func (e RunLoadTestResponseValidationError) Field() string

+ func (e RunLoadTestResponseValidationError) Key() bool

+ func (e RunLoadTestResponseValidationError) Reason() string

type RunPipelineRequest

+ func (m *RunPipelineRequest) Validate() error

+ func (m *RunPipelineRequest) ValidateAll() error

+ type RunPipelineRequestMultiError []error

+ func (m RunPipelineRequestMultiError) AllErrors() []error

+ func (m RunPipelineRequestMultiError) Error() string

+ type RunPipelineRequestValidationError struct

+ func (e RunPipelineRequestValidationError) Cause() error

+ func (e RunPipelineRequestValidationError) Error() string

+ func (e RunPipelineRequestValidationError) ErrorName() string

+ func (e RunPipelineRequestValidationError) Field() string

+ func (e RunPipelineRequestValidationError) Key() bool

+ func (e RunPipelineRequestValidationError) Reason() string

type SchedulingSpec

+ func (m *SchedulingSpec) Validate() error

+ func (m *SchedulingSpec) ValidateAll() error

+ type SchedulingSpecMultiError []error

+ func (m SchedulingSpecMultiError) AllErrors() []error

+ func (m SchedulingSpecMultiError) Error() string

+ type SchedulingSpecValidationError struct

+ func (e SchedulingSpecValidationError) Cause() error

+ func (e SchedulingSpecValidationError) Error() string

+ func (e SchedulingSpecValidationError) ErrorName() string

+ func (e SchedulingSpecValidationError) Field() string

+ func (e SchedulingSpecValidationError) Key() bool

+ func (e SchedulingSpecValidationError) Reason() string

type Secret

+ func (m *Secret) Validate() error

+ func (m *Secret) ValidateAll() error

type SecretInfo

+ func (m *SecretInfo) Validate() error

+ func (m *SecretInfo) ValidateAll() error

+ type SecretInfoMultiError []error

+ func (m SecretInfoMultiError) AllErrors() []error

+ func (m SecretInfoMultiError) Error() string

+ type SecretInfoValidationError struct

+ func (e SecretInfoValidationError) Cause() error

+ func (e SecretInfoValidationError) Error() string

+ func (e SecretInfoValidationError) ErrorName() string

+ func (e SecretInfoValidationError) Field() string

+ func (e SecretInfoValidationError) Key() bool

+ func (e SecretInfoValidationError) Reason() string

type SecretInfos

+ func (m *SecretInfos) Validate() error

+ func (m *SecretInfos) ValidateAll() error

+ type SecretInfosMultiError []error

+ func (m SecretInfosMultiError) AllErrors() []error

+ func (m SecretInfosMultiError) Error() string

+ type SecretInfosValidationError struct

+ func (e SecretInfosValidationError) Cause() error

+ func (e SecretInfosValidationError) Error() string

+ func (e SecretInfosValidationError) ErrorName() string

+ func (e SecretInfosValidationError) Field() string

+ func (e SecretInfosValidationError) Key() bool

+ func (e SecretInfosValidationError) Reason() string

type SecretMount

+ func (m *SecretMount) Validate() error

+ func (m *SecretMount) ValidateAll() error

+ type SecretMountMultiError []error

+ func (m SecretMountMultiError) AllErrors() []error

+ func (m SecretMountMultiError) Error() string

+ type SecretMountValidationError struct

+ func (e SecretMountValidationError) Cause() error

+ func (e SecretMountValidationError) Error() string

+ func (e SecretMountValidationError) ErrorName() string

+ func (e SecretMountValidationError) Field() string

+ func (e SecretMountValidationError) Key() bool

+ func (e SecretMountValidationError) Reason() string

+ type SecretMultiError []error

+ func (m SecretMultiError) AllErrors() []error

+ func (m SecretMultiError) Error() string

+ type SecretValidationError struct

+ func (e SecretValidationError) Cause() error

+ func (e SecretValidationError) Error() string

+ func (e SecretValidationError) ErrorName() string

+ func (e SecretValidationError) Field() string

+ func (e SecretValidationError) Key() bool

+ func (e SecretValidationError) Reason() string

type Service

+ func (m *Service) Validate() error

+ func (m *Service) ValidateAll() error

+ type ServiceMultiError []error

+ func (m ServiceMultiError) AllErrors() []error

+ func (m ServiceMultiError) Error() string

+ type ServiceValidationError struct

+ func (e ServiceValidationError) Cause() error

+ func (e ServiceValidationError) Error() string

+ func (e ServiceValidationError) ErrorName() string

+ func (e ServiceValidationError) Field() string

+ func (e ServiceValidationError) Key() bool

+ func (e ServiceValidationError) Reason() string

type SetClusterDefaultsRequest

+ ClusterDefaultsJson string

+ func (m *SetClusterDefaultsRequest) Validate() error

+ func (m *SetClusterDefaultsRequest) ValidateAll() error

+ func (x *SetClusterDefaultsRequest) GetClusterDefaultsJson() string

+ type SetClusterDefaultsRequestMultiError []error

+ func (m SetClusterDefaultsRequestMultiError) AllErrors() []error

+ func (m SetClusterDefaultsRequestMultiError) Error() string

+ type SetClusterDefaultsRequestValidationError struct

+ func (e SetClusterDefaultsRequestValidationError) Cause() error

+ func (e SetClusterDefaultsRequestValidationError) Error() string

+ func (e SetClusterDefaultsRequestValidationError) ErrorName() string

+ func (e SetClusterDefaultsRequestValidationError) Field() string

+ func (e SetClusterDefaultsRequestValidationError) Key() bool

+ func (e SetClusterDefaultsRequestValidationError) Reason() string

type SetClusterDefaultsResponse

+ func (m *SetClusterDefaultsResponse) Validate() error

+ func (m *SetClusterDefaultsResponse) ValidateAll() error

+ type SetClusterDefaultsResponseMultiError []error

+ func (m SetClusterDefaultsResponseMultiError) AllErrors() []error

+ func (m SetClusterDefaultsResponseMultiError) Error() string

+ type SetClusterDefaultsResponseValidationError struct

+ func (e SetClusterDefaultsResponseValidationError) Cause() error

+ func (e SetClusterDefaultsResponseValidationError) Error() string

+ func (e SetClusterDefaultsResponseValidationError) ErrorName() string

+ func (e SetClusterDefaultsResponseValidationError) Field() string

+ func (e SetClusterDefaultsResponseValidationError) Key() bool

+ func (e SetClusterDefaultsResponseValidationError) Reason() string

+ type SetProjectDefaultsRequest struct

+ DryRun bool

+ Project *pfs.Project

+ ProjectDefaultsJson string

+ Regenerate bool

+ Reprocess bool

+ func (*SetProjectDefaultsRequest) Descriptor() ([]byte, []int)

+ func (*SetProjectDefaultsRequest) ProtoMessage()

+ func (m *SetProjectDefaultsRequest) Validate() error

+ func (m *SetProjectDefaultsRequest) ValidateAll() error

+ func (x *SetProjectDefaultsRequest) GetDryRun() bool

+ func (x *SetProjectDefaultsRequest) GetProject() *pfs.Project

+ func (x *SetProjectDefaultsRequest) GetProjectDefaultsJson() string

+ func (x *SetProjectDefaultsRequest) GetRegenerate() bool

+ func (x *SetProjectDefaultsRequest) GetReprocess() bool

+ func (x *SetProjectDefaultsRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *SetProjectDefaultsRequest) ProtoReflect() protoreflect.Message

+ func (x *SetProjectDefaultsRequest) Reset()

+ func (x *SetProjectDefaultsRequest) String() string

+ type SetProjectDefaultsRequestMultiError []error

+ func (m SetProjectDefaultsRequestMultiError) AllErrors() []error

+ func (m SetProjectDefaultsRequestMultiError) Error() string

+ type SetProjectDefaultsRequestValidationError struct

+ func (e SetProjectDefaultsRequestValidationError) Cause() error

+ func (e SetProjectDefaultsRequestValidationError) Error() string

+ func (e SetProjectDefaultsRequestValidationError) ErrorName() string

+ func (e SetProjectDefaultsRequestValidationError) Field() string

+ func (e SetProjectDefaultsRequestValidationError) Key() bool

+ func (e SetProjectDefaultsRequestValidationError) Reason() string

+ type SetProjectDefaultsResponse struct

+ AffectedPipelines []*Pipeline

+ func (*SetProjectDefaultsResponse) Descriptor() ([]byte, []int)

+ func (*SetProjectDefaultsResponse) ProtoMessage()

+ func (m *SetProjectDefaultsResponse) Validate() error

+ func (m *SetProjectDefaultsResponse) ValidateAll() error

+ func (x *SetProjectDefaultsResponse) GetAffectedPipelines() []*Pipeline

+ func (x *SetProjectDefaultsResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *SetProjectDefaultsResponse) ProtoReflect() protoreflect.Message

+ func (x *SetProjectDefaultsResponse) Reset()

+ func (x *SetProjectDefaultsResponse) String() string

+ type SetProjectDefaultsResponseMultiError []error

+ func (m SetProjectDefaultsResponseMultiError) AllErrors() []error

+ func (m SetProjectDefaultsResponseMultiError) Error() string

+ type SetProjectDefaultsResponseValidationError struct

+ func (e SetProjectDefaultsResponseValidationError) Cause() error

+ func (e SetProjectDefaultsResponseValidationError) Error() string

+ func (e SetProjectDefaultsResponseValidationError) ErrorName() string

+ func (e SetProjectDefaultsResponseValidationError) Field() string

+ func (e SetProjectDefaultsResponseValidationError) Key() bool

+ func (e SetProjectDefaultsResponseValidationError) Reason() string

type Spout

+ func (m *Spout) Validate() error

+ func (m *Spout) ValidateAll() error

+ type SpoutMultiError []error

+ func (m SpoutMultiError) AllErrors() []error

+ func (m SpoutMultiError) Error() string

+ type SpoutValidationError struct

+ func (e SpoutValidationError) Cause() error

+ func (e SpoutValidationError) Error() string

+ func (e SpoutValidationError) ErrorName() string

+ func (e SpoutValidationError) Field() string

+ func (e SpoutValidationError) Key() bool

+ func (e SpoutValidationError) Reason() string

type StartPipelineRequest

+ func (m *StartPipelineRequest) Validate() error

+ func (m *StartPipelineRequest) ValidateAll() error

+ type StartPipelineRequestMultiError []error

+ func (m StartPipelineRequestMultiError) AllErrors() []error

+ func (m StartPipelineRequestMultiError) Error() string

+ type StartPipelineRequestValidationError struct

+ func (e StartPipelineRequestValidationError) Cause() error

+ func (e StartPipelineRequestValidationError) Error() string

+ func (e StartPipelineRequestValidationError) ErrorName() string

+ func (e StartPipelineRequestValidationError) Field() string

+ func (e StartPipelineRequestValidationError) Key() bool

+ func (e StartPipelineRequestValidationError) Reason() string

type StopJobRequest

+ func (m *StopJobRequest) Validate() error

+ func (m *StopJobRequest) ValidateAll() error

+ type StopJobRequestMultiError []error

+ func (m StopJobRequestMultiError) AllErrors() []error

+ func (m StopJobRequestMultiError) Error() string

+ type StopJobRequestValidationError struct

+ func (e StopJobRequestValidationError) Cause() error

+ func (e StopJobRequestValidationError) Error() string

+ func (e StopJobRequestValidationError) ErrorName() string

+ func (e StopJobRequestValidationError) Field() string

+ func (e StopJobRequestValidationError) Key() bool

+ func (e StopJobRequestValidationError) Reason() string

type StopPipelineRequest

+ MustExist bool

+ func (m *StopPipelineRequest) Validate() error

+ func (m *StopPipelineRequest) ValidateAll() error

+ func (x *StopPipelineRequest) GetMustExist() bool

+ type StopPipelineRequestMultiError []error

+ func (m StopPipelineRequestMultiError) AllErrors() []error

+ func (m StopPipelineRequestMultiError) Error() string

+ type StopPipelineRequestValidationError struct

+ func (e StopPipelineRequestValidationError) Cause() error

+ func (e StopPipelineRequestValidationError) Error() string

+ func (e StopPipelineRequestValidationError) ErrorName() string

+ func (e StopPipelineRequestValidationError) Field() string

+ func (e StopPipelineRequestValidationError) Key() bool

+ func (e StopPipelineRequestValidationError) Reason() string

type SubscribeJobRequest

+ func (m *SubscribeJobRequest) Validate() error

+ func (m *SubscribeJobRequest) ValidateAll() error

+ type SubscribeJobRequestMultiError []error

+ func (m SubscribeJobRequestMultiError) AllErrors() []error

+ func (m SubscribeJobRequestMultiError) Error() string

+ type SubscribeJobRequestValidationError struct

+ func (e SubscribeJobRequestValidationError) Cause() error

+ func (e SubscribeJobRequestValidationError) Error() string

+ func (e SubscribeJobRequestValidationError) ErrorName() string

+ func (e SubscribeJobRequestValidationError) Field() string

+ func (e SubscribeJobRequestValidationError) Key() bool

+ func (e SubscribeJobRequestValidationError) Reason() string

type TFJob

+ func (m *TFJob) Validate() error

+ func (m *TFJob) ValidateAll() error

+ type TFJobMultiError []error

+ func (m TFJobMultiError) AllErrors() []error

+ func (m TFJobMultiError) Error() string

+ type TFJobValidationError struct

+ func (e TFJobValidationError) Cause() error

+ func (e TFJobValidationError) Error() string

+ func (e TFJobValidationError) ErrorName() string

+ func (e TFJobValidationError) Field() string

+ func (e TFJobValidationError) Key() bool

+ func (e TFJobValidationError) Reason() string

type Toleration

+ func (m *Toleration) Validate() error

+ func (m *Toleration) ValidateAll() error

+ type TolerationMultiError []error

+ func (m TolerationMultiError) AllErrors() []error

+ func (m TolerationMultiError) Error() string

+ type TolerationValidationError struct

+ func (e TolerationValidationError) Cause() error

+ func (e TolerationValidationError) Error() string

+ func (e TolerationValidationError) ErrorName() string

+ func (e TolerationValidationError) Field() string

+ func (e TolerationValidationError) Key() bool

+ func (e TolerationValidationError) Reason() string

type Transform

+ func (m *Transform) Validate() error

+ func (m *Transform) ValidateAll() error

+ type TransformMultiError []error

+ func (m TransformMultiError) AllErrors() []error

+ func (m TransformMultiError) Error() string

+ type TransformValidationError struct

+ func (e TransformValidationError) Cause() error

+ func (e TransformValidationError) Error() string

+ func (e TransformValidationError) ErrorName() string

+ func (e TransformValidationError) Field() string

+ func (e TransformValidationError) Key() bool

+ func (e TransformValidationError) Reason() string

type UnimplementedAPIServer

+ func (UnimplementedAPIServer) CreatePipelineV2(context.Context, *CreatePipelineV2Request) (*CreatePipelineV2Response, error)

+ func (UnimplementedAPIServer) GetClusterDefaults(context.Context, *GetClusterDefaultsRequest) (*GetClusterDefaultsResponse, error)

+ func (UnimplementedAPIServer) GetProjectDefaults(context.Context, *GetProjectDefaultsRequest) (*GetProjectDefaultsResponse, error)

+ func (UnimplementedAPIServer) RerunPipeline(context.Context, *RerunPipelineRequest) (*emptypb.Empty, error)

+ func (UnimplementedAPIServer) SetClusterDefaults(context.Context, *SetClusterDefaultsRequest) (*SetClusterDefaultsResponse, error)

+ func (UnimplementedAPIServer) SetProjectDefaults(context.Context, *SetProjectDefaultsRequest) (*SetProjectDefaultsResponse, error)

type UpdateJobStateRequest

+ func (m *UpdateJobStateRequest) Validate() error

+ func (m *UpdateJobStateRequest) ValidateAll() error

+ type UpdateJobStateRequestMultiError []error

+ func (m UpdateJobStateRequestMultiError) AllErrors() []error

+ func (m UpdateJobStateRequestMultiError) Error() string

+ type UpdateJobStateRequestValidationError struct

+ func (e UpdateJobStateRequestValidationError) Cause() error

+ func (e UpdateJobStateRequestValidationError) Error() string

+ func (e UpdateJobStateRequestValidationError) ErrorName() string

+ func (e UpdateJobStateRequestValidationError) Field() string

+ func (e UpdateJobStateRequestValidationError) Key() bool

+ func (e UpdateJobStateRequestValidationError) Reason() string

type Worker

+ func (m *Worker) Validate() error

+ func (m *Worker) ValidateAll() error

+ type WorkerMultiError []error

+ func (m WorkerMultiError) AllErrors() []error

+ func (m WorkerMultiError) Error() string

type WorkerStatus

+ func (m *WorkerStatus) Validate() error

+ func (m *WorkerStatus) ValidateAll() error

+ type WorkerStatusMultiError []error

+ func (m WorkerStatusMultiError) AllErrors() []error

+ func (m WorkerStatusMultiError) Error() string

+ type WorkerStatusValidationError struct

+ func (e WorkerStatusValidationError) Cause() error

+ func (e WorkerStatusValidationError) Error() string

+ func (e WorkerStatusValidationError) ErrorName() string

+ func (e WorkerStatusValidationError) Field() string

+ func (e WorkerStatusValidationError) Key() bool

+ func (e WorkerStatusValidationError) Reason() string

+ type WorkerValidationError struct

+ func (e WorkerValidationError) Cause() error

+ func (e WorkerValidationError) Error() string

+ func (e WorkerValidationError) ErrorName() string

+ func (e WorkerValidationError) Field() string

+ func (e WorkerValidationError) Key() bool

+ func (e WorkerValidationError) Reason() string

Aug 9, 2023

Changes in this version

+ const API_ActivateAuth_FullMethodName

+ const API_CreatePipeline_FullMethodName

+ const API_CreateSecret_FullMethodName

+ const API_DeleteAll_FullMethodName

+ const API_DeleteJob_FullMethodName

+ const API_DeletePipeline_FullMethodName

+ const API_DeletePipelines_FullMethodName

+ const API_DeleteSecret_FullMethodName

+ const API_GetKubeEvents_FullMethodName

+ const API_GetLogs_FullMethodName

+ const API_InspectDatum_FullMethodName

+ const API_InspectJobSet_FullMethodName

+ const API_InspectJob_FullMethodName

+ const API_InspectPipeline_FullMethodName

+ const API_InspectSecret_FullMethodName

+ const API_ListDatum_FullMethodName

+ const API_ListJobSet_FullMethodName

+ const API_ListJob_FullMethodName

+ const API_ListPipeline_FullMethodName

+ const API_ListSecret_FullMethodName

+ const API_ListTask_FullMethodName

+ const API_QueryLoki_FullMethodName

+ const API_RenderTemplate_FullMethodName

+ const API_RestartDatum_FullMethodName

+ const API_RunCron_FullMethodName

+ const API_RunLoadTestDefault_FullMethodName

+ const API_RunLoadTest_FullMethodName

+ const API_RunPipeline_FullMethodName

+ const API_StartPipeline_FullMethodName

+ const API_StopJob_FullMethodName

+ const API_StopPipeline_FullMethodName

+ const API_SubscribeJob_FullMethodName

+ const API_UpdateJobState_FullMethodName

+ var API_ServiceDesc = grpc.ServiceDesc

+ var File_pps_pps_proto protoreflect.FileDescriptor

type ActivateAuthRequest

+ func (x *ActivateAuthRequest) ProtoReflect() protoreflect.Message

type ActivateAuthResponse

+ func (x *ActivateAuthResponse) ProtoReflect() protoreflect.Message

type Aggregate

+ func (x *Aggregate) ProtoReflect() protoreflect.Message

type AggregateProcessStats

+ func (x *AggregateProcessStats) ProtoReflect() protoreflect.Message

+ type ClusterDefaults struct

+ DetailsJson string

+ EffectiveDetailsJson string

+ func (*ClusterDefaults) Descriptor() ([]byte, []int)

+ func (*ClusterDefaults) ProtoMessage()

+ func (x *ClusterDefaults) GetDetailsJson() string

+ func (x *ClusterDefaults) GetEffectiveDetailsJson() string

+ func (x *ClusterDefaults) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *ClusterDefaults) ProtoReflect() protoreflect.Message

+ func (x *ClusterDefaults) Reset()

+ func (x *ClusterDefaults) String() string

type CreatePipelineRequest

+ DetailsJson string

+ Determined *Determined

+ DryRun bool

+ TfJob *TFJob

+ func (x *CreatePipelineRequest) GetDetailsJson() string

+ func (x *CreatePipelineRequest) GetDetermined() *Determined

+ func (x *CreatePipelineRequest) GetDryRun() bool

+ func (x *CreatePipelineRequest) GetTfJob() *TFJob

+ func (x *CreatePipelineRequest) ProtoReflect() protoreflect.Message

+ type CreatePipelineResponse struct

+ DetailsJson string

+ func (*CreatePipelineResponse) Descriptor() ([]byte, []int)

+ func (*CreatePipelineResponse) ProtoMessage()

+ func (x *CreatePipelineResponse) GetDetailsJson() string

+ func (x *CreatePipelineResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *CreatePipelineResponse) ProtoReflect() protoreflect.Message

+ func (x *CreatePipelineResponse) Reset()

+ func (x *CreatePipelineResponse) String() string

type CreateSecretRequest

+ func (x *CreateSecretRequest) ProtoReflect() protoreflect.Message

type CronInput

+ func (x *CronInput) ProtoReflect() protoreflect.Message

type Datum

+ Id string

+ func (x *Datum) GetId() string

+ func (x *Datum) ProtoReflect() protoreflect.Message

type DatumInfo

+ func (x *DatumInfo) ProtoReflect() protoreflect.Message

type DatumSetSpec

+ func (x *DatumSetSpec) ProtoReflect() protoreflect.Message

type DatumState

+ func (DatumState) Descriptor() protoreflect.EnumDescriptor

+ func (DatumState) Type() protoreflect.EnumType

+ func (x DatumState) Enum() *DatumState

+ func (x DatumState) Number() protoreflect.EnumNumber

type DatumStatus

+ func (x *DatumStatus) ProtoReflect() protoreflect.Message

type DeleteJobRequest

+ func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message

type DeletePipelineRequest

+ func (x *DeletePipelineRequest) ProtoReflect() protoreflect.Message

type DeletePipelinesRequest

+ func (x *DeletePipelinesRequest) ProtoReflect() protoreflect.Message

type DeletePipelinesResponse

+ func (x *DeletePipelinesResponse) ProtoReflect() protoreflect.Message

type DeleteSecretRequest

+ func (x *DeleteSecretRequest) ProtoReflect() protoreflect.Message

+ type Determined struct

+ Workspaces []string

+ func (*Determined) Descriptor() ([]byte, []int)

+ func (*Determined) ProtoMessage()

+ func (x *Determined) GetWorkspaces() []string

+ func (x *Determined) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *Determined) ProtoReflect() protoreflect.Message

+ func (x *Determined) Reset()

+ func (x *Determined) String() string

type Egress

+ func (x *Egress) ProtoReflect() protoreflect.Message

type GPUSpec

+ func (x *GPUSpec) ProtoReflect() protoreflect.Message

+ type GetClusterDefaultsRequest struct

+ func (*GetClusterDefaultsRequest) Descriptor() ([]byte, []int)

+ func (*GetClusterDefaultsRequest) ProtoMessage()

+ func (x *GetClusterDefaultsRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *GetClusterDefaultsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetClusterDefaultsRequest) Reset()

+ func (x *GetClusterDefaultsRequest) String() string

+ type GetClusterDefaultsResponse struct

+ ClusterDefaults *ClusterDefaults

+ func (*GetClusterDefaultsResponse) Descriptor() ([]byte, []int)

+ func (*GetClusterDefaultsResponse) ProtoMessage()

+ func (x *GetClusterDefaultsResponse) GetClusterDefaults() *ClusterDefaults

+ func (x *GetClusterDefaultsResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *GetClusterDefaultsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetClusterDefaultsResponse) Reset()

+ func (x *GetClusterDefaultsResponse) String() string

type GetLogsRequest

+ func (x *GetLogsRequest) ProtoReflect() protoreflect.Message

type Input

+ func (x *Input) ProtoReflect() protoreflect.Message

type InputFile

+ func (x *InputFile) ProtoReflect() protoreflect.Message

type InspectDatumRequest

+ func (x *InspectDatumRequest) ProtoReflect() protoreflect.Message

type InspectJobRequest

+ func (x *InspectJobRequest) ProtoReflect() protoreflect.Message

type InspectJobSetRequest

+ func (x *InspectJobSetRequest) ProtoReflect() protoreflect.Message

type InspectPipelineRequest

+ func (x *InspectPipelineRequest) ProtoReflect() protoreflect.Message

type InspectSecretRequest

+ func (x *InspectSecretRequest) ProtoReflect() protoreflect.Message

type Job

+ Id string

+ func (x *Job) GetId() string

+ func (x *Job) ProtoReflect() protoreflect.Message

type JobInfo

+ AuthToken string

+ func (x *JobInfo) GetAuthToken() string

+ func (x *JobInfo) ProtoReflect() protoreflect.Message

type JobInfo_Details

+ func (x *JobInfo_Details) ProtoReflect() protoreflect.Message

type JobInput

+ func (x *JobInput) ProtoReflect() protoreflect.Message

type JobSet

+ Id string

+ func (x *JobSet) GetId() string

+ func (x *JobSet) ProtoReflect() protoreflect.Message

type JobSetInfo

+ func (x *JobSetInfo) ProtoReflect() protoreflect.Message

type JobState

+ func (JobState) Descriptor() protoreflect.EnumDescriptor

+ func (JobState) Type() protoreflect.EnumType

+ func (x JobState) Enum() *JobState

+ func (x JobState) Number() protoreflect.EnumNumber

type ListDatumRequest

+ func (x *ListDatumRequest) ProtoReflect() protoreflect.Message

type ListDatumRequest_Filter

+ func (x *ListDatumRequest_Filter) ProtoReflect() protoreflect.Message

type ListJobRequest

+ func (x *ListJobRequest) ProtoReflect() protoreflect.Message

type ListJobSetRequest

+ JqFilter string

+ func (x *ListJobSetRequest) GetJqFilter() string

+ func (x *ListJobSetRequest) ProtoReflect() protoreflect.Message

type ListPipelineRequest

+ func (x *ListPipelineRequest) ProtoReflect() protoreflect.Message

type LogMessage

+ DatumId string

+ JobId string

+ WorkerId string

+ func (x *LogMessage) GetDatumId() string

+ func (x *LogMessage) GetJobId() string

+ func (x *LogMessage) GetWorkerId() string

+ func (x *LogMessage) ProtoReflect() protoreflect.Message

type LokiLogMessage

+ func (x *LokiLogMessage) ProtoReflect() protoreflect.Message

type LokiRequest

+ func (x *LokiRequest) ProtoReflect() protoreflect.Message

type Metadata

+ func (x *Metadata) ProtoReflect() protoreflect.Message

type PFSInput

+ func (x *PFSInput) ProtoReflect() protoreflect.Message

type ParallelismSpec

+ func (x *ParallelismSpec) ProtoReflect() protoreflect.Message

type Pipeline

+ func (x *Pipeline) ProtoReflect() protoreflect.Message

type PipelineInfo

+ DetailsJson string

+ func (x *PipelineInfo) GetDetailsJson() string

+ func (x *PipelineInfo) ProtoReflect() protoreflect.Message

type PipelineInfo_Details

+ Determined *Determined

+ TfJob *TFJob

+ func (x *PipelineInfo_Details) GetDetermined() *Determined

+ func (x *PipelineInfo_Details) GetTfJob() *TFJob

+ func (x *PipelineInfo_Details) ProtoReflect() protoreflect.Message

type PipelineInfo_PipelineType

+ func (PipelineInfo_PipelineType) Descriptor() protoreflect.EnumDescriptor

+ func (PipelineInfo_PipelineType) Type() protoreflect.EnumType

+ func (x PipelineInfo_PipelineType) Enum() *PipelineInfo_PipelineType

+ func (x PipelineInfo_PipelineType) Number() protoreflect.EnumNumber

type PipelineInfos

+ func (x *PipelineInfos) ProtoReflect() protoreflect.Message

type PipelineState

+ func (PipelineState) Descriptor() protoreflect.EnumDescriptor

+ func (PipelineState) Type() protoreflect.EnumType

+ func (x PipelineState) Enum() *PipelineState

+ func (x PipelineState) Number() protoreflect.EnumNumber

type ProcessStats

+ func (x *ProcessStats) ProtoReflect() protoreflect.Message

type RenderTemplateRequest

+ func (x *RenderTemplateRequest) ProtoReflect() protoreflect.Message

type RenderTemplateResponse

+ func (x *RenderTemplateResponse) ProtoReflect() protoreflect.Message

type ResourceSpec

+ func (x *ResourceSpec) ProtoReflect() protoreflect.Message

type RestartDatumRequest

+ func (x *RestartDatumRequest) ProtoReflect() protoreflect.Message

type RunCronRequest

+ func (x *RunCronRequest) ProtoReflect() protoreflect.Message

type RunLoadTestRequest

+ func (x *RunLoadTestRequest) ProtoReflect() protoreflect.Message

type RunLoadTestResponse

+ func (x *RunLoadTestResponse) ProtoReflect() protoreflect.Message

type RunPipelineRequest

+ JobId string

+ func (x *RunPipelineRequest) GetJobId() string

+ func (x *RunPipelineRequest) ProtoReflect() protoreflect.Message

type SchedulingSpec

+ func (x *SchedulingSpec) ProtoReflect() protoreflect.Message

type Secret

+ func (x *Secret) ProtoReflect() protoreflect.Message

type SecretInfo

+ func (x *SecretInfo) ProtoReflect() protoreflect.Message

type SecretInfos

+ func (x *SecretInfos) ProtoReflect() protoreflect.Message

type SecretMount

+ func (x *SecretMount) ProtoReflect() protoreflect.Message

type Service

+ Ip string

+ func (x *Service) GetIp() string

+ func (x *Service) ProtoReflect() protoreflect.Message

+ type SetClusterDefaultsRequest struct

+ ClusterDefaults *ClusterDefaults

+ DryRun bool

+ Regenerate bool

+ Reprocess bool

+ func (*SetClusterDefaultsRequest) Descriptor() ([]byte, []int)

+ func (*SetClusterDefaultsRequest) ProtoMessage()

+ func (x *SetClusterDefaultsRequest) GetClusterDefaults() *ClusterDefaults

+ func (x *SetClusterDefaultsRequest) GetDryRun() bool

+ func (x *SetClusterDefaultsRequest) GetRegenerate() bool

+ func (x *SetClusterDefaultsRequest) GetReprocess() bool

+ func (x *SetClusterDefaultsRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *SetClusterDefaultsRequest) ProtoReflect() protoreflect.Message

+ func (x *SetClusterDefaultsRequest) Reset()

+ func (x *SetClusterDefaultsRequest) String() string

+ type SetClusterDefaultsResponse struct

+ AffectedPipelines []*Pipeline

+ EffectiveDetailsJson string

+ func (*SetClusterDefaultsResponse) Descriptor() ([]byte, []int)

+ func (*SetClusterDefaultsResponse) ProtoMessage()

+ func (x *SetClusterDefaultsResponse) GetAffectedPipelines() []*Pipeline

+ func (x *SetClusterDefaultsResponse) GetEffectiveDetailsJson() string

+ func (x *SetClusterDefaultsResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ func (x *SetClusterDefaultsResponse) ProtoReflect() protoreflect.Message

+ func (x *SetClusterDefaultsResponse) Reset()

+ func (x *SetClusterDefaultsResponse) String() string

type Spout

+ func (x *Spout) ProtoReflect() protoreflect.Message

type StartPipelineRequest

+ func (x *StartPipelineRequest) ProtoReflect() protoreflect.Message

type StopJobRequest

+ func (x *StopJobRequest) ProtoReflect() protoreflect.Message

type StopPipelineRequest

+ func (x *StopPipelineRequest) ProtoReflect() protoreflect.Message

type SubscribeJobRequest

+ func (x *SubscribeJobRequest) ProtoReflect() protoreflect.Message

type TFJob

+ TfJob string

+ func (x *TFJob) GetTfJob() string

+ func (x *TFJob) ProtoReflect() protoreflect.Message

type TaintEffect

+ func (TaintEffect) Descriptor() protoreflect.EnumDescriptor

+ func (TaintEffect) Type() protoreflect.EnumType

+ func (x TaintEffect) Enum() *TaintEffect

+ func (x TaintEffect) Number() protoreflect.EnumNumber

type Toleration

+ func (x *Toleration) ProtoReflect() protoreflect.Message

type TolerationOperator

+ func (TolerationOperator) Descriptor() protoreflect.EnumDescriptor

+ func (TolerationOperator) Type() protoreflect.EnumType

+ func (x TolerationOperator) Enum() *TolerationOperator

+ func (x TolerationOperator) Number() protoreflect.EnumNumber

type Transform

+ func (x *Transform) ProtoReflect() protoreflect.Message

+ type UnsafeAPIServer interface

type UpdateJobStateRequest

+ func (x *UpdateJobStateRequest) ProtoReflect() protoreflect.Message

type Worker

+ func (x *Worker) ProtoReflect() protoreflect.Message

type WorkerState

+ func (WorkerState) Descriptor() protoreflect.EnumDescriptor

+ func (WorkerState) Type() protoreflect.EnumType

+ func (x WorkerState) Enum() *WorkerState

+ func (x WorkerState) Number() protoreflect.EnumNumber

type WorkerStatus

+ JobId string

+ WorkerId string

+ func (x *WorkerStatus) GetJobId() string

+ func (x *WorkerStatus) GetWorkerId() string

+ func (x *WorkerStatus) ProtoReflect() protoreflect.Message

May 11, 2023

Changes in this version

+ var DatumState_name = map[int32]string

+ var DatumState_value = map[string]int32

+ var ErrIntOverflowPps = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPps = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupPps = fmt.Errorf("proto: unexpected end of group")

+ var JobState_name = map[int32]string

+ var JobState_value = map[string]int32

+ var PipelineInfo_PipelineType_name = map[int32]string

+ var PipelineInfo_PipelineType_value = map[string]int32

+ var PipelineState_name = map[int32]string

+ var PipelineState_value = map[string]int32

+ var TaintEffect_name = map[int32]string

+ var TaintEffect_value = map[string]int32

+ var TolerationOperator_name = map[int32]string

+ var TolerationOperator_value = map[string]int32

+ var WorkerState_name = map[int32]string

+ var WorkerState_value = map[string]int32

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

+ func DatumIDField(id string) zap.Field

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

+ func InputName(input *Input) string

+ func IsTerminal(state JobState) bool

+ func JobIDField(id string) zap.Field

+ func MasterField(master bool) zap.Field

+ func PipelineNameField(name string) zap.Field

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

+ func ProjectNameField(name string) zap.Field

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

+ func SortInput(input *Input)

+ func UserField(user bool) zap.Field

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

+ func WorkerIDField(id string) zap.Field

+ type APIClient interface

+ ActivateAuth func(ctx context.Context, in *ActivateAuthRequest, opts ...grpc.CallOption) (*ActivateAuthResponse, error)

+ CreatePipeline func(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ CreateSecret func(ctx context.Context, in *CreateSecretRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ DeleteAll func(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.Empty, error)

+ DeleteJob func(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ DeletePipeline func(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ DeletePipelines func(ctx context.Context, in *DeletePipelinesRequest, opts ...grpc.CallOption) (*DeletePipelinesResponse, error)

+ DeleteSecret func(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ GetKubeEvents func(ctx context.Context, in *LokiRequest, opts ...grpc.CallOption) (API_GetKubeEventsClient, error)

+ GetLogs func(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (API_GetLogsClient, error)

+ InspectDatum func(ctx context.Context, in *InspectDatumRequest, opts ...grpc.CallOption) (*DatumInfo, error)

+ InspectJob func(ctx context.Context, in *InspectJobRequest, opts ...grpc.CallOption) (*JobInfo, error)

+ InspectJobSet func(ctx context.Context, in *InspectJobSetRequest, opts ...grpc.CallOption) (API_InspectJobSetClient, error)

+ InspectPipeline func(ctx context.Context, in *InspectPipelineRequest, opts ...grpc.CallOption) (*PipelineInfo, error)

+ InspectSecret func(ctx context.Context, in *InspectSecretRequest, opts ...grpc.CallOption) (*SecretInfo, error)

+ ListDatum func(ctx context.Context, in *ListDatumRequest, opts ...grpc.CallOption) (API_ListDatumClient, error)

+ ListJob func(ctx context.Context, in *ListJobRequest, opts ...grpc.CallOption) (API_ListJobClient, error)

+ ListJobSet func(ctx context.Context, in *ListJobSetRequest, opts ...grpc.CallOption) (API_ListJobSetClient, error)

+ ListPipeline func(ctx context.Context, in *ListPipelineRequest, opts ...grpc.CallOption) (API_ListPipelineClient, error)

+ ListSecret func(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*SecretInfos, error)

+ ListTask func(ctx context.Context, in *task.ListTaskRequest, opts ...grpc.CallOption) (API_ListTaskClient, error)

+ QueryLoki func(ctx context.Context, in *LokiRequest, opts ...grpc.CallOption) (API_QueryLokiClient, error)

+ RenderTemplate func(ctx context.Context, in *RenderTemplateRequest, opts ...grpc.CallOption) (*RenderTemplateResponse, error)

+ RestartDatum func(ctx context.Context, in *RestartDatumRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ RunCron func(ctx context.Context, in *RunCronRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ RunLoadTest func(ctx context.Context, in *RunLoadTestRequest, opts ...grpc.CallOption) (*RunLoadTestResponse, error)

+ RunLoadTestDefault func(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*RunLoadTestResponse, error)

+ RunPipeline func(ctx context.Context, in *RunPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ StartPipeline func(ctx context.Context, in *StartPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ StopJob func(ctx context.Context, in *StopJobRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ StopPipeline func(ctx context.Context, in *StopPipelineRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ SubscribeJob func(ctx context.Context, in *SubscribeJobRequest, opts ...grpc.CallOption) (API_SubscribeJobClient, error)

+ UpdateJobState func(ctx context.Context, in *UpdateJobStateRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ func NewAPIClient(cc *grpc.ClientConn) APIClient

+ type APIServer interface

+ ActivateAuth func(context.Context, *ActivateAuthRequest) (*ActivateAuthResponse, error)

+ CreatePipeline func(context.Context, *CreatePipelineRequest) (*types.Empty, error)

+ CreateSecret func(context.Context, *CreateSecretRequest) (*types.Empty, error)

+ DeleteAll func(context.Context, *types.Empty) (*types.Empty, error)

+ DeleteJob func(context.Context, *DeleteJobRequest) (*types.Empty, error)

+ DeletePipeline func(context.Context, *DeletePipelineRequest) (*types.Empty, error)

+ DeletePipelines func(context.Context, *DeletePipelinesRequest) (*DeletePipelinesResponse, error)

+ DeleteSecret func(context.Context, *DeleteSecretRequest) (*types.Empty, error)

+ GetKubeEvents func(*LokiRequest, API_GetKubeEventsServer) error

+ GetLogs func(*GetLogsRequest, API_GetLogsServer) error

+ InspectDatum func(context.Context, *InspectDatumRequest) (*DatumInfo, error)

+ InspectJob func(context.Context, *InspectJobRequest) (*JobInfo, error)

+ InspectJobSet func(*InspectJobSetRequest, API_InspectJobSetServer) error

+ InspectPipeline func(context.Context, *InspectPipelineRequest) (*PipelineInfo, error)

+ InspectSecret func(context.Context, *InspectSecretRequest) (*SecretInfo, error)

+ ListDatum func(*ListDatumRequest, API_ListDatumServer) error

+ ListJob func(*ListJobRequest, API_ListJobServer) error

+ ListJobSet func(*ListJobSetRequest, API_ListJobSetServer) error

+ ListPipeline func(*ListPipelineRequest, API_ListPipelineServer) error

+ ListSecret func(context.Context, *types.Empty) (*SecretInfos, error)

+ ListTask func(*task.ListTaskRequest, API_ListTaskServer) error

+ QueryLoki func(*LokiRequest, API_QueryLokiServer) error

+ RenderTemplate func(context.Context, *RenderTemplateRequest) (*RenderTemplateResponse, error)

+ RestartDatum func(context.Context, *RestartDatumRequest) (*types.Empty, error)

+ RunCron func(context.Context, *RunCronRequest) (*types.Empty, error)

+ RunLoadTest func(context.Context, *RunLoadTestRequest) (*RunLoadTestResponse, error)

+ RunLoadTestDefault func(context.Context, *types.Empty) (*RunLoadTestResponse, error)

+ RunPipeline func(context.Context, *RunPipelineRequest) (*types.Empty, error)

+ StartPipeline func(context.Context, *StartPipelineRequest) (*types.Empty, error)

+ StopJob func(context.Context, *StopJobRequest) (*types.Empty, error)

+ StopPipeline func(context.Context, *StopPipelineRequest) (*types.Empty, error)

+ SubscribeJob func(*SubscribeJobRequest, API_SubscribeJobServer) error

+ UpdateJobState func(context.Context, *UpdateJobStateRequest) (*types.Empty, error)

+ type API_GetKubeEventsClient interface

+ Recv func() (*LokiLogMessage, error)

+ type API_GetKubeEventsServer interface

+ Send func(*LokiLogMessage) error

+ type API_GetLogsClient interface

+ Recv func() (*LogMessage, error)

+ type API_GetLogsServer interface

+ Send func(*LogMessage) error

+ type API_InspectJobSetClient interface

+ Recv func() (*JobInfo, error)

+ type API_InspectJobSetServer interface

+ Send func(*JobInfo) error

+ type API_ListDatumClient interface

+ Recv func() (*DatumInfo, error)

+ type API_ListDatumServer interface

+ Send func(*DatumInfo) error

+ type API_ListJobClient interface

+ Recv func() (*JobInfo, error)

+ type API_ListJobServer interface

+ Send func(*JobInfo) error

+ type API_ListJobSetClient interface

+ Recv func() (*JobSetInfo, error)

+ type API_ListJobSetServer interface

+ Send func(*JobSetInfo) error

+ type API_ListPipelineClient interface

+ Recv func() (*PipelineInfo, error)

+ type API_ListPipelineServer interface

+ Send func(*PipelineInfo) error

+ type API_ListTaskClient interface

+ Recv func() (*task.TaskInfo, error)

+ type API_ListTaskServer interface

+ Send func(*task.TaskInfo) error

+ type API_QueryLokiClient interface

+ Recv func() (*LokiLogMessage, error)

+ type API_QueryLokiServer interface

+ Send func(*LokiLogMessage) error

+ type API_SubscribeJobClient interface

+ Recv func() (*JobInfo, error)

+ type API_SubscribeJobServer interface

+ Send func(*JobInfo) error

+ type ActivateAuthRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ActivateAuthRequest) ProtoMessage()

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

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

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

+ func (m *ActivateAuthRequest) Reset()

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

+ func (m *ActivateAuthRequest) String() string

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

+ func (m *ActivateAuthRequest) XXX_DiscardUnknown()

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

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

+ func (m *ActivateAuthRequest) XXX_Size() int

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

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

+ type ActivateAuthResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ActivateAuthResponse) ProtoMessage()

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

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

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

+ func (m *ActivateAuthResponse) Reset()

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

+ func (m *ActivateAuthResponse) String() string

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

+ func (m *ActivateAuthResponse) XXX_DiscardUnknown()

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

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

+ func (m *ActivateAuthResponse) XXX_Size() int

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

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

+ type Aggregate struct

+ Count int64

+ FifthPercentile float64

+ Mean float64

+ NinetyFifthPercentile float64

+ Stddev float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Aggregate) ProtoMessage()

+ func (m *Aggregate) GetCount() int64

+ func (m *Aggregate) GetFifthPercentile() float64

+ func (m *Aggregate) GetMean() float64

+ func (m *Aggregate) GetNinetyFifthPercentile() float64

+ func (m *Aggregate) GetStddev() float64

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

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

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

+ func (m *Aggregate) Reset()

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

+ func (m *Aggregate) String() string

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

+ func (m *Aggregate) XXX_DiscardUnknown()

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

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

+ func (m *Aggregate) XXX_Size() int

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

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

+ type AggregateProcessStats struct

+ DownloadBytes *Aggregate

+ DownloadTime *Aggregate

+ ProcessTime *Aggregate

+ UploadBytes *Aggregate

+ UploadTime *Aggregate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AggregateProcessStats) ProtoMessage()

+ func (m *AggregateProcessStats) GetDownloadBytes() *Aggregate

+ func (m *AggregateProcessStats) GetDownloadTime() *Aggregate

+ func (m *AggregateProcessStats) GetProcessTime() *Aggregate

+ func (m *AggregateProcessStats) GetUploadBytes() *Aggregate

+ func (m *AggregateProcessStats) GetUploadTime() *Aggregate

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

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

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

+ func (m *AggregateProcessStats) Reset()

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

+ func (m *AggregateProcessStats) String() string

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

+ func (m *AggregateProcessStats) XXX_DiscardUnknown()

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

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

+ func (m *AggregateProcessStats) XXX_Size() int

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

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

+ type CreatePipelineRequest struct

+ Autoscaling bool

+ DatumSetSpec *DatumSetSpec

+ DatumTimeout *types.Duration

+ DatumTries int64

+ Description string

+ Egress *Egress

+ Input *Input

+ JobTimeout *types.Duration

+ Metadata *Metadata

+ OutputBranch string

+ ParallelismSpec *ParallelismSpec

+ Pipeline *Pipeline

+ PodPatch string

+ PodSpec string

+ Reprocess bool

+ ReprocessSpec string

+ ResourceLimits *ResourceSpec

+ ResourceRequests *ResourceSpec

+ S3Out bool

+ Salt string

+ SchedulingSpec *SchedulingSpec

+ Service *Service

+ SidecarResourceLimits *ResourceSpec

+ SidecarResourceRequests *ResourceSpec

+ SpecCommit *pfs.Commit

+ Spout *Spout

+ TFJob *TFJob

+ Tolerations []*Toleration

+ Transform *Transform

+ Update bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreatePipelineRequest) ProtoMessage()

+ func (m *CreatePipelineRequest) GetAutoscaling() bool

+ func (m *CreatePipelineRequest) GetDatumSetSpec() *DatumSetSpec

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

+ func (m *CreatePipelineRequest) GetDatumTries() int64

+ func (m *CreatePipelineRequest) GetDescription() string

+ func (m *CreatePipelineRequest) GetEgress() *Egress

+ func (m *CreatePipelineRequest) GetInput() *Input

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

+ func (m *CreatePipelineRequest) GetMetadata() *Metadata

+ func (m *CreatePipelineRequest) GetOutputBranch() string

+ func (m *CreatePipelineRequest) GetParallelismSpec() *ParallelismSpec

+ func (m *CreatePipelineRequest) GetPipeline() *Pipeline

+ func (m *CreatePipelineRequest) GetPodPatch() string

+ func (m *CreatePipelineRequest) GetPodSpec() string

+ func (m *CreatePipelineRequest) GetReprocess() bool

+ func (m *CreatePipelineRequest) GetReprocessSpec() string

+ func (m *CreatePipelineRequest) GetResourceLimits() *ResourceSpec

+ func (m *CreatePipelineRequest) GetResourceRequests() *ResourceSpec

+ func (m *CreatePipelineRequest) GetS3Out() bool

+ func (m *CreatePipelineRequest) GetSalt() string

+ func (m *CreatePipelineRequest) GetSchedulingSpec() *SchedulingSpec

+ func (m *CreatePipelineRequest) GetService() *Service

+ func (m *CreatePipelineRequest) GetSidecarResourceLimits() *ResourceSpec

+ func (m *CreatePipelineRequest) GetSidecarResourceRequests() *ResourceSpec

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

+ func (m *CreatePipelineRequest) GetSpout() *Spout

+ func (m *CreatePipelineRequest) GetTFJob() *TFJob

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

+ func (m *CreatePipelineRequest) GetTransform() *Transform

+ func (m *CreatePipelineRequest) GetUpdate() bool

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

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

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

+ func (m *CreatePipelineRequest) Reset()

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

+ func (m *CreatePipelineRequest) String() string

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

+ func (m *CreatePipelineRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreatePipelineRequest) XXX_Size() int

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

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

+ type CreateSecretRequest struct

+ File []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateSecretRequest) ProtoMessage()

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

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

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

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

+ func (m *CreateSecretRequest) Reset()

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

+ func (m *CreateSecretRequest) String() string

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

+ func (m *CreateSecretRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreateSecretRequest) XXX_Size() int

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

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

+ type CronInput struct

+ Commit string

+ Name string

+ Overwrite bool

+ Project string

+ Repo string

+ Spec string

+ Start *types.Timestamp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CronInput) ProtoMessage()

+ func (m *CronInput) GetCommit() string

+ func (m *CronInput) GetName() string

+ func (m *CronInput) GetOverwrite() bool

+ func (m *CronInput) GetProject() string

+ func (m *CronInput) GetRepo() string

+ func (m *CronInput) GetSpec() string

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

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

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

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

+ func (m *CronInput) Reset()

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

+ func (m *CronInput) String() string

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

+ func (m *CronInput) XXX_DiscardUnknown()

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

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

+ func (m *CronInput) XXX_Size() int

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

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

+ type Datum struct

+ ID string

+ Job *Job

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Datum) ProtoMessage()

+ func (m *Datum) GetID() string

+ func (m *Datum) GetJob() *Job

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

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

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

+ func (m *Datum) Reset()

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

+ func (m *Datum) String() string

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

+ func (m *Datum) XXX_DiscardUnknown()

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

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

+ func (m *Datum) XXX_Size() int

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

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

+ type DatumInfo struct

+ Data []*pfs.FileInfo

+ Datum *Datum

+ ImageId string

+ PfsState *pfs.File

+ State DatumState

+ Stats *ProcessStats

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DatumInfo) ProtoMessage()

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

+ func (m *DatumInfo) GetDatum() *Datum

+ func (m *DatumInfo) GetImageId() string

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

+ func (m *DatumInfo) GetState() DatumState

+ func (m *DatumInfo) GetStats() *ProcessStats

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

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

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

+ func (m *DatumInfo) Reset()

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

+ func (m *DatumInfo) String() string

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

+ func (m *DatumInfo) XXX_DiscardUnknown()

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

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

+ func (m *DatumInfo) XXX_Size() int

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

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

+ type DatumSetSpec struct

+ Number int64

+ PerWorker int64

+ SizeBytes int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DatumSetSpec) ProtoMessage()

+ func (m *DatumSetSpec) GetNumber() int64

+ func (m *DatumSetSpec) GetPerWorker() int64

+ func (m *DatumSetSpec) GetSizeBytes() int64

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

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

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

+ func (m *DatumSetSpec) Reset()

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

+ func (m *DatumSetSpec) String() string

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

+ func (m *DatumSetSpec) XXX_DiscardUnknown()

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

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

+ func (m *DatumSetSpec) XXX_Size() int

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

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

+ type DatumState int32

+ const DatumState_FAILED

+ const DatumState_RECOVERED

+ const DatumState_SKIPPED

+ const DatumState_STARTING

+ const DatumState_SUCCESS

+ const DatumState_UNKNOWN

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

+ func (x DatumState) String() string

+ type DatumStatus struct

+ Data []*InputFile

+ Started *types.Timestamp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DatumStatus) ProtoMessage()

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

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

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

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

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

+ func (m *DatumStatus) Reset()

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

+ func (m *DatumStatus) String() string

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

+ func (m *DatumStatus) XXX_DiscardUnknown()

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

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

+ func (m *DatumStatus) XXX_Size() int

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

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

+ type DeleteJobRequest struct

+ Job *Job

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteJobRequest) ProtoMessage()

+ func (m *DeleteJobRequest) GetJob() *Job

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

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

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

+ func (m *DeleteJobRequest) Reset()

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

+ func (m *DeleteJobRequest) String() string

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

+ func (m *DeleteJobRequest) XXX_DiscardUnknown()

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

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

+ func (m *DeleteJobRequest) XXX_Size() int

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

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

+ type DeletePipelineRequest struct

+ All bool

+ Force bool

+ KeepRepo bool

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeletePipelineRequest) ProtoMessage()

+ func (m *DeletePipelineRequest) GetAll() bool

+ func (m *DeletePipelineRequest) GetForce() bool

+ func (m *DeletePipelineRequest) GetKeepRepo() bool

+ func (m *DeletePipelineRequest) GetPipeline() *Pipeline

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

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

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

+ func (m *DeletePipelineRequest) Reset()

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

+ func (m *DeletePipelineRequest) String() string

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

+ func (m *DeletePipelineRequest) XXX_DiscardUnknown()

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

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

+ func (m *DeletePipelineRequest) XXX_Size() int

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

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

+ type DeletePipelinesRequest struct

+ All bool

+ Force bool

+ KeepRepo bool

+ Projects []*pfs.Project

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeletePipelinesRequest) ProtoMessage()

+ func (m *DeletePipelinesRequest) GetAll() bool

+ func (m *DeletePipelinesRequest) GetForce() bool

+ func (m *DeletePipelinesRequest) GetKeepRepo() bool

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

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

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

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

+ func (m *DeletePipelinesRequest) Reset()

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

+ func (m *DeletePipelinesRequest) String() string

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

+ func (m *DeletePipelinesRequest) XXX_DiscardUnknown()

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

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

+ func (m *DeletePipelinesRequest) XXX_Size() int

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

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

+ type DeletePipelinesResponse struct

+ Pipelines []*Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeletePipelinesResponse) ProtoMessage()

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

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

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

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

+ func (m *DeletePipelinesResponse) Reset()

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

+ func (m *DeletePipelinesResponse) String() string

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

+ func (m *DeletePipelinesResponse) XXX_DiscardUnknown()

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

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

+ func (m *DeletePipelinesResponse) XXX_Size() int

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

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

+ type DeleteSecretRequest struct

+ Secret *Secret

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteSecretRequest) ProtoMessage()

+ func (m *DeleteSecretRequest) GetSecret() *Secret

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

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

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

+ func (m *DeleteSecretRequest) Reset()

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

+ func (m *DeleteSecretRequest) String() string

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

+ func (m *DeleteSecretRequest) XXX_DiscardUnknown()

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

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

+ func (m *DeleteSecretRequest) XXX_Size() int

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

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

+ type Egress struct

+ Target isEgress_Target

+ URL string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Egress) ProtoMessage()

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

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

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

+ func (m *Egress) GetTarget() isEgress_Target

+ func (m *Egress) GetURL() string

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

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

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

+ func (m *Egress) Reset()

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

+ func (m *Egress) String() string

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

+ func (m *Egress) XXX_DiscardUnknown()

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

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

+ func (m *Egress) XXX_Size() int

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

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

+ type Egress_ObjectStorage struct

+ ObjectStorage *pfs.ObjectStorageEgress

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

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

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

+ type Egress_SqlDatabase struct

+ SqlDatabase *pfs.SQLDatabaseEgress

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

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

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

+ type GPUSpec struct

+ Number int64

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GPUSpec) ProtoMessage()

+ func (m *GPUSpec) GetNumber() int64

+ func (m *GPUSpec) GetType() string

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

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

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

+ func (m *GPUSpec) Reset()

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

+ func (m *GPUSpec) String() string

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

+ func (m *GPUSpec) XXX_DiscardUnknown()

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

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

+ func (m *GPUSpec) XXX_Size() int

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

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

+ type GetLogsRequest struct

+ DataFilters []string

+ Datum *Datum

+ Follow bool

+ Job *Job

+ Master bool

+ Pipeline *Pipeline

+ Since *types.Duration

+ Tail int64

+ UseLokiBackend bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetLogsRequest) ProtoMessage()

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

+ func (m *GetLogsRequest) GetDatum() *Datum

+ func (m *GetLogsRequest) GetFollow() bool

+ func (m *GetLogsRequest) GetJob() *Job

+ func (m *GetLogsRequest) GetMaster() bool

+ func (m *GetLogsRequest) GetPipeline() *Pipeline

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

+ func (m *GetLogsRequest) GetTail() int64

+ func (m *GetLogsRequest) GetUseLokiBackend() bool

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

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

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

+ func (m *GetLogsRequest) Reset()

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

+ func (m *GetLogsRequest) String() string

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

+ func (m *GetLogsRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetLogsRequest) XXX_Size() int

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

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

+ type Input struct

+ Cron *CronInput

+ Cross []*Input

+ Group []*Input

+ Join []*Input

+ Pfs *PFSInput

+ Union []*Input

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Input) ProtoMessage()

+ func (m *Input) GetCron() *CronInput

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

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

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

+ func (m *Input) GetPfs() *PFSInput

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

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

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

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

+ func (m *Input) Reset()

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

+ func (m *Input) String() string

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

+ func (m *Input) XXX_DiscardUnknown()

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

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

+ func (m *Input) XXX_Size() int

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

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

+ type InputFile struct

+ Hash []byte

+ Path string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InputFile) ProtoMessage()

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

+ func (m *InputFile) GetPath() string

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

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

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

+ func (m *InputFile) Reset()

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

+ func (m *InputFile) String() string

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

+ func (m *InputFile) XXX_DiscardUnknown()

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

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

+ func (m *InputFile) XXX_Size() int

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

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

+ type InspectDatumRequest struct

+ Datum *Datum

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InspectDatumRequest) ProtoMessage()

+ func (m *InspectDatumRequest) GetDatum() *Datum

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

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

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

+ func (m *InspectDatumRequest) Reset()

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

+ func (m *InspectDatumRequest) String() string

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

+ func (m *InspectDatumRequest) XXX_DiscardUnknown()

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

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

+ func (m *InspectDatumRequest) XXX_Size() int

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

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

+ type InspectJobRequest struct

+ Details bool

+ Job *Job

+ Wait bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InspectJobRequest) ProtoMessage()

+ func (m *InspectJobRequest) GetDetails() bool

+ func (m *InspectJobRequest) GetJob() *Job

+ func (m *InspectJobRequest) GetWait() bool

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

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

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

+ func (m *InspectJobRequest) Reset()

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

+ func (m *InspectJobRequest) String() string

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

+ func (m *InspectJobRequest) XXX_DiscardUnknown()

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

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

+ func (m *InspectJobRequest) XXX_Size() int

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

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

+ type InspectJobSetRequest struct

+ Details bool

+ JobSet *JobSet

+ Wait bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InspectJobSetRequest) ProtoMessage()

+ func (m *InspectJobSetRequest) GetDetails() bool

+ func (m *InspectJobSetRequest) GetJobSet() *JobSet

+ func (m *InspectJobSetRequest) GetWait() bool

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

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

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

+ func (m *InspectJobSetRequest) Reset()

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

+ func (m *InspectJobSetRequest) String() string

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

+ func (m *InspectJobSetRequest) XXX_DiscardUnknown()

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

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

+ func (m *InspectJobSetRequest) XXX_Size() int

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

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

+ type InspectPipelineRequest struct

+ Details bool

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InspectPipelineRequest) ProtoMessage()

+ func (m *InspectPipelineRequest) GetDetails() bool

+ func (m *InspectPipelineRequest) GetPipeline() *Pipeline

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

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

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

+ func (m *InspectPipelineRequest) Reset()

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

+ func (m *InspectPipelineRequest) String() string

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

+ func (m *InspectPipelineRequest) XXX_DiscardUnknown()

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

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

+ func (m *InspectPipelineRequest) XXX_Size() int

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

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

+ type InspectSecretRequest struct

+ Secret *Secret

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InspectSecretRequest) ProtoMessage()

+ func (m *InspectSecretRequest) GetSecret() *Secret

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

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

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

+ func (m *InspectSecretRequest) Reset()

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

+ func (m *InspectSecretRequest) String() string

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

+ func (m *InspectSecretRequest) XXX_DiscardUnknown()

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

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

+ func (m *InspectSecretRequest) XXX_Size() int

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

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

+ type Job struct

+ ID string

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Job) ProtoMessage()

+ func (j *Job) String() string

+ func (m *Job) GetID() string

+ func (m *Job) GetPipeline() *Pipeline

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

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

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

+ func (m *Job) Reset()

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

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

+ func (m *Job) XXX_DiscardUnknown()

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

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

+ func (m *Job) XXX_Size() int

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

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

+ type JobInfo struct

+ Created *types.Timestamp

+ DataFailed int64

+ DataProcessed int64

+ DataRecovered int64

+ DataSkipped int64

+ DataTotal int64

+ Details *JobInfo_Details

+ Finished *types.Timestamp

+ Job *Job

+ OutputCommit *pfs.Commit

+ PipelineVersion uint64

+ Reason string

+ Restart uint64

+ Started *types.Timestamp

+ State JobState

+ Stats *ProcessStats

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobInfo) ProtoMessage()

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

+ func (m *JobInfo) GetDataFailed() int64

+ func (m *JobInfo) GetDataProcessed() int64

+ func (m *JobInfo) GetDataRecovered() int64

+ func (m *JobInfo) GetDataSkipped() int64

+ func (m *JobInfo) GetDataTotal() int64

+ func (m *JobInfo) GetDetails() *JobInfo_Details

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

+ func (m *JobInfo) GetJob() *Job

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

+ func (m *JobInfo) GetPipelineVersion() uint64

+ func (m *JobInfo) GetReason() string

+ func (m *JobInfo) GetRestart() uint64

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

+ func (m *JobInfo) GetState() JobState

+ func (m *JobInfo) GetStats() *ProcessStats

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

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

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

+ func (m *JobInfo) Reset()

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

+ func (m *JobInfo) String() string

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

+ func (m *JobInfo) XXX_DiscardUnknown()

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

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

+ func (m *JobInfo) XXX_Size() int

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

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

+ type JobInfo_Details struct

+ DatumSetSpec *DatumSetSpec

+ DatumTimeout *types.Duration

+ DatumTries int64

+ Egress *Egress

+ Input *Input

+ JobTimeout *types.Duration

+ ParallelismSpec *ParallelismSpec

+ PodPatch string

+ PodSpec string

+ ResourceLimits *ResourceSpec

+ ResourceRequests *ResourceSpec

+ Salt string

+ SchedulingSpec *SchedulingSpec

+ Service *Service

+ SidecarResourceLimits *ResourceSpec

+ SidecarResourceRequests *ResourceSpec

+ Spout *Spout

+ Transform *Transform

+ WorkerStatus []*WorkerStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobInfo_Details) ProtoMessage()

+ func (m *JobInfo_Details) GetDatumSetSpec() *DatumSetSpec

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

+ func (m *JobInfo_Details) GetDatumTries() int64

+ func (m *JobInfo_Details) GetEgress() *Egress

+ func (m *JobInfo_Details) GetInput() *Input

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

+ func (m *JobInfo_Details) GetParallelismSpec() *ParallelismSpec

+ func (m *JobInfo_Details) GetPodPatch() string

+ func (m *JobInfo_Details) GetPodSpec() string

+ func (m *JobInfo_Details) GetResourceLimits() *ResourceSpec

+ func (m *JobInfo_Details) GetResourceRequests() *ResourceSpec

+ func (m *JobInfo_Details) GetSalt() string

+ func (m *JobInfo_Details) GetSchedulingSpec() *SchedulingSpec

+ func (m *JobInfo_Details) GetService() *Service

+ func (m *JobInfo_Details) GetSidecarResourceLimits() *ResourceSpec

+ func (m *JobInfo_Details) GetSidecarResourceRequests() *ResourceSpec

+ func (m *JobInfo_Details) GetSpout() *Spout

+ func (m *JobInfo_Details) GetTransform() *Transform

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

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

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

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

+ func (m *JobInfo_Details) Reset()

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

+ func (m *JobInfo_Details) String() string

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

+ func (m *JobInfo_Details) XXX_DiscardUnknown()

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

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

+ func (m *JobInfo_Details) XXX_Size() int

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

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

+ type JobInput struct

+ Commit *pfs.Commit

+ Glob string

+ Lazy bool

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobInput) ProtoMessage()

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

+ func (m *JobInput) GetGlob() string

+ func (m *JobInput) GetLazy() bool

+ func (m *JobInput) GetName() string

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

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

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

+ func (m *JobInput) Reset()

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

+ func (m *JobInput) String() string

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

+ func (m *JobInput) XXX_DiscardUnknown()

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

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

+ func (m *JobInput) XXX_Size() int

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

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

+ type JobSet struct

+ ID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobSet) ProtoMessage()

+ func (m *JobSet) GetID() string

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

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

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

+ func (m *JobSet) Reset()

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

+ func (m *JobSet) String() string

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

+ func (m *JobSet) XXX_DiscardUnknown()

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

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

+ func (m *JobSet) XXX_Size() int

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

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

+ type JobSetInfo struct

+ JobSet *JobSet

+ Jobs []*JobInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobSetInfo) ProtoMessage()

+ func (m *JobSetInfo) GetJobSet() *JobSet

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

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

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

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

+ func (m *JobSetInfo) Reset()

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

+ func (m *JobSetInfo) String() string

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

+ func (m *JobSetInfo) XXX_DiscardUnknown()

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

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

+ func (m *JobSetInfo) XXX_Size() int

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

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

+ type JobState int32

+ const JobState_JOB_CREATED

+ const JobState_JOB_EGRESSING

+ const JobState_JOB_FAILURE

+ const JobState_JOB_FINISHING

+ const JobState_JOB_KILLED

+ const JobState_JOB_RUNNING

+ const JobState_JOB_STARTING

+ const JobState_JOB_STATE_UNKNOWN

+ const JobState_JOB_SUCCESS

+ const JobState_JOB_UNRUNNABLE

+ func JobStateFromName(name string) (JobState, error)

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

+ func (x JobState) String() string

+ type ListDatumRequest struct

+ Filter *ListDatumRequest_Filter

+ Input *Input

+ Job *Job

+ Number int64

+ PaginationMarker string

+ Reverse bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListDatumRequest) ProtoMessage()

+ func (m *ListDatumRequest) GetFilter() *ListDatumRequest_Filter

+ func (m *ListDatumRequest) GetInput() *Input

+ func (m *ListDatumRequest) GetJob() *Job

+ func (m *ListDatumRequest) GetNumber() int64

+ func (m *ListDatumRequest) GetPaginationMarker() string

+ func (m *ListDatumRequest) GetReverse() bool

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

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

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

+ func (m *ListDatumRequest) Reset()

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

+ func (m *ListDatumRequest) String() string

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

+ func (m *ListDatumRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListDatumRequest) XXX_Size() int

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

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

+ type ListDatumRequest_Filter struct

+ State []DatumState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListDatumRequest_Filter) ProtoMessage()

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

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

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

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

+ func (m *ListDatumRequest_Filter) Reset()

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

+ func (m *ListDatumRequest_Filter) String() string

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

+ func (m *ListDatumRequest_Filter) XXX_DiscardUnknown()

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

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

+ func (m *ListDatumRequest_Filter) XXX_Size() int

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

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

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

+ type ListJobRequest struct

+ Details bool

+ History int64

+ InputCommit []*pfs.Commit

+ JqFilter string

+ Number int64

+ PaginationMarker *types.Timestamp

+ Pipeline *Pipeline

+ Projects []*pfs.Project

+ Reverse bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListJobRequest) ProtoMessage()

+ func (m *ListJobRequest) GetDetails() bool

+ func (m *ListJobRequest) GetHistory() int64

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

+ func (m *ListJobRequest) GetJqFilter() string

+ func (m *ListJobRequest) GetNumber() int64

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

+ func (m *ListJobRequest) GetPipeline() *Pipeline

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

+ func (m *ListJobRequest) GetReverse() bool

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

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

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

+ func (m *ListJobRequest) Reset()

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

+ func (m *ListJobRequest) String() string

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

+ func (m *ListJobRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListJobRequest) XXX_Size() int

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

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

+ type ListJobSetRequest struct

+ Details bool

+ Number int64

+ PaginationMarker *types.Timestamp

+ Projects []*pfs.Project

+ Reverse bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListJobSetRequest) ProtoMessage()

+ func (m *ListJobSetRequest) GetDetails() bool

+ func (m *ListJobSetRequest) GetNumber() int64

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

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

+ func (m *ListJobSetRequest) GetReverse() bool

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

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

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

+ func (m *ListJobSetRequest) Reset()

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

+ func (m *ListJobSetRequest) String() string

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

+ func (m *ListJobSetRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListJobSetRequest) XXX_Size() int

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

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

+ type ListPipelineRequest struct

+ CommitSet *pfs.CommitSet

+ Details bool

+ History int64

+ JqFilter string

+ Pipeline *Pipeline

+ Projects []*pfs.Project

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListPipelineRequest) ProtoMessage()

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

+ func (m *ListPipelineRequest) GetDetails() bool

+ func (m *ListPipelineRequest) GetHistory() int64

+ func (m *ListPipelineRequest) GetJqFilter() string

+ func (m *ListPipelineRequest) GetPipeline() *Pipeline

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

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

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

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

+ func (m *ListPipelineRequest) Reset()

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

+ func (m *ListPipelineRequest) String() string

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

+ func (m *ListPipelineRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListPipelineRequest) XXX_Size() int

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

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

+ type LogMessage struct

+ Data []*InputFile

+ DatumID string

+ JobID string

+ Master bool

+ Message string

+ PipelineName string

+ ProjectName string

+ Ts *types.Timestamp

+ User bool

+ WorkerID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LogMessage) ProtoMessage()

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

+ func (m *LogMessage) GetDatumID() string

+ func (m *LogMessage) GetJobID() string

+ func (m *LogMessage) GetMaster() bool

+ func (m *LogMessage) GetMessage() string

+ func (m *LogMessage) GetPipelineName() string

+ func (m *LogMessage) GetProjectName() string

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

+ func (m *LogMessage) GetUser() bool

+ func (m *LogMessage) GetWorkerID() string

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

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

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

+ func (m *LogMessage) Reset()

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

+ func (m *LogMessage) String() string

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

+ func (m *LogMessage) XXX_DiscardUnknown()

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

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

+ func (m *LogMessage) XXX_Size() int

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

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

+ type LokiLogMessage struct

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LokiLogMessage) ProtoMessage()

+ func (m *LokiLogMessage) GetMessage() string

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

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

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

+ func (m *LokiLogMessage) Reset()

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

+ func (m *LokiLogMessage) String() string

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

+ func (m *LokiLogMessage) XXX_DiscardUnknown()

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

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

+ func (m *LokiLogMessage) XXX_Size() int

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

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

+ type LokiRequest struct

+ Query string

+ Since *types.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LokiRequest) ProtoMessage()

+ func (m *LokiRequest) GetQuery() string

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

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

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

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

+ func (m *LokiRequest) Reset()

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

+ func (m *LokiRequest) String() string

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

+ func (m *LokiRequest) XXX_DiscardUnknown()

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

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

+ func (m *LokiRequest) XXX_Size() int

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

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

+ type Metadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Metadata) ProtoMessage()

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

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

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

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

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

+ func (m *Metadata) Reset()

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

+ func (m *Metadata) String() string

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

+ func (m *Metadata) XXX_DiscardUnknown()

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

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

+ func (m *Metadata) XXX_Size() int

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

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

+ type PFSInput struct

+ Branch string

+ Commit string

+ EmptyFiles bool

+ Glob string

+ GroupBy string

+ JoinOn string

+ Lazy bool

+ Name string

+ OuterJoin bool

+ Project string

+ Repo string

+ RepoType string

+ S3 bool

+ Trigger *pfs.Trigger

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PFSInput) ProtoMessage()

+ func (m *PFSInput) GetBranch() string

+ func (m *PFSInput) GetCommit() string

+ func (m *PFSInput) GetEmptyFiles() bool

+ func (m *PFSInput) GetGlob() string

+ func (m *PFSInput) GetGroupBy() string

+ func (m *PFSInput) GetJoinOn() string

+ func (m *PFSInput) GetLazy() bool

+ func (m *PFSInput) GetName() string

+ func (m *PFSInput) GetOuterJoin() bool

+ func (m *PFSInput) GetProject() string

+ func (m *PFSInput) GetRepo() string

+ func (m *PFSInput) GetRepoType() string

+ func (m *PFSInput) GetS3() bool

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

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

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

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

+ func (m *PFSInput) Reset()

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

+ func (m *PFSInput) String() string

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

+ func (m *PFSInput) XXX_DiscardUnknown()

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

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

+ func (m *PFSInput) XXX_Size() int

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

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

+ type ParallelismSpec struct

+ Constant uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ParallelismSpec) ProtoMessage()

+ func (m *ParallelismSpec) GetConstant() uint64

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

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

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

+ func (m *ParallelismSpec) Reset()

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

+ func (m *ParallelismSpec) String() string

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

+ func (m *ParallelismSpec) XXX_DiscardUnknown()

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

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

+ func (m *ParallelismSpec) XXX_Size() int

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

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

+ type Pipeline struct

+ Name string

+ Project *pfs.Project

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func RepoPipeline(r *pfs.Repo) *Pipeline

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

+ func (*Pipeline) ProtoMessage()

+ func (m *Pipeline) GetName() string

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

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

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

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

+ func (m *Pipeline) Reset()

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

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

+ func (m *Pipeline) XXX_DiscardUnknown()

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

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

+ func (m *Pipeline) XXX_Size() int

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

+ func (p *Pipeline) String() string

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

+ type PipelineInfo struct

+ AuthToken string

+ Details *PipelineInfo_Details

+ LastJobState JobState

+ Parallelism uint64

+ Pipeline *Pipeline

+ Reason string

+ SpecCommit *pfs.Commit

+ State PipelineState

+ Stopped bool

+ Type PipelineInfo_PipelineType

+ Version uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PipelineInfo) ProtoMessage()

+ func (m *PipelineInfo) GetAuthToken() string

+ func (m *PipelineInfo) GetDetails() *PipelineInfo_Details

+ func (m *PipelineInfo) GetLastJobState() JobState

+ func (m *PipelineInfo) GetParallelism() uint64

+ func (m *PipelineInfo) GetPipeline() *Pipeline

+ func (m *PipelineInfo) GetReason() string

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

+ func (m *PipelineInfo) GetState() PipelineState

+ func (m *PipelineInfo) GetStopped() bool

+ func (m *PipelineInfo) GetType() PipelineInfo_PipelineType

+ func (m *PipelineInfo) GetVersion() uint64

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

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

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

+ func (m *PipelineInfo) Reset()

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

+ func (m *PipelineInfo) String() string

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

+ func (m *PipelineInfo) XXX_DiscardUnknown()

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

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

+ func (m *PipelineInfo) XXX_Size() int

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

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

+ type PipelineInfo_Details struct

+ Autoscaling bool

+ CreatedAt *types.Timestamp

+ DatumSetSpec *DatumSetSpec

+ DatumTimeout *types.Duration

+ DatumTries int64

+ Description string

+ Egress *Egress

+ Input *Input

+ JobTimeout *types.Duration

+ Metadata *Metadata

+ OutputBranch string

+ ParallelismSpec *ParallelismSpec

+ PodPatch string

+ PodSpec string

+ Reason string

+ RecentError string

+ ReprocessSpec string

+ ResourceLimits *ResourceSpec

+ ResourceRequests *ResourceSpec

+ S3Out bool

+ Salt string

+ SchedulingSpec *SchedulingSpec

+ Service *Service

+ SidecarResourceLimits *ResourceSpec

+ SidecarResourceRequests *ResourceSpec

+ Spout *Spout

+ TFJob *TFJob

+ Tolerations []*Toleration

+ Transform *Transform

+ UnclaimedTasks int64

+ WorkerRc string

+ WorkersAvailable int64

+ WorkersRequested int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PipelineInfo_Details) ProtoMessage()

+ func (m *PipelineInfo_Details) GetAutoscaling() bool

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

+ func (m *PipelineInfo_Details) GetDatumSetSpec() *DatumSetSpec

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

+ func (m *PipelineInfo_Details) GetDatumTries() int64

+ func (m *PipelineInfo_Details) GetDescription() string

+ func (m *PipelineInfo_Details) GetEgress() *Egress

+ func (m *PipelineInfo_Details) GetInput() *Input

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

+ func (m *PipelineInfo_Details) GetMetadata() *Metadata

+ func (m *PipelineInfo_Details) GetOutputBranch() string

+ func (m *PipelineInfo_Details) GetParallelismSpec() *ParallelismSpec

+ func (m *PipelineInfo_Details) GetPodPatch() string

+ func (m *PipelineInfo_Details) GetPodSpec() string

+ func (m *PipelineInfo_Details) GetReason() string

+ func (m *PipelineInfo_Details) GetRecentError() string

+ func (m *PipelineInfo_Details) GetReprocessSpec() string

+ func (m *PipelineInfo_Details) GetResourceLimits() *ResourceSpec

+ func (m *PipelineInfo_Details) GetResourceRequests() *ResourceSpec

+ func (m *PipelineInfo_Details) GetS3Out() bool

+ func (m *PipelineInfo_Details) GetSalt() string

+ func (m *PipelineInfo_Details) GetSchedulingSpec() *SchedulingSpec

+ func (m *PipelineInfo_Details) GetService() *Service

+ func (m *PipelineInfo_Details) GetSidecarResourceLimits() *ResourceSpec

+ func (m *PipelineInfo_Details) GetSidecarResourceRequests() *ResourceSpec

+ func (m *PipelineInfo_Details) GetSpout() *Spout

+ func (m *PipelineInfo_Details) GetTFJob() *TFJob

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

+ func (m *PipelineInfo_Details) GetTransform() *Transform

+ func (m *PipelineInfo_Details) GetUnclaimedTasks() int64

+ func (m *PipelineInfo_Details) GetWorkerRc() string

+ func (m *PipelineInfo_Details) GetWorkersAvailable() int64

+ func (m *PipelineInfo_Details) GetWorkersRequested() int64

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

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

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

+ func (m *PipelineInfo_Details) Reset()

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

+ func (m *PipelineInfo_Details) String() string

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

+ func (m *PipelineInfo_Details) XXX_DiscardUnknown()

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

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

+ func (m *PipelineInfo_Details) XXX_Size() int

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

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

+ type PipelineInfo_PipelineType int32

+ const PipelineInfo_PIPELINE_TYPE_SERVICE

+ const PipelineInfo_PIPELINE_TYPE_SPOUT

+ const PipelineInfo_PIPELINE_TYPE_TRANSFORM

+ const PipelineInfo_PIPELINT_TYPE_UNKNOWN

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

+ func (x PipelineInfo_PipelineType) String() string

+ type PipelineInfos struct

+ PipelineInfo []*PipelineInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PipelineInfos) ProtoMessage()

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

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

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

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

+ func (m *PipelineInfos) Reset()

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

+ func (m *PipelineInfos) String() string

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

+ func (m *PipelineInfos) XXX_DiscardUnknown()

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

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

+ func (m *PipelineInfos) XXX_Size() int

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

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

+ type PipelineState int32

+ const PipelineState_PIPELINE_CRASHING

+ const PipelineState_PIPELINE_FAILURE

+ const PipelineState_PIPELINE_PAUSED

+ const PipelineState_PIPELINE_RESTARTING

+ const PipelineState_PIPELINE_RUNNING

+ const PipelineState_PIPELINE_STANDBY

+ const PipelineState_PIPELINE_STARTING

+ const PipelineState_PIPELINE_STATE_UNKNOWN

+ func PipelineStateFromName(name string) (PipelineState, error)

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

+ func (x PipelineState) String() string

+ type ProcessStats struct

+ DownloadBytes int64

+ DownloadTime *types.Duration

+ ProcessTime *types.Duration

+ UploadBytes int64

+ UploadTime *types.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ProcessStats) ProtoMessage()

+ func (m *ProcessStats) GetDownloadBytes() int64

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

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

+ func (m *ProcessStats) GetUploadBytes() int64

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

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

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

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

+ func (m *ProcessStats) Reset()

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

+ func (m *ProcessStats) String() string

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

+ func (m *ProcessStats) XXX_DiscardUnknown()

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

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

+ func (m *ProcessStats) XXX_Size() int

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

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

+ type RenderTemplateRequest struct

+ Args map[string]string

+ Template string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RenderTemplateRequest) ProtoMessage()

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

+ func (m *RenderTemplateRequest) GetTemplate() string

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

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

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

+ func (m *RenderTemplateRequest) Reset()

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

+ func (m *RenderTemplateRequest) String() string

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

+ func (m *RenderTemplateRequest) XXX_DiscardUnknown()

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

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

+ func (m *RenderTemplateRequest) XXX_Size() int

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

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

+ type RenderTemplateResponse struct

+ Json string

+ Specs []*CreatePipelineRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RenderTemplateResponse) ProtoMessage()

+ func (m *RenderTemplateResponse) GetJson() string

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

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

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

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

+ func (m *RenderTemplateResponse) Reset()

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

+ func (m *RenderTemplateResponse) String() string

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

+ func (m *RenderTemplateResponse) XXX_DiscardUnknown()

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

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

+ func (m *RenderTemplateResponse) XXX_Size() int

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

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

+ type ResourceSpec struct

+ Cpu float32

+ Disk string

+ Gpu *GPUSpec

+ Memory string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ResourceSpec) ProtoMessage()

+ func (m *ResourceSpec) GetCpu() float32

+ func (m *ResourceSpec) GetDisk() string

+ func (m *ResourceSpec) GetGpu() *GPUSpec

+ func (m *ResourceSpec) GetMemory() string

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

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

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

+ func (m *ResourceSpec) Reset()

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

+ func (m *ResourceSpec) String() string

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

+ func (m *ResourceSpec) XXX_DiscardUnknown()

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

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

+ func (m *ResourceSpec) XXX_Size() int

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

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

+ type RestartDatumRequest struct

+ DataFilters []string

+ Job *Job

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RestartDatumRequest) ProtoMessage()

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

+ func (m *RestartDatumRequest) GetJob() *Job

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

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

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

+ func (m *RestartDatumRequest) Reset()

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

+ func (m *RestartDatumRequest) String() string

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

+ func (m *RestartDatumRequest) XXX_DiscardUnknown()

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

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

+ func (m *RestartDatumRequest) XXX_Size() int

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

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

+ type RunCronRequest struct

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RunCronRequest) ProtoMessage()

+ func (m *RunCronRequest) GetPipeline() *Pipeline

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

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

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

+ func (m *RunCronRequest) Reset()

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

+ func (m *RunCronRequest) String() string

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

+ func (m *RunCronRequest) XXX_DiscardUnknown()

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

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

+ func (m *RunCronRequest) XXX_Size() int

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

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

+ type RunLoadTestRequest struct

+ DagSpec string

+ LoadSpec string

+ Parallelism int64

+ PodPatch string

+ Seed int64

+ StateId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RunLoadTestRequest) ProtoMessage()

+ func (m *RunLoadTestRequest) GetDagSpec() string

+ func (m *RunLoadTestRequest) GetLoadSpec() string

+ func (m *RunLoadTestRequest) GetParallelism() int64

+ func (m *RunLoadTestRequest) GetPodPatch() string

+ func (m *RunLoadTestRequest) GetSeed() int64

+ func (m *RunLoadTestRequest) GetStateId() string

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

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

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

+ func (m *RunLoadTestRequest) Reset()

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

+ func (m *RunLoadTestRequest) String() string

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

+ func (m *RunLoadTestRequest) XXX_DiscardUnknown()

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

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

+ func (m *RunLoadTestRequest) XXX_Size() int

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

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

+ type RunLoadTestResponse struct

+ Error string

+ StateId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RunLoadTestResponse) ProtoMessage()

+ func (m *RunLoadTestResponse) GetError() string

+ func (m *RunLoadTestResponse) GetStateId() string

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

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

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

+ func (m *RunLoadTestResponse) Reset()

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

+ func (m *RunLoadTestResponse) String() string

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

+ func (m *RunLoadTestResponse) XXX_DiscardUnknown()

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

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

+ func (m *RunLoadTestResponse) XXX_Size() int

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

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

+ type RunPipelineRequest struct

+ JobID string

+ Pipeline *Pipeline

+ Provenance []*pfs.Commit

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RunPipelineRequest) ProtoMessage()

+ func (m *RunPipelineRequest) GetJobID() string

+ func (m *RunPipelineRequest) GetPipeline() *Pipeline

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

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

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

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

+ func (m *RunPipelineRequest) Reset()

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

+ func (m *RunPipelineRequest) String() string

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

+ func (m *RunPipelineRequest) XXX_DiscardUnknown()

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

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

+ func (m *RunPipelineRequest) XXX_Size() int

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

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

+ type SchedulingSpec struct

+ NodeSelector map[string]string

+ PriorityClassName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SchedulingSpec) ProtoMessage()

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

+ func (m *SchedulingSpec) GetPriorityClassName() string

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

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

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

+ func (m *SchedulingSpec) Reset()

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

+ func (m *SchedulingSpec) String() string

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

+ func (m *SchedulingSpec) XXX_DiscardUnknown()

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

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

+ func (m *SchedulingSpec) XXX_Size() int

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

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

+ type Secret struct

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Secret) ProtoMessage()

+ func (m *Secret) GetName() string

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

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

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

+ func (m *Secret) Reset()

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

+ func (m *Secret) String() string

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

+ func (m *Secret) XXX_DiscardUnknown()

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

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

+ func (m *Secret) XXX_Size() int

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

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

+ type SecretInfo struct

+ CreationTimestamp *types.Timestamp

+ Secret *Secret

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SecretInfo) ProtoMessage()

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

+ func (m *SecretInfo) GetSecret() *Secret

+ func (m *SecretInfo) GetType() string

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

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

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

+ func (m *SecretInfo) Reset()

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

+ func (m *SecretInfo) String() string

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

+ func (m *SecretInfo) XXX_DiscardUnknown()

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

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

+ func (m *SecretInfo) XXX_Size() int

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

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

+ type SecretInfos struct

+ SecretInfo []*SecretInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SecretInfos) ProtoMessage()

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

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

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

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

+ func (m *SecretInfos) Reset()

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

+ func (m *SecretInfos) String() string

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

+ func (m *SecretInfos) XXX_DiscardUnknown()

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

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

+ func (m *SecretInfos) XXX_Size() int

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

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

+ type SecretMount struct

+ EnvVar string

+ Key string

+ MountPath string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SecretMount) ProtoMessage()

+ func (m *SecretMount) GetEnvVar() string

+ func (m *SecretMount) GetKey() string

+ func (m *SecretMount) GetMountPath() string

+ func (m *SecretMount) GetName() string

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

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

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

+ func (m *SecretMount) Reset()

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

+ func (m *SecretMount) String() string

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

+ func (m *SecretMount) XXX_DiscardUnknown()

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

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

+ func (m *SecretMount) XXX_Size() int

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

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

+ type Service struct

+ ExternalPort int32

+ IP string

+ InternalPort int32

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Service) ProtoMessage()

+ func (m *Service) GetExternalPort() int32

+ func (m *Service) GetIP() string

+ func (m *Service) GetInternalPort() int32

+ func (m *Service) GetType() string

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

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

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

+ func (m *Service) Reset()

+ func (m *Service) Size() (n int)

+ func (m *Service) String() string

+ func (m *Service) Unmarshal(dAtA []byte) error

+ func (m *Service) XXX_DiscardUnknown()

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

+ func (m *Service) XXX_Merge(src proto.Message)

+ func (m *Service) XXX_Size() int

+ func (m *Service) XXX_Unmarshal(b []byte) error

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

+ type Spout struct

+ Service *Service

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Spout) Descriptor() ([]byte, []int)

+ func (*Spout) ProtoMessage()

+ func (m *Spout) GetService() *Service

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

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

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

+ func (m *Spout) Reset()

+ func (m *Spout) Size() (n int)

+ func (m *Spout) String() string

+ func (m *Spout) Unmarshal(dAtA []byte) error

+ func (m *Spout) XXX_DiscardUnknown()

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

+ func (m *Spout) XXX_Merge(src proto.Message)

+ func (m *Spout) XXX_Size() int

+ func (m *Spout) XXX_Unmarshal(b []byte) error

+ func (x *Spout) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type StartPipelineRequest struct

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StartPipelineRequest) Descriptor() ([]byte, []int)

+ func (*StartPipelineRequest) ProtoMessage()

+ func (m *StartPipelineRequest) GetPipeline() *Pipeline

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

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

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

+ func (m *StartPipelineRequest) Reset()

+ func (m *StartPipelineRequest) Size() (n int)

+ func (m *StartPipelineRequest) String() string

+ func (m *StartPipelineRequest) Unmarshal(dAtA []byte) error

+ func (m *StartPipelineRequest) XXX_DiscardUnknown()

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

+ func (m *StartPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *StartPipelineRequest) XXX_Size() int

+ func (m *StartPipelineRequest) XXX_Unmarshal(b []byte) error

+ func (x *StartPipelineRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type StopJobRequest struct

+ Job *Job

+ Reason string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StopJobRequest) Descriptor() ([]byte, []int)

+ func (*StopJobRequest) ProtoMessage()

+ func (m *StopJobRequest) GetJob() *Job

+ func (m *StopJobRequest) GetReason() string

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

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

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

+ func (m *StopJobRequest) Reset()

+ func (m *StopJobRequest) Size() (n int)

+ func (m *StopJobRequest) String() string

+ func (m *StopJobRequest) Unmarshal(dAtA []byte) error

+ func (m *StopJobRequest) XXX_DiscardUnknown()

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

+ func (m *StopJobRequest) XXX_Merge(src proto.Message)

+ func (m *StopJobRequest) XXX_Size() int

+ func (m *StopJobRequest) XXX_Unmarshal(b []byte) error

+ func (x *StopJobRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type StopPipelineRequest struct

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StopPipelineRequest) Descriptor() ([]byte, []int)

+ func (*StopPipelineRequest) ProtoMessage()

+ func (m *StopPipelineRequest) GetPipeline() *Pipeline

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

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

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

+ func (m *StopPipelineRequest) Reset()

+ func (m *StopPipelineRequest) Size() (n int)

+ func (m *StopPipelineRequest) String() string

+ func (m *StopPipelineRequest) Unmarshal(dAtA []byte) error

+ func (m *StopPipelineRequest) XXX_DiscardUnknown()

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

+ func (m *StopPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *StopPipelineRequest) XXX_Size() int

+ func (m *StopPipelineRequest) XXX_Unmarshal(b []byte) error

+ func (x *StopPipelineRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type SubscribeJobRequest struct

+ Details bool

+ Pipeline *Pipeline

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SubscribeJobRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeJobRequest) ProtoMessage()

+ func (m *SubscribeJobRequest) GetDetails() bool

+ func (m *SubscribeJobRequest) GetPipeline() *Pipeline

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

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

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

+ func (m *SubscribeJobRequest) Reset()

+ func (m *SubscribeJobRequest) Size() (n int)

+ func (m *SubscribeJobRequest) String() string

+ func (m *SubscribeJobRequest) Unmarshal(dAtA []byte) error

+ func (m *SubscribeJobRequest) XXX_DiscardUnknown()

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

+ func (m *SubscribeJobRequest) XXX_Merge(src proto.Message)

+ func (m *SubscribeJobRequest) XXX_Size() int

+ func (m *SubscribeJobRequest) XXX_Unmarshal(b []byte) error

+ func (x *SubscribeJobRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type TFJob struct

+ TFJob string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TFJob) Descriptor() ([]byte, []int)

+ func (*TFJob) ProtoMessage()

+ func (m *TFJob) GetTFJob() string

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

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

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

+ func (m *TFJob) Reset()

+ func (m *TFJob) Size() (n int)

+ func (m *TFJob) String() string

+ func (m *TFJob) Unmarshal(dAtA []byte) error

+ func (m *TFJob) XXX_DiscardUnknown()

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

+ func (m *TFJob) XXX_Merge(src proto.Message)

+ func (m *TFJob) XXX_Size() int

+ func (m *TFJob) XXX_Unmarshal(b []byte) error

+ func (x *TFJob) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type TaintEffect int32

+ const TaintEffect_ALL_EFFECTS

+ const TaintEffect_NO_EXECUTE

+ const TaintEffect_NO_SCHEDULE

+ const TaintEffect_PREFER_NO_SCHEDULE

+ func (TaintEffect) EnumDescriptor() ([]byte, []int)

+ func (x TaintEffect) String() string

+ type Toleration struct

+ Effect TaintEffect

+ Key string

+ Operator TolerationOperator

+ TolerationSeconds *types.Int64Value

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Toleration) Descriptor() ([]byte, []int)

+ func (*Toleration) ProtoMessage()

+ func (m *Toleration) GetEffect() TaintEffect

+ func (m *Toleration) GetKey() string

+ func (m *Toleration) GetOperator() TolerationOperator

+ func (m *Toleration) GetTolerationSeconds() *types.Int64Value

+ func (m *Toleration) GetValue() string

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

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

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

+ func (m *Toleration) Reset()

+ func (m *Toleration) Size() (n int)

+ func (m *Toleration) String() string

+ func (m *Toleration) Unmarshal(dAtA []byte) error

+ func (m *Toleration) XXX_DiscardUnknown()

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

+ func (m *Toleration) XXX_Merge(src proto.Message)

+ func (m *Toleration) XXX_Size() int

+ func (m *Toleration) XXX_Unmarshal(b []byte) error

+ func (x *Toleration) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type TolerationOperator int32

+ const TolerationOperator_EMPTY

+ const TolerationOperator_EQUAL

+ const TolerationOperator_EXISTS

+ func (TolerationOperator) EnumDescriptor() ([]byte, []int)

+ func (x TolerationOperator) String() string

+ type Transform struct

+ AcceptReturnCode []int64

+ Cmd []string

+ DatumBatching bool

+ Debug bool

+ Dockerfile string

+ Env map[string]string

+ ErrCmd []string

+ ErrStdin []string

+ Image string

+ ImagePullSecrets []string

+ MemoryVolume bool

+ Secrets []*SecretMount

+ Stdin []string

+ User string

+ WorkingDir string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Transform) Descriptor() ([]byte, []int)

+ func (*Transform) ProtoMessage()

+ func (m *Transform) GetAcceptReturnCode() []int64

+ func (m *Transform) GetCmd() []string

+ func (m *Transform) GetDatumBatching() bool

+ func (m *Transform) GetDebug() bool

+ func (m *Transform) GetDockerfile() string

+ func (m *Transform) GetEnv() map[string]string

+ func (m *Transform) GetErrCmd() []string

+ func (m *Transform) GetErrStdin() []string

+ func (m *Transform) GetImage() string

+ func (m *Transform) GetImagePullSecrets() []string

+ func (m *Transform) GetMemoryVolume() bool

+ func (m *Transform) GetSecrets() []*SecretMount

+ func (m *Transform) GetStdin() []string

+ func (m *Transform) GetUser() string

+ func (m *Transform) GetWorkingDir() string

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

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

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

+ func (m *Transform) Reset()

+ func (m *Transform) Size() (n int)

+ func (m *Transform) String() string

+ func (m *Transform) Unmarshal(dAtA []byte) error

+ func (m *Transform) XXX_DiscardUnknown()

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

+ func (m *Transform) XXX_Merge(src proto.Message)

+ func (m *Transform) XXX_Size() int

+ func (m *Transform) XXX_Unmarshal(b []byte) error

+ func (x *Transform) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type UnimplementedAPIServer struct

+ func (*UnimplementedAPIServer) ActivateAuth(ctx context.Context, req *ActivateAuthRequest) (*ActivateAuthResponse, error)

+ func (*UnimplementedAPIServer) CreatePipeline(ctx context.Context, req *CreatePipelineRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) CreateSecret(ctx context.Context, req *CreateSecretRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) DeleteAll(ctx context.Context, req *types.Empty) (*types.Empty, error)

+ func (*UnimplementedAPIServer) DeleteJob(ctx context.Context, req *DeleteJobRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) DeletePipeline(ctx context.Context, req *DeletePipelineRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) DeletePipelines(ctx context.Context, req *DeletePipelinesRequest) (*DeletePipelinesResponse, error)

+ func (*UnimplementedAPIServer) DeleteSecret(ctx context.Context, req *DeleteSecretRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) GetKubeEvents(req *LokiRequest, srv API_GetKubeEventsServer) error

+ func (*UnimplementedAPIServer) GetLogs(req *GetLogsRequest, srv API_GetLogsServer) error

+ func (*UnimplementedAPIServer) InspectDatum(ctx context.Context, req *InspectDatumRequest) (*DatumInfo, error)

+ func (*UnimplementedAPIServer) InspectJob(ctx context.Context, req *InspectJobRequest) (*JobInfo, error)

+ func (*UnimplementedAPIServer) InspectJobSet(req *InspectJobSetRequest, srv API_InspectJobSetServer) error

+ func (*UnimplementedAPIServer) InspectPipeline(ctx context.Context, req *InspectPipelineRequest) (*PipelineInfo, error)

+ func (*UnimplementedAPIServer) InspectSecret(ctx context.Context, req *InspectSecretRequest) (*SecretInfo, error)

+ func (*UnimplementedAPIServer) ListDatum(req *ListDatumRequest, srv API_ListDatumServer) error

+ func (*UnimplementedAPIServer) ListJob(req *ListJobRequest, srv API_ListJobServer) error

+ func (*UnimplementedAPIServer) ListJobSet(req *ListJobSetRequest, srv API_ListJobSetServer) error

+ func (*UnimplementedAPIServer) ListPipeline(req *ListPipelineRequest, srv API_ListPipelineServer) error

+ func (*UnimplementedAPIServer) ListSecret(ctx context.Context, req *types.Empty) (*SecretInfos, error)

+ func (*UnimplementedAPIServer) ListTask(req *task.ListTaskRequest, srv API_ListTaskServer) error

+ func (*UnimplementedAPIServer) QueryLoki(req *LokiRequest, srv API_QueryLokiServer) error

+ func (*UnimplementedAPIServer) RenderTemplate(ctx context.Context, req *RenderTemplateRequest) (*RenderTemplateResponse, error)

+ func (*UnimplementedAPIServer) RestartDatum(ctx context.Context, req *RestartDatumRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) RunCron(ctx context.Context, req *RunCronRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) RunLoadTest(ctx context.Context, req *RunLoadTestRequest) (*RunLoadTestResponse, error)

+ func (*UnimplementedAPIServer) RunLoadTestDefault(ctx context.Context, req *types.Empty) (*RunLoadTestResponse, error)

+ func (*UnimplementedAPIServer) RunPipeline(ctx context.Context, req *RunPipelineRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) StartPipeline(ctx context.Context, req *StartPipelineRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) StopJob(ctx context.Context, req *StopJobRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) StopPipeline(ctx context.Context, req *StopPipelineRequest) (*types.Empty, error)

+ func (*UnimplementedAPIServer) SubscribeJob(req *SubscribeJobRequest, srv API_SubscribeJobServer) error

+ func (*UnimplementedAPIServer) UpdateJobState(ctx context.Context, req *UpdateJobStateRequest) (*types.Empty, error)

+ type UpdateJobStateRequest struct

+ DataFailed int64

+ DataProcessed int64

+ DataRecovered int64

+ DataSkipped int64

+ DataTotal int64

+ Job *Job

+ Reason string

+ Restart uint64

+ State JobState

+ Stats *ProcessStats

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpdateJobStateRequest) Descriptor() ([]byte, []int)

+ func (*UpdateJobStateRequest) ProtoMessage()

+ func (m *UpdateJobStateRequest) GetDataFailed() int64

+ func (m *UpdateJobStateRequest) GetDataProcessed() int64

+ func (m *UpdateJobStateRequest) GetDataRecovered() int64

+ func (m *UpdateJobStateRequest) GetDataSkipped() int64

+ func (m *UpdateJobStateRequest) GetDataTotal() int64

+ func (m *UpdateJobStateRequest) GetJob() *Job

+ func (m *UpdateJobStateRequest) GetReason() string

+ func (m *UpdateJobStateRequest) GetRestart() uint64

+ func (m *UpdateJobStateRequest) GetState() JobState

+ func (m *UpdateJobStateRequest) GetStats() *ProcessStats

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

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

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

+ func (m *UpdateJobStateRequest) Reset()

+ func (m *UpdateJobStateRequest) Size() (n int)

+ func (m *UpdateJobStateRequest) String() string

+ func (m *UpdateJobStateRequest) Unmarshal(dAtA []byte) error

+ func (m *UpdateJobStateRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateJobStateRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateJobStateRequest) XXX_Size() int

+ func (m *UpdateJobStateRequest) XXX_Unmarshal(b []byte) error

+ func (x *UpdateJobStateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type Worker struct

+ Name string

+ State WorkerState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Worker) Descriptor() ([]byte, []int)

+ func (*Worker) ProtoMessage()

+ func (m *Worker) GetName() string

+ func (m *Worker) GetState() WorkerState

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

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

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

+ func (m *Worker) Reset()

+ func (m *Worker) Size() (n int)

+ func (m *Worker) String() string

+ func (m *Worker) Unmarshal(dAtA []byte) error

+ func (m *Worker) XXX_DiscardUnknown()

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

+ func (m *Worker) XXX_Merge(src proto.Message)

+ func (m *Worker) XXX_Size() int

+ func (m *Worker) XXX_Unmarshal(b []byte) error

+ func (x *Worker) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type WorkerState int32

+ const WorkerState_POD_FAILED

+ const WorkerState_POD_RUNNING

+ const WorkerState_POD_SUCCESS

+ const WorkerState_WORKER_STATE_UNKNOWN

+ func (WorkerState) EnumDescriptor() ([]byte, []int)

+ func (x WorkerState) String() string

+ type WorkerStatus struct

+ DatumStatus *DatumStatus

+ JobID string

+ WorkerID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkerStatus) Descriptor() ([]byte, []int)

+ func (*WorkerStatus) ProtoMessage()

+ func (m *WorkerStatus) GetDatumStatus() *DatumStatus

+ func (m *WorkerStatus) GetJobID() string

+ func (m *WorkerStatus) GetWorkerID() string

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

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

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

+ func (m *WorkerStatus) Reset()

+ func (m *WorkerStatus) Size() (n int)

+ func (m *WorkerStatus) String() string

+ func (m *WorkerStatus) Unmarshal(dAtA []byte) error

+ func (m *WorkerStatus) XXX_DiscardUnknown()

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

+ func (m *WorkerStatus) XXX_Merge(src proto.Message)

+ func (m *WorkerStatus) XXX_Size() int

+ func (m *WorkerStatus) XXX_Unmarshal(b []byte) error

+ func (x *WorkerStatus) MarshalLogObject(enc zapcore.ObjectEncoder) error