go_client

package
v1.7.0-alpha.3 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2021 License: Apache-2.0 Imports: 19 Imported by: 1

Documentation

Overview

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package go_client is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	AuthorizeRequest_Resources_name = map[int32]string{
		0: "UNASSIGNED_RESOURCES",
		1: "VIEWERS",
	}
	AuthorizeRequest_Resources_value = map[string]int32{
		"UNASSIGNED_RESOURCES": 0,
		"VIEWERS":              1,
	}
)

Enum value maps for AuthorizeRequest_Resources.

View Source 
var (
	AuthorizeRequest_Verb_name = map[int32]string{
		0: "UNASSIGNED_VERB",
		1: "CREATE",
		2: "GET",
		3: "DELETE",
	}
	AuthorizeRequest_Verb_value = map[string]int32{
		"UNASSIGNED_VERB": 0,
		"CREATE":          1,
		"GET":             2,
		"DELETE":          3,
	}
)

Enum value maps for AuthorizeRequest_Verb.

View Source 
var (
	Experiment_StorageState_name = map[int32]string{
		0: "STORAGESTATE_UNSPECIFIED",
		1: "STORAGESTATE_AVAILABLE",
		2: "STORAGESTATE_ARCHIVED",
	}
	Experiment_StorageState_value = map[string]int32{
		"STORAGESTATE_UNSPECIFIED": 0,
		"STORAGESTATE_AVAILABLE":   1,
		"STORAGESTATE_ARCHIVED":    2,
	}
)

Enum value maps for Experiment_StorageState.

View Source 
var (
	Predicate_Op_name = map[int32]string{
		0: "UNKNOWN",
		1: "EQUALS",
		2: "NOT_EQUALS",
		3: "GREATER_THAN",
		5: "GREATER_THAN_EQUALS",
		6: "LESS_THAN",
		7: "LESS_THAN_EQUALS",
		8: "IN",
		9: "IS_SUBSTRING",
	}
	Predicate_Op_value = map[string]int32{
		"UNKNOWN":             0,
		"EQUALS":              1,
		"NOT_EQUALS":          2,
		"GREATER_THAN":        3,
		"GREATER_THAN_EQUALS": 5,
		"LESS_THAN":           6,
		"LESS_THAN_EQUALS":    7,
		"IN":                  8,
		"IS_SUBSTRING":        9,
	}
)

Enum value maps for Predicate_Op.

View Source 
var (
	Job_Mode_name = map[int32]string{
		0: "UNKNOWN_MODE",
		1: "ENABLED",
		2: "DISABLED",
	}
	Job_Mode_value = map[string]int32{
		"UNKNOWN_MODE": 0,
		"ENABLED":      1,
		"DISABLED":     2,
	}
)

Enum value maps for Job_Mode.

View Source 
var (
	ResourceType_name = map[int32]string{
		0: "UNKNOWN_RESOURCE_TYPE",
		1: "EXPERIMENT",
		2: "JOB",
		3: "PIPELINE",
		4: "PIPELINE_VERSION",
		5: "NAMESPACE",
	}
	ResourceType_value = map[string]int32{
		"UNKNOWN_RESOURCE_TYPE": 0,
		"EXPERIMENT":            1,
		"JOB":                   2,
		"PIPELINE":              3,
		"PIPELINE_VERSION":      4,
		"NAMESPACE":             5,
	}
)

Enum value maps for ResourceType.

View Source 
var (
	Relationship_name = map[int32]string{
		0: "UNKNOWN_RELATIONSHIP",
		1: "OWNER",
		2: "CREATOR",
	}
	Relationship_value = map[string]int32{
		"UNKNOWN_RELATIONSHIP": 0,
		"OWNER":                1,
		"CREATOR":              2,
	}
)

Enum value maps for Relationship.

View Source 
var (
	Run_StorageState_name = map[int32]string{
		0: "STORAGESTATE_AVAILABLE",
		1: "STORAGESTATE_ARCHIVED",
	}
	Run_StorageState_value = map[string]int32{
		"STORAGESTATE_AVAILABLE": 0,
		"STORAGESTATE_ARCHIVED":  1,
	}
)

Enum value maps for Run_StorageState.

View Source 
var (
	RunMetric_Format_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "RAW",
		2: "PERCENTAGE",
	}
	RunMetric_Format_value = map[string]int32{
		"UNSPECIFIED": 0,
		"RAW":         1,
		"PERCENTAGE":  2,
	}
)

Enum value maps for RunMetric_Format.

View Source 
var (
	ReportRunMetricsResponse_ReportRunMetricResult_Status_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "OK",
		2: "INVALID_ARGUMENT",
		3: "DUPLICATE_REPORTING",
		4: "INTERNAL_ERROR",
	}
	ReportRunMetricsResponse_ReportRunMetricResult_Status_value = map[string]int32{
		"UNSPECIFIED":         0,
		"OK":                  1,
		"INVALID_ARGUMENT":    2,
		"DUPLICATE_REPORTING": 3,
		"INTERNAL_ERROR":      4,
	}
)

Enum value maps for ReportRunMetricsResponse_ReportRunMetricResult_Status.

View Source 
var (
	Visualization_Type_name = map[int32]string{
		0: "ROC_CURVE",
		1: "TFDV",
		2: "TFMA",
		3: "TABLE",
		4: "CUSTOM",
	}
	Visualization_Type_value = map[string]int32{
		"ROC_CURVE": 0,
		"TFDV":      1,
		"TFMA":      2,
		"TABLE":     3,
		"CUSTOM":    4,
	}
)

Enum value maps for Visualization_Type.

View Source 
var File_backend_api_auth_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_error_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_experiment_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_filter_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_healthz_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_job_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_parameter_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_pipeline_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_pipeline_spec_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_report_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_resource_reference_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_run_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_task_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_visualization_proto protoreflect.FileDescriptor

Functions

func RegisterAuthServiceHandler 

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

RegisterAuthServiceHandler registers the http handlers for service AuthService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAuthServiceHandlerClient 

func RegisterAuthServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AuthServiceClient) error

RegisterAuthServiceHandlerClient registers the http handlers for service AuthService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AuthServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AuthServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AuthServiceClient" to call the correct interceptors.

func RegisterAuthServiceHandlerFromEndpoint 

func RegisterAuthServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAuthServiceHandlerFromEndpoint is same as RegisterAuthServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAuthServiceServer 

func RegisterAuthServiceServer(s *grpc.Server, srv AuthServiceServer)

func RegisterDummyFilterServiceServer 

func RegisterDummyFilterServiceServer(s *grpc.Server, srv DummyFilterServiceServer)

func RegisterExperimentServiceHandler 

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

RegisterExperimentServiceHandler registers the http handlers for service ExperimentService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterExperimentServiceHandlerClient 

func RegisterExperimentServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ExperimentServiceClient) error

RegisterExperimentServiceHandlerClient registers the http handlers for service ExperimentService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ExperimentServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ExperimentServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ExperimentServiceClient" to call the correct interceptors.

func RegisterExperimentServiceHandlerFromEndpoint 

func RegisterExperimentServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterExperimentServiceHandlerFromEndpoint is same as RegisterExperimentServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterExperimentServiceServer 

func RegisterExperimentServiceServer(s *grpc.Server, srv ExperimentServiceServer)

func RegisterHealthzServiceHandler 

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

RegisterHealthzServiceHandler registers the http handlers for service HealthzService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterHealthzServiceHandlerClient 

func RegisterHealthzServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client HealthzServiceClient) error

RegisterHealthzServiceHandlerClient registers the http handlers for service HealthzService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "HealthzServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "HealthzServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "HealthzServiceClient" to call the correct interceptors.

func RegisterHealthzServiceHandlerFromEndpoint 

func RegisterHealthzServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterHealthzServiceHandlerFromEndpoint is same as RegisterHealthzServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterHealthzServiceServer 

func RegisterHealthzServiceServer(s *grpc.Server, srv HealthzServiceServer)

func RegisterJobServiceHandler 

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

RegisterJobServiceHandler registers the http handlers for service JobService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterJobServiceHandlerClient 

func RegisterJobServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobServiceClient) error

RegisterJobServiceHandlerClient registers the http handlers for service JobService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "JobServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "JobServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "JobServiceClient" to call the correct interceptors.

func RegisterJobServiceHandlerFromEndpoint 

func RegisterJobServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterJobServiceHandlerFromEndpoint is same as RegisterJobServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterJobServiceServer 

func RegisterJobServiceServer(s *grpc.Server, srv JobServiceServer)

func RegisterPipelineServiceHandler 

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

RegisterPipelineServiceHandler registers the http handlers for service PipelineService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPipelineServiceHandlerClient 

func RegisterPipelineServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PipelineServiceClient) error

RegisterPipelineServiceHandlerClient registers the http handlers for service PipelineService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PipelineServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PipelineServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PipelineServiceClient" to call the correct interceptors.

func RegisterPipelineServiceHandlerFromEndpoint 

func RegisterPipelineServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPipelineServiceHandlerFromEndpoint is same as RegisterPipelineServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPipelineServiceServer 

func RegisterPipelineServiceServer(s *grpc.Server, srv PipelineServiceServer)

func RegisterReportServiceHandler 

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

RegisterReportServiceHandler registers the http handlers for service ReportService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterReportServiceHandlerClient 

func RegisterReportServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ReportServiceClient) error

RegisterReportServiceHandlerClient registers the http handlers for service ReportService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ReportServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ReportServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ReportServiceClient" to call the correct interceptors.

func RegisterReportServiceHandlerFromEndpoint 

func RegisterReportServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterReportServiceHandlerFromEndpoint is same as RegisterReportServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterReportServiceServer 

func RegisterReportServiceServer(s *grpc.Server, srv ReportServiceServer)

func RegisterRunServiceHandler 

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

RegisterRunServiceHandler registers the http handlers for service RunService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRunServiceHandlerClient 

func RegisterRunServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RunServiceClient) error

RegisterRunServiceHandlerClient registers the http handlers for service RunService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RunServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RunServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RunServiceClient" to call the correct interceptors.

func RegisterRunServiceHandlerFromEndpoint 

func RegisterRunServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRunServiceHandlerFromEndpoint is same as RegisterRunServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRunServiceServer 

func RegisterRunServiceServer(s *grpc.Server, srv RunServiceServer)

func RegisterTaskServiceHandler 

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

RegisterTaskServiceHandler registers the http handlers for service TaskService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterTaskServiceHandlerClient 

func RegisterTaskServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TaskServiceClient) error

RegisterTaskServiceHandlerClient registers the http handlers for service TaskService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TaskServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TaskServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "TaskServiceClient" to call the correct interceptors.

func RegisterTaskServiceHandlerFromEndpoint 

func RegisterTaskServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterTaskServiceHandlerFromEndpoint is same as RegisterTaskServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterTaskServiceServer 

func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)

func RegisterVisualizationServiceHandler 

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

RegisterVisualizationServiceHandler registers the http handlers for service VisualizationService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterVisualizationServiceHandlerClient 

func RegisterVisualizationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client VisualizationServiceClient) error

RegisterVisualizationServiceHandlerClient registers the http handlers for service VisualizationService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "VisualizationServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "VisualizationServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "VisualizationServiceClient" to call the correct interceptors.

func RegisterVisualizationServiceHandlerFromEndpoint 

func RegisterVisualizationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterVisualizationServiceHandlerFromEndpoint is same as RegisterVisualizationServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterVisualizationServiceServer 

func RegisterVisualizationServiceServer(s *grpc.Server, srv VisualizationServiceServer)

Types

type ArchiveExperimentRequest 

type ArchiveExperimentRequest struct {

	// The ID of the experiment to be archived.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ArchiveExperimentRequest) Descriptor deprecated 

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

Deprecated: Use ArchiveExperimentRequest.ProtoReflect.Descriptor instead.

func (*ArchiveExperimentRequest) GetId 

func (x *ArchiveExperimentRequest) GetId() string

func (*ArchiveExperimentRequest) ProtoMessage 

func (*ArchiveExperimentRequest) ProtoMessage()

func (*ArchiveExperimentRequest) ProtoReflect 

func (x *ArchiveExperimentRequest) ProtoReflect() protoreflect.Message

func (*ArchiveExperimentRequest) Reset 

func (x *ArchiveExperimentRequest) Reset()

func (*ArchiveExperimentRequest) String 

func (x *ArchiveExperimentRequest) String() string

type ArchiveRunRequest 

type ArchiveRunRequest struct {

	// The ID of the run to be archived.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ArchiveRunRequest) Descriptor deprecated 

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

Deprecated: Use ArchiveRunRequest.ProtoReflect.Descriptor instead.

func (*ArchiveRunRequest) GetId 

func (x *ArchiveRunRequest) GetId() string

func (*ArchiveRunRequest) ProtoMessage 

func (*ArchiveRunRequest) ProtoMessage()

func (*ArchiveRunRequest) ProtoReflect 

func (x *ArchiveRunRequest) ProtoReflect() protoreflect.Message

func (*ArchiveRunRequest) Reset 

func (x *ArchiveRunRequest) Reset()

func (*ArchiveRunRequest) String 

func (x *ArchiveRunRequest) String() string

type AuthServiceClient 

type AuthServiceClient interface {
	Authorize(ctx context.Context, in *AuthorizeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

AuthServiceClient is the client API for AuthService service.

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

func NewAuthServiceClient 

func NewAuthServiceClient(cc grpc.ClientConnInterface) AuthServiceClient

type AuthServiceServer 

type AuthServiceServer interface {
	Authorize(context.Context, *AuthorizeRequest) (*emptypb.Empty, error)
}

AuthServiceServer is the server API for AuthService service.

type AuthorizeRequest 

type AuthorizeRequest struct {
	Namespace string                     `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`                                      // Namespace the resource belongs to.
	Resources AuthorizeRequest_Resources `protobuf:"varint,2,opt,name=resources,proto3,enum=api.AuthorizeRequest_Resources" json:"resources,omitempty"` // Resource type asking for authorization.
	Verb      AuthorizeRequest_Verb      `protobuf:"varint,3,opt,name=verb,proto3,enum=api.AuthorizeRequest_Verb" json:"verb,omitempty"`                // Verb on the resource asking for authorization.
	// contains filtered or unexported fields
}

Ask for authorization of an access by providing resource's namespace, type and verb. User identity is not part of the message, because it is expected to be parsed from request headers. Caller should proxy user request's headers.

func (*AuthorizeRequest) Descriptor deprecated 

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

Deprecated: Use AuthorizeRequest.ProtoReflect.Descriptor instead.

func (*AuthorizeRequest) GetNamespace 

func (x *AuthorizeRequest) GetNamespace() string

func (*AuthorizeRequest) GetResources 

func (x *AuthorizeRequest) GetResources() AuthorizeRequest_Resources

func (*AuthorizeRequest) GetVerb 

func (x *AuthorizeRequest) GetVerb() AuthorizeRequest_Verb

func (*AuthorizeRequest) ProtoMessage 

func (*AuthorizeRequest) ProtoMessage()

func (*AuthorizeRequest) ProtoReflect 

func (x *AuthorizeRequest) ProtoReflect() protoreflect.Message

func (*AuthorizeRequest) Reset 

func (x *AuthorizeRequest) Reset()

func (*AuthorizeRequest) String 

func (x *AuthorizeRequest) String() string

type AuthorizeRequest_Resources 

type AuthorizeRequest_Resources int32

Type of resources in pipelines system. 

const (
	AuthorizeRequest_UNASSIGNED_RESOURCES AuthorizeRequest_Resources = 0
	AuthorizeRequest_VIEWERS              AuthorizeRequest_Resources = 1
)

func (AuthorizeRequest_Resources) Descriptor 

func (AuthorizeRequest_Resources) Descriptor() protoreflect.EnumDescriptor

func (AuthorizeRequest_Resources) Enum 

func (x AuthorizeRequest_Resources) Enum() *AuthorizeRequest_Resources

func (AuthorizeRequest_Resources) EnumDescriptor deprecated 

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

Deprecated: Use AuthorizeRequest_Resources.Descriptor instead.

func (AuthorizeRequest_Resources) Number 

func (x AuthorizeRequest_Resources) Number() protoreflect.EnumNumber

func (AuthorizeRequest_Resources) String 

func (x AuthorizeRequest_Resources) String() string

func (AuthorizeRequest_Resources) Type 

func (AuthorizeRequest_Resources) Type() protoreflect.EnumType

type AuthorizeRequest_Verb 

type AuthorizeRequest_Verb int32

Type of verbs that act on the resources. 

const (
	AuthorizeRequest_UNASSIGNED_VERB AuthorizeRequest_Verb = 0
	AuthorizeRequest_CREATE          AuthorizeRequest_Verb = 1
	AuthorizeRequest_GET             AuthorizeRequest_Verb = 2
	AuthorizeRequest_DELETE          AuthorizeRequest_Verb = 3
)

func (AuthorizeRequest_Verb) Descriptor 

func (AuthorizeRequest_Verb) Descriptor() protoreflect.EnumDescriptor

func (AuthorizeRequest_Verb) Enum 

func (x AuthorizeRequest_Verb) Enum() *AuthorizeRequest_Verb

func (AuthorizeRequest_Verb) EnumDescriptor deprecated 

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

Deprecated: Use AuthorizeRequest_Verb.Descriptor instead.

func (AuthorizeRequest_Verb) Number 

func (x AuthorizeRequest_Verb) Number() protoreflect.EnumNumber

func (AuthorizeRequest_Verb) String 

func (x AuthorizeRequest_Verb) String() string

func (AuthorizeRequest_Verb) Type 

func (AuthorizeRequest_Verb) Type() protoreflect.EnumType

type CreateExperimentRequest 

type CreateExperimentRequest struct {

	// The experiment to be created.
	Experiment *Experiment `protobuf:"bytes,1,opt,name=experiment,proto3" json:"experiment,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateExperimentRequest) Descriptor deprecated 

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

Deprecated: Use CreateExperimentRequest.ProtoReflect.Descriptor instead.

func (*CreateExperimentRequest) GetExperiment 

func (x *CreateExperimentRequest) GetExperiment() *Experiment

func (*CreateExperimentRequest) ProtoMessage 

func (*CreateExperimentRequest) ProtoMessage()

func (*CreateExperimentRequest) ProtoReflect 

func (x *CreateExperimentRequest) ProtoReflect() protoreflect.Message

func (*CreateExperimentRequest) Reset 

func (x *CreateExperimentRequest) Reset()

func (*CreateExperimentRequest) String 

func (x *CreateExperimentRequest) String() string

type CreateJobRequest 

type CreateJobRequest struct {

	// The job to be created
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateJobRequest) Descriptor deprecated 

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

Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.

func (*CreateJobRequest) GetJob 

func (x *CreateJobRequest) GetJob() *Job

func (*CreateJobRequest) ProtoMessage 

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) ProtoReflect 

func (x *CreateJobRequest) ProtoReflect() protoreflect.Message

func (*CreateJobRequest) Reset 

func (x *CreateJobRequest) Reset()

func (*CreateJobRequest) String 

func (x *CreateJobRequest) String() string

type CreatePipelineRequest 

type CreatePipelineRequest struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

Create pipeline by providing an URL pointing to the pipeline file, and optionally a pipeline name. If name is not provided, file name is used as pipeline name by default. Maximum size of 32MB is supported.

func (*CreatePipelineRequest) Descriptor deprecated 

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

Deprecated: Use CreatePipelineRequest.ProtoReflect.Descriptor instead.

func (*CreatePipelineRequest) GetPipeline 

func (x *CreatePipelineRequest) GetPipeline() *Pipeline

func (*CreatePipelineRequest) ProtoMessage 

func (*CreatePipelineRequest) ProtoMessage()

func (*CreatePipelineRequest) ProtoReflect 

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

func (*CreatePipelineRequest) Reset 

func (x *CreatePipelineRequest) Reset()

func (*CreatePipelineRequest) String 

func (x *CreatePipelineRequest) String() string

type CreatePipelineVersionRequest 

type CreatePipelineVersionRequest struct {

	// ResourceReference inside PipelineVersion specifies the pipeline that this
	// version belongs to.
	Version *PipelineVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePipelineVersionRequest) Descriptor deprecated 

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

Deprecated: Use CreatePipelineVersionRequest.ProtoReflect.Descriptor instead.

func (*CreatePipelineVersionRequest) GetVersion 

func (x *CreatePipelineVersionRequest) GetVersion() *PipelineVersion

func (*CreatePipelineVersionRequest) ProtoMessage 

func (*CreatePipelineVersionRequest) ProtoMessage()

func (*CreatePipelineVersionRequest) ProtoReflect 

func (x *CreatePipelineVersionRequest) ProtoReflect() protoreflect.Message

func (*CreatePipelineVersionRequest) Reset 

func (x *CreatePipelineVersionRequest) Reset()

func (*CreatePipelineVersionRequest) String 

func (x *CreatePipelineVersionRequest) String() string

type CreateRunRequest 

type CreateRunRequest struct {
	Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRunRequest) Descriptor deprecated 

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

Deprecated: Use CreateRunRequest.ProtoReflect.Descriptor instead.

func (*CreateRunRequest) GetRun 

func (x *CreateRunRequest) GetRun() *Run

func (*CreateRunRequest) ProtoMessage 

func (*CreateRunRequest) ProtoMessage()

func (*CreateRunRequest) ProtoReflect 

func (x *CreateRunRequest) ProtoReflect() protoreflect.Message

func (*CreateRunRequest) Reset 

func (x *CreateRunRequest) Reset()

func (*CreateRunRequest) String 

func (x *CreateRunRequest) String() string

type CreateTaskRequest 

type CreateTaskRequest struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTaskRequest) Descriptor deprecated 

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

Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskRequest) GetTask 

func (x *CreateTaskRequest) GetTask() *Task

func (*CreateTaskRequest) ProtoMessage 

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) ProtoReflect 

func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message

func (*CreateTaskRequest) Reset 

func (x *CreateTaskRequest) Reset()

func (*CreateTaskRequest) String 

func (x *CreateTaskRequest) String() string

type CreateVisualizationRequest 

type CreateVisualizationRequest struct {
	Visualization *Visualization `protobuf:"bytes,1,opt,name=visualization,proto3" json:"visualization,omitempty"`
	Namespace     string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

Create visualization by providing the type of visualization that is desired and input data paths. Input dat paths are assumed to be unique and are used for determining output path.

func (*CreateVisualizationRequest) Descriptor deprecated 

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

Deprecated: Use CreateVisualizationRequest.ProtoReflect.Descriptor instead.

func (*CreateVisualizationRequest) GetNamespace 

func (x *CreateVisualizationRequest) GetNamespace() string

func (*CreateVisualizationRequest) GetVisualization 

func (x *CreateVisualizationRequest) GetVisualization() *Visualization

func (*CreateVisualizationRequest) ProtoMessage 

func (*CreateVisualizationRequest) ProtoMessage()

func (*CreateVisualizationRequest) ProtoReflect 

func (x *CreateVisualizationRequest) ProtoReflect() protoreflect.Message

func (*CreateVisualizationRequest) Reset 

func (x *CreateVisualizationRequest) Reset()

func (*CreateVisualizationRequest) String 

func (x *CreateVisualizationRequest) String() string

type CronSchedule 

type CronSchedule struct {

	// The start time of the cron job
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The end time of the cron job
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// The cron string. For details how to compose a cron, visit
	// ttps://en.wikipedia.org/wiki/Cron
	Cron string `protobuf:"bytes,3,opt,name=cron,proto3" json:"cron,omitempty"`
	// contains filtered or unexported fields
}

CronSchedule allow scheduling the job with unix-like cron

func (*CronSchedule) Descriptor deprecated 

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

Deprecated: Use CronSchedule.ProtoReflect.Descriptor instead.

func (*CronSchedule) GetCron 

func (x *CronSchedule) GetCron() string

func (*CronSchedule) GetEndTime 

func (x *CronSchedule) GetEndTime() *timestamppb.Timestamp

func (*CronSchedule) GetStartTime 

func (x *CronSchedule) GetStartTime() *timestamppb.Timestamp

func (*CronSchedule) ProtoMessage 

func (*CronSchedule) ProtoMessage()

func (*CronSchedule) ProtoReflect 

func (x *CronSchedule) ProtoReflect() protoreflect.Message

func (*CronSchedule) Reset 

func (x *CronSchedule) Reset()

func (*CronSchedule) String 

func (x *CronSchedule) String() string

type DeleteExperimentRequest 

type DeleteExperimentRequest struct {

	// The ID of the experiment to be deleted.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteExperimentRequest) Descriptor deprecated 

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

Deprecated: Use DeleteExperimentRequest.ProtoReflect.Descriptor instead.

func (*DeleteExperimentRequest) GetId 

func (x *DeleteExperimentRequest) GetId() string

func (*DeleteExperimentRequest) ProtoMessage 

func (*DeleteExperimentRequest) ProtoMessage()

func (*DeleteExperimentRequest) ProtoReflect 

func (x *DeleteExperimentRequest) ProtoReflect() protoreflect.Message

func (*DeleteExperimentRequest) Reset 

func (x *DeleteExperimentRequest) Reset()

func (*DeleteExperimentRequest) String 

func (x *DeleteExperimentRequest) String() string

type DeleteJobRequest 

type DeleteJobRequest struct {

	// The ID of the job to be deleted
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteJobRequest) Descriptor deprecated 

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

Deprecated: Use DeleteJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteJobRequest) GetId 

func (x *DeleteJobRequest) GetId() string

func (*DeleteJobRequest) ProtoMessage 

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) ProtoReflect 

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

func (*DeleteJobRequest) Reset 

func (x *DeleteJobRequest) Reset()

func (*DeleteJobRequest) String 

func (x *DeleteJobRequest) String() string

type DeletePipelineRequest 

type DeletePipelineRequest struct {

	// The ID of the pipeline to be deleted.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePipelineRequest) Descriptor deprecated 

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

Deprecated: Use DeletePipelineRequest.ProtoReflect.Descriptor instead.

func (*DeletePipelineRequest) GetId 

func (x *DeletePipelineRequest) GetId() string

func (*DeletePipelineRequest) ProtoMessage 

func (*DeletePipelineRequest) ProtoMessage()

func (*DeletePipelineRequest) ProtoReflect 

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

func (*DeletePipelineRequest) Reset 

func (x *DeletePipelineRequest) Reset()

func (*DeletePipelineRequest) String 

func (x *DeletePipelineRequest) String() string

type DeletePipelineVersionRequest 

type DeletePipelineVersionRequest struct {

	// The ID of the pipeline version to be deleted.
	VersionId string `protobuf:"bytes,1,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePipelineVersionRequest) Descriptor deprecated 

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

Deprecated: Use DeletePipelineVersionRequest.ProtoReflect.Descriptor instead.

func (*DeletePipelineVersionRequest) GetVersionId 

func (x *DeletePipelineVersionRequest) GetVersionId() string

func (*DeletePipelineVersionRequest) ProtoMessage 

func (*DeletePipelineVersionRequest) ProtoMessage()

func (*DeletePipelineVersionRequest) ProtoReflect 

func (x *DeletePipelineVersionRequest) ProtoReflect() protoreflect.Message

func (*DeletePipelineVersionRequest) Reset 

func (x *DeletePipelineVersionRequest) Reset()

func (*DeletePipelineVersionRequest) String 

func (x *DeletePipelineVersionRequest) String() string

type DeleteRunRequest 

type DeleteRunRequest struct {

	// The ID of the run to be deleted.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRunRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRunRequest.ProtoReflect.Descriptor instead.

func (*DeleteRunRequest) GetId 

func (x *DeleteRunRequest) GetId() string

func (*DeleteRunRequest) ProtoMessage 

func (*DeleteRunRequest) ProtoMessage()

func (*DeleteRunRequest) ProtoReflect 

func (x *DeleteRunRequest) ProtoReflect() protoreflect.Message

func (*DeleteRunRequest) Reset 

func (x *DeleteRunRequest) Reset()

func (*DeleteRunRequest) String 

func (x *DeleteRunRequest) String() string

type DisableJobRequest 

type DisableJobRequest struct {

	// The ID of the job to be disabled
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DisableJobRequest) Descriptor deprecated 

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

Deprecated: Use DisableJobRequest.ProtoReflect.Descriptor instead.

func (*DisableJobRequest) GetId 

func (x *DisableJobRequest) GetId() string

func (*DisableJobRequest) ProtoMessage 

func (*DisableJobRequest) ProtoMessage()

func (*DisableJobRequest) ProtoReflect 

func (x *DisableJobRequest) ProtoReflect() protoreflect.Message

func (*DisableJobRequest) Reset 

func (x *DisableJobRequest) Reset()

func (*DisableJobRequest) String 

func (x *DisableJobRequest) String() string

type DummyFilterServiceClient 

type DummyFilterServiceClient interface {
	GetFilter(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Filter, error)
}

DummyFilterServiceClient is the client API for DummyFilterService service.

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

func NewDummyFilterServiceClient 

func NewDummyFilterServiceClient(cc grpc.ClientConnInterface) DummyFilterServiceClient

type DummyFilterServiceServer 

type DummyFilterServiceServer interface {
	GetFilter(context.Context, *Filter) (*Filter, error)
}

DummyFilterServiceServer is the server API for DummyFilterService service.

type EnableJobRequest 

type EnableJobRequest struct {

	// The ID of the job to be enabled
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*EnableJobRequest) Descriptor deprecated 

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

Deprecated: Use EnableJobRequest.ProtoReflect.Descriptor instead.

func (*EnableJobRequest) GetId 

func (x *EnableJobRequest) GetId() string

func (*EnableJobRequest) ProtoMessage 

func (*EnableJobRequest) ProtoMessage()

func (*EnableJobRequest) ProtoReflect 

func (x *EnableJobRequest) ProtoReflect() protoreflect.Message

func (*EnableJobRequest) Reset 

func (x *EnableJobRequest) Reset()

func (*EnableJobRequest) String 

func (x *EnableJobRequest) String() string

type Error 

type Error struct {
	ErrorMessage string `protobuf:"bytes,1,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ErrorDetails string `protobuf:"bytes,2,opt,name=error_details,json=errorDetails,proto3" json:"error_details,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetErrorDetails 

func (x *Error) GetErrorDetails() string

func (*Error) GetErrorMessage 

func (x *Error) GetErrorMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type Experiment 

type Experiment struct {

	// Output. Unique experiment ID. Generated by API server.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Required input field. Unique experiment name provided by user.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Optional input field. Describing the purpose of the experiment
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Output. The time that the experiment created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Optional input field. Specify which resource this run belongs to.
	// For Experiment, the only valid resource reference is a single Namespace.
	ResourceReferences []*ResourceReference `protobuf:"bytes,5,rep,name=resource_references,json=resourceReferences,proto3" json:"resource_references,omitempty"`
	// Output. Specifies whether this experiment is in archived or available state.
	StorageState Experiment_StorageState `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Experiment) Descriptor deprecated 

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

Deprecated: Use Experiment.ProtoReflect.Descriptor instead.

func (*Experiment) GetCreatedAt 

func (x *Experiment) GetCreatedAt() *timestamppb.Timestamp

func (*Experiment) GetDescription 

func (x *Experiment) GetDescription() string

func (*Experiment) GetId 

func (x *Experiment) GetId() string

func (*Experiment) GetName 

func (x *Experiment) GetName() string

func (*Experiment) GetResourceReferences 

func (x *Experiment) GetResourceReferences() []*ResourceReference

func (*Experiment) GetStorageState 

func (x *Experiment) GetStorageState() Experiment_StorageState

func (*Experiment) ProtoMessage 

func (*Experiment) ProtoMessage()

func (*Experiment) ProtoReflect 

func (x *Experiment) ProtoReflect() protoreflect.Message

func (*Experiment) Reset 

func (x *Experiment) Reset()

func (*Experiment) String 

func (x *Experiment) String() string

type ExperimentServiceClient 

type ExperimentServiceClient interface {
	// Creates a new experiment.
	CreateExperiment(ctx context.Context, in *CreateExperimentRequest, opts ...grpc.CallOption) (*Experiment, error)
	// Finds a specific experiment by ID.
	GetExperiment(ctx context.Context, in *GetExperimentRequest, opts ...grpc.CallOption) (*Experiment, error)
	// Finds all experiments. Supports pagination, and sorting on certain fields.
	ListExperiment(ctx context.Context, in *ListExperimentsRequest, opts ...grpc.CallOption) (*ListExperimentsResponse, error)
	// Deletes an experiment without deleting the experiment's runs and jobs. To
	// avoid unexpected behaviors, delete an experiment's runs and jobs before
	// deleting the experiment.
	DeleteExperiment(ctx context.Context, in *DeleteExperimentRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Archives an experiment and the experiment's runs and jobs.
	ArchiveExperiment(ctx context.Context, in *ArchiveExperimentRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Restores an archived experiment. The experiment's archived runs and jobs
	// will stay archived.
	UnarchiveExperiment(ctx context.Context, in *UnarchiveExperimentRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ExperimentServiceClient is the client API for ExperimentService service.

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

func NewExperimentServiceClient 

func NewExperimentServiceClient(cc grpc.ClientConnInterface) ExperimentServiceClient

type ExperimentServiceServer 

type ExperimentServiceServer interface {
	// Creates a new experiment.
	CreateExperiment(context.Context, *CreateExperimentRequest) (*Experiment, error)
	// Finds a specific experiment by ID.
	GetExperiment(context.Context, *GetExperimentRequest) (*Experiment, error)
	// Finds all experiments. Supports pagination, and sorting on certain fields.
	ListExperiment(context.Context, *ListExperimentsRequest) (*ListExperimentsResponse, error)
	// Deletes an experiment without deleting the experiment's runs and jobs. To
	// avoid unexpected behaviors, delete an experiment's runs and jobs before
	// deleting the experiment.
	DeleteExperiment(context.Context, *DeleteExperimentRequest) (*emptypb.Empty, error)
	// Archives an experiment and the experiment's runs and jobs.
	ArchiveExperiment(context.Context, *ArchiveExperimentRequest) (*emptypb.Empty, error)
	// Restores an archived experiment. The experiment's archived runs and jobs
	// will stay archived.
	UnarchiveExperiment(context.Context, *UnarchiveExperimentRequest) (*emptypb.Empty, error)
}

ExperimentServiceServer is the server API for ExperimentService service.

type Experiment_StorageState 

type Experiment_StorageState int32
const (
	Experiment_STORAGESTATE_UNSPECIFIED Experiment_StorageState = 0
	Experiment_STORAGESTATE_AVAILABLE   Experiment_StorageState = 1
	Experiment_STORAGESTATE_ARCHIVED    Experiment_StorageState = 2
)

func (Experiment_StorageState) Descriptor 

func (Experiment_StorageState) Descriptor() protoreflect.EnumDescriptor

func (Experiment_StorageState) Enum 

func (x Experiment_StorageState) Enum() *Experiment_StorageState

func (Experiment_StorageState) EnumDescriptor deprecated 

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

Deprecated: Use Experiment_StorageState.Descriptor instead.

func (Experiment_StorageState) Number 

func (x Experiment_StorageState) Number() protoreflect.EnumNumber

func (Experiment_StorageState) String 

func (x Experiment_StorageState) String() string

func (Experiment_StorageState) Type 

func (Experiment_StorageState) Type() protoreflect.EnumType

type Filter 

type Filter struct {

	// All predicates are AND-ed when this filter is applied.
	Predicates []*Predicate `protobuf:"bytes,1,rep,name=predicates,proto3" json:"predicates,omitempty"`
	// contains filtered or unexported fields
}

Filter is used to filter resources returned from a ListXXX request.

Example filters: 1) Filter runs with status = 'Running' 

filter {
  predicate {
    key: "status"
    op: EQUALS
    string_value: "Running"
  }
}

2) Filter runs that succeeded since Dec 1, 2018 

filter {
  predicate {
    key: "status"
    op: EQUALS
    string_value: "Succeeded"
  }
  predicate {
    key: "created_at"
    op: GREATER_THAN
    timestamp_value {
      seconds: 1543651200
    }
  }
}

3) Filter runs with one of labels 'label_1' or 'label_2' 

filter {
  predicate {
    key: "label"
    op: IN
    string_values {
      value: 'label_1'
      value: 'label_2'
    }
  }
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetPredicates 

func (x *Filter) GetPredicates() []*Predicate

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

func (x *Filter) ProtoReflect() protoreflect.Message

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type GetExperimentRequest 

type GetExperimentRequest struct {

	// The ID of the experiment to be retrieved.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExperimentRequest) Descriptor deprecated 

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

Deprecated: Use GetExperimentRequest.ProtoReflect.Descriptor instead.

func (*GetExperimentRequest) GetId 

func (x *GetExperimentRequest) GetId() string

func (*GetExperimentRequest) ProtoMessage 

func (*GetExperimentRequest) ProtoMessage()

func (*GetExperimentRequest) ProtoReflect 

func (x *GetExperimentRequest) ProtoReflect() protoreflect.Message

func (*GetExperimentRequest) Reset 

func (x *GetExperimentRequest) Reset()

func (*GetExperimentRequest) String 

func (x *GetExperimentRequest) String() string

type GetHealthzResponse 

type GetHealthzResponse struct {

	// Returns if KFP in multi-user mode
	MultiUser bool `protobuf:"varint,3,opt,name=multi_user,json=multiUser,proto3" json:"multi_user,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHealthzResponse) Descriptor deprecated 

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

Deprecated: Use GetHealthzResponse.ProtoReflect.Descriptor instead.

func (*GetHealthzResponse) GetMultiUser 

func (x *GetHealthzResponse) GetMultiUser() bool

func (*GetHealthzResponse) ProtoMessage 

func (*GetHealthzResponse) ProtoMessage()

func (*GetHealthzResponse) ProtoReflect 

func (x *GetHealthzResponse) ProtoReflect() protoreflect.Message

func (*GetHealthzResponse) Reset 

func (x *GetHealthzResponse) Reset()

func (*GetHealthzResponse) String 

func (x *GetHealthzResponse) String() string

type GetJobRequest 

type GetJobRequest struct {

	// The ID of the job to be retrieved
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetId 

func (x *GetJobRequest) GetId() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

func (x *GetJobRequest) ProtoReflect() protoreflect.Message

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetPipelineRequest 

type GetPipelineRequest struct {

	// The ID of the pipeline to be retrieved.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineRequest) Descriptor deprecated 

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

Deprecated: Use GetPipelineRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineRequest) GetId 

func (x *GetPipelineRequest) GetId() string

func (*GetPipelineRequest) ProtoMessage 

func (*GetPipelineRequest) ProtoMessage()

func (*GetPipelineRequest) ProtoReflect 

func (x *GetPipelineRequest) ProtoReflect() protoreflect.Message

func (*GetPipelineRequest) Reset 

func (x *GetPipelineRequest) Reset()

func (*GetPipelineRequest) String 

func (x *GetPipelineRequest) String() string

type GetPipelineVersionRequest 

type GetPipelineVersionRequest struct {

	// The ID of the pipeline version to be retrieved.
	VersionId string `protobuf:"bytes,1,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineVersionRequest) Descriptor deprecated 

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

Deprecated: Use GetPipelineVersionRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineVersionRequest) GetVersionId 

func (x *GetPipelineVersionRequest) GetVersionId() string

func (*GetPipelineVersionRequest) ProtoMessage 

func (*GetPipelineVersionRequest) ProtoMessage()

func (*GetPipelineVersionRequest) ProtoReflect 

func (x *GetPipelineVersionRequest) ProtoReflect() protoreflect.Message

func (*GetPipelineVersionRequest) Reset 

func (x *GetPipelineVersionRequest) Reset()

func (*GetPipelineVersionRequest) String 

func (x *GetPipelineVersionRequest) String() string

type GetPipelineVersionTemplateRequest 

type GetPipelineVersionTemplateRequest struct {

	// The ID of the pipeline version whose template is to be retrieved.
	VersionId string `protobuf:"bytes,1,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineVersionTemplateRequest) Descriptor deprecated 

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

Deprecated: Use GetPipelineVersionTemplateRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineVersionTemplateRequest) GetVersionId 

func (x *GetPipelineVersionTemplateRequest) GetVersionId() string

func (*GetPipelineVersionTemplateRequest) ProtoMessage 

func (*GetPipelineVersionTemplateRequest) ProtoMessage()

func (*GetPipelineVersionTemplateRequest) ProtoReflect 

func (x *GetPipelineVersionTemplateRequest) ProtoReflect() protoreflect.Message

func (*GetPipelineVersionTemplateRequest) Reset 

func (x *GetPipelineVersionTemplateRequest) Reset()

func (*GetPipelineVersionTemplateRequest) String 

func (x *GetPipelineVersionTemplateRequest) String() string

type GetRunRequest 

type GetRunRequest struct {

	// The ID of the run to be retrieved.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRunRequest) Descriptor deprecated 

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

Deprecated: Use GetRunRequest.ProtoReflect.Descriptor instead.

func (*GetRunRequest) GetRunId 

func (x *GetRunRequest) GetRunId() string

func (*GetRunRequest) ProtoMessage 

func (*GetRunRequest) ProtoMessage()

func (*GetRunRequest) ProtoReflect 

func (x *GetRunRequest) ProtoReflect() protoreflect.Message

func (*GetRunRequest) Reset 

func (x *GetRunRequest) Reset()

func (*GetRunRequest) String 

func (x *GetRunRequest) String() string

type GetTemplateRequest 

type GetTemplateRequest struct {

	// The ID of the pipeline whose template is to be retrieved.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTemplateRequest) Descriptor deprecated 

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

Deprecated: Use GetTemplateRequest.ProtoReflect.Descriptor instead.

func (*GetTemplateRequest) GetId 

func (x *GetTemplateRequest) GetId() string

func (*GetTemplateRequest) ProtoMessage 

func (*GetTemplateRequest) ProtoMessage()

func (*GetTemplateRequest) ProtoReflect 

func (x *GetTemplateRequest) ProtoReflect() protoreflect.Message

func (*GetTemplateRequest) Reset 

func (x *GetTemplateRequest) Reset()

func (*GetTemplateRequest) String 

func (x *GetTemplateRequest) String() string

type GetTemplateResponse 

type GetTemplateResponse struct {

	// The template of the pipeline specified in a GetTemplate request, or of a
	// pipeline version specified in a GetPipelinesVersionTemplate request.
	Template string `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTemplateResponse) Descriptor deprecated 

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

Deprecated: Use GetTemplateResponse.ProtoReflect.Descriptor instead.

func (*GetTemplateResponse) GetTemplate 

func (x *GetTemplateResponse) GetTemplate() string

func (*GetTemplateResponse) ProtoMessage 

func (*GetTemplateResponse) ProtoMessage()

func (*GetTemplateResponse) ProtoReflect 

func (x *GetTemplateResponse) ProtoReflect() protoreflect.Message

func (*GetTemplateResponse) Reset 

func (x *GetTemplateResponse) Reset()

func (*GetTemplateResponse) String 

func (x *GetTemplateResponse) String() string

type HealthzServiceClient 

type HealthzServiceClient interface {
	// Get healthz data.
	GetHealthz(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetHealthzResponse, error)
}

HealthzServiceClient is the client API for HealthzService service.

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

func NewHealthzServiceClient 

func NewHealthzServiceClient(cc grpc.ClientConnInterface) HealthzServiceClient

type HealthzServiceServer 

type HealthzServiceServer interface {
	// Get healthz data.
	GetHealthz(context.Context, *emptypb.Empty) (*GetHealthzResponse, error)
}

HealthzServiceServer is the server API for HealthzService service.

type IntValues 

type IntValues struct {
	Values []int32 `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*IntValues) Descriptor deprecated 

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

Deprecated: Use IntValues.ProtoReflect.Descriptor instead.

func (*IntValues) GetValues 

func (x *IntValues) GetValues() []int32

func (*IntValues) ProtoMessage 

func (*IntValues) ProtoMessage()

func (*IntValues) ProtoReflect 

func (x *IntValues) ProtoReflect() protoreflect.Message

func (*IntValues) Reset 

func (x *IntValues) Reset()

func (*IntValues) String 

func (x *IntValues) String() string

type Job 

type Job struct {

	// Output. Unique run ID. Generated by API server.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Required input field. Job name provided by user. Not unique.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Optional input field. Describing the purpose of the job
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Required input field.
	// Describing what the pipeline manifest and parameters to use
	// for the scheduled job.
	PipelineSpec *PipelineSpec `protobuf:"bytes,4,opt,name=pipeline_spec,json=pipelineSpec,proto3" json:"pipeline_spec,omitempty"`
	// Optional input field. Specify which resource this job belongs to.
	ResourceReferences []*ResourceReference `protobuf:"bytes,5,rep,name=resource_references,json=resourceReferences,proto3" json:"resource_references,omitempty"`
	// Optional input field. Specify which Kubernetes service account this job uses.
	ServiceAccount string `protobuf:"bytes,18,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Required input field.
	// Specify how many runs can be executed concurrently. Rage [1-10]
	MaxConcurrency int64 `protobuf:"varint,6,opt,name=max_concurrency,json=maxConcurrency,proto3" json:"max_concurrency,omitempty"`
	// Required input field.
	// Specify how a run is triggered. Support cron mode or periodic mode.
	Trigger *Trigger `protobuf:"bytes,7,opt,name=trigger,proto3" json:"trigger,omitempty"`
	Mode    Job_Mode `protobuf:"varint,8,opt,name=mode,proto3,enum=api.Job_Mode" json:"mode,omitempty"`
	// Output. The time this job is created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Output. The last time this job is updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Output. The status of the job.
	// One of [Enable, Disable, Error]
	Status string `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`
	// In case any error happens retrieving a job field, only job ID
	// and the error message is returned. Client has the flexibility of choosing
	// how to handle error. This is especially useful during listing call.
	Error string `protobuf:"bytes,12,opt,name=error,proto3" json:"error,omitempty"`
	// Input. Whether the job is enabled or not.
	Enabled bool `protobuf:"varint,16,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Optional input field. Whether the job should catch up if behind schedule.
	// If true, the job will only schedule the latest interval if behind schedule.
	// If false, the job will catch up on each past interval.
	NoCatchup bool `protobuf:"varint,17,opt,name=no_catchup,json=noCatchup,proto3" json:"no_catchup,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetCreatedAt 

func (x *Job) GetCreatedAt() *timestamppb.Timestamp

func (*Job) GetDescription 

func (x *Job) GetDescription() string

func (*Job) GetEnabled 

func (x *Job) GetEnabled() bool

func (*Job) GetError 

func (x *Job) GetError() string

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetMaxConcurrency 

func (x *Job) GetMaxConcurrency() int64

func (*Job) GetMode 

func (x *Job) GetMode() Job_Mode

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetNoCatchup 

func (x *Job) GetNoCatchup() bool

func (*Job) GetPipelineSpec 

func (x *Job) GetPipelineSpec() *PipelineSpec

func (*Job) GetResourceReferences 

func (x *Job) GetResourceReferences() []*ResourceReference

func (*Job) GetServiceAccount 

func (x *Job) GetServiceAccount() string

func (*Job) GetStatus 

func (x *Job) GetStatus() string

func (*Job) GetTrigger 

func (x *Job) GetTrigger() *Trigger

func (*Job) GetUpdatedAt 

func (x *Job) GetUpdatedAt() *timestamppb.Timestamp

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobServiceClient 

type JobServiceClient interface {
	// Creates a new job.
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)
	// Finds a specific job by ID.
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
	// Finds all jobs.
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	// Restarts a job that was previously stopped. All runs associated with the job will continue.
	EnableJob(ctx context.Context, in *EnableJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Stops a job and all its associated runs. The job is not deleted.
	DisableJob(ctx context.Context, in *DisableJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deletes a job.
	DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

JobServiceClient is the client API for JobService service.

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

func NewJobServiceClient 

func NewJobServiceClient(cc grpc.ClientConnInterface) JobServiceClient

type JobServiceServer 

type JobServiceServer interface {
	// Creates a new job.
	CreateJob(context.Context, *CreateJobRequest) (*Job, error)
	// Finds a specific job by ID.
	GetJob(context.Context, *GetJobRequest) (*Job, error)
	// Finds all jobs.
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	// Restarts a job that was previously stopped. All runs associated with the job will continue.
	EnableJob(context.Context, *EnableJobRequest) (*emptypb.Empty, error)
	// Stops a job and all its associated runs. The job is not deleted.
	DisableJob(context.Context, *DisableJobRequest) (*emptypb.Empty, error)
	// Deletes a job.
	DeleteJob(context.Context, *DeleteJobRequest) (*emptypb.Empty, error)
}

JobServiceServer is the server API for JobService service.

type Job_Mode 

type Job_Mode int32

Required input. 

const (
	Job_UNKNOWN_MODE Job_Mode = 0
	Job_ENABLED      Job_Mode = 1
	// The job won't schedule any run if disabled.
	Job_DISABLED Job_Mode = 2
)

func (Job_Mode) Descriptor 

func (Job_Mode) Descriptor() protoreflect.EnumDescriptor

func (Job_Mode) Enum 

func (x Job_Mode) Enum() *Job_Mode

func (Job_Mode) EnumDescriptor deprecated 

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

Deprecated: Use Job_Mode.Descriptor instead.

func (Job_Mode) Number 

func (x Job_Mode) Number() protoreflect.EnumNumber

func (Job_Mode) String 

func (x Job_Mode) String() string

func (Job_Mode) Type 

func (Job_Mode) Type() protoreflect.EnumType

type ListExperimentsRequest 

type ListExperimentsRequest struct {

	// A page token to request the next page of results. The token is acquried
	// from the nextPageToken field of the response from the previous
	// ListExperiment call or can be omitted when fetching the first page.
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The number of experiments to be listed per page. If there are more
	// experiments than this number, the response message will contain a
	// nextPageToken field you can use to fetch the next page.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Can be format of "field_name", "field_name asc" or "field_name desc"
	// Ascending by default.
	SortBy string `protobuf:"bytes,3,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// A url-encoded, JSON-serialized Filter protocol buffer (see
	// [filter.proto](https://github.com/kubeflow/pipelines/
	// blob/master/backend/api/filter.proto)).
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// What resource reference to filter on.
	// For Experiment, the only valid resource type is Namespace. An sample query string could be
	// resource_reference_key.type=NAMESPACE&resource_reference_key.id=ns1
	ResourceReferenceKey *ResourceKey `protobuf:"bytes,5,opt,name=resource_reference_key,json=resourceReferenceKey,proto3" json:"resource_reference_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExperimentsRequest) Descriptor deprecated 

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

Deprecated: Use ListExperimentsRequest.ProtoReflect.Descriptor instead.

func (*ListExperimentsRequest) GetFilter 

func (x *ListExperimentsRequest) GetFilter() string

func (*ListExperimentsRequest) GetPageSize 

func (x *ListExperimentsRequest) GetPageSize() int32

func (*ListExperimentsRequest) GetPageToken 

func (x *ListExperimentsRequest) GetPageToken() string

func (*ListExperimentsRequest) GetResourceReferenceKey 

func (x *ListExperimentsRequest) GetResourceReferenceKey() *ResourceKey

func (*ListExperimentsRequest) GetSortBy 

func (x *ListExperimentsRequest) GetSortBy() string

func (*ListExperimentsRequest) ProtoMessage 

func (*ListExperimentsRequest) ProtoMessage()

func (*ListExperimentsRequest) ProtoReflect 

func (x *ListExperimentsRequest) ProtoReflect() protoreflect.Message

func (*ListExperimentsRequest) Reset 

func (x *ListExperimentsRequest) Reset()

func (*ListExperimentsRequest) String 

func (x *ListExperimentsRequest) String() string

type ListExperimentsResponse 

type ListExperimentsResponse struct {

	// A list of experiments returned.
	Experiments []*Experiment `protobuf:"bytes,1,rep,name=experiments,proto3" json:"experiments,omitempty"`
	// The total number of experiments for the given query.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// The token to list the next page of experiments.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExperimentsResponse) Descriptor deprecated 

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

Deprecated: Use ListExperimentsResponse.ProtoReflect.Descriptor instead.

func (*ListExperimentsResponse) GetExperiments 

func (x *ListExperimentsResponse) GetExperiments() []*Experiment

func (*ListExperimentsResponse) GetNextPageToken 

func (x *ListExperimentsResponse) GetNextPageToken() string

func (*ListExperimentsResponse) GetTotalSize 

func (x *ListExperimentsResponse) GetTotalSize() int32

func (*ListExperimentsResponse) ProtoMessage 

func (*ListExperimentsResponse) ProtoMessage()

func (*ListExperimentsResponse) ProtoReflect 

func (x *ListExperimentsResponse) ProtoReflect() protoreflect.Message

func (*ListExperimentsResponse) Reset 

func (x *ListExperimentsResponse) Reset()

func (*ListExperimentsResponse) String 

func (x *ListExperimentsResponse) String() string

type ListJobsRequest 

type ListJobsRequest struct {

	// A page token to request the next page of results. The token is acquried
	// from the nextPageToken field of the response from the previous
	// ListJobs call or can be omitted when fetching the first page.
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The number of jobs to be listed per page. If there are more jobs than this
	// number, the response message will contain a nextPageToken field you can use
	// to fetch the next page.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Can be format of "field_name", "field_name asc" or "field_name desc".
	// Ascending by default.
	SortBy string `protobuf:"bytes,3,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// What resource reference to filter on.
	// E.g. If listing job for an experiment, the query string would be
	// resource_reference_key.type=EXPERIMENT&resource_reference_key.id=123
	ResourceReferenceKey *ResourceKey `protobuf:"bytes,4,opt,name=resource_reference_key,json=resourceReferenceKey,proto3" json:"resource_reference_key,omitempty"`
	// A url-encoded, JSON-serialized Filter protocol buffer (see
	// [filter.proto](https://github.com/kubeflow/pipelines/
	// blob/master/backend/api/filter.proto)).
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetFilter 

func (x *ListJobsRequest) GetFilter() string

func (*ListJobsRequest) GetPageSize 

func (x *ListJobsRequest) GetPageSize() int32

func (*ListJobsRequest) GetPageToken 

func (x *ListJobsRequest) GetPageToken() string

func (*ListJobsRequest) GetResourceReferenceKey 

func (x *ListJobsRequest) GetResourceReferenceKey() *ResourceKey

func (*ListJobsRequest) GetSortBy 

func (x *ListJobsRequest) GetSortBy() string

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect 

func (x *ListJobsRequest) ProtoReflect() protoreflect.Message

func (*ListJobsRequest) Reset 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (x *ListJobsRequest) String() string

type ListJobsResponse 

type ListJobsResponse struct {

	// A list of jobs returned.
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// The total number of jobs for the given query.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// The token to list the next page of jobs.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetJobs 

func (x *ListJobsResponse) GetJobs() []*Job

func (*ListJobsResponse) GetNextPageToken 

func (x *ListJobsResponse) GetNextPageToken() string

func (*ListJobsResponse) GetTotalSize 

func (x *ListJobsResponse) GetTotalSize() int32

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect 

func (x *ListJobsResponse) ProtoReflect() protoreflect.Message

func (*ListJobsResponse) Reset 

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (x *ListJobsResponse) String() string

type ListPipelineVersionsRequest 

type ListPipelineVersionsRequest struct {

	// ResourceKey specifies the pipeline whose versions are to be listed.
	ResourceKey *ResourceKey `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	// The number of pipeline versions to be listed per page. If there are more
	// pipeline versions than this number, the response message will contain a
	// nextPageToken field you can use to fetch the next page.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token to request the next page of results. The token is acquried
	// from the nextPageToken field of the response from the previous
	// ListPipelineVersions call or can be omitted when fetching the first page.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Can be format of "field_name", "field_name asc" or "field_name desc"
	// Ascending by default.
	SortBy string `protobuf:"bytes,4,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// A base-64 encoded, JSON-serialized Filter protocol buffer (see
	// filter.proto).
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPipelineVersionsRequest) Descriptor deprecated 

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

Deprecated: Use ListPipelineVersionsRequest.ProtoReflect.Descriptor instead.

func (*ListPipelineVersionsRequest) GetFilter 

func (x *ListPipelineVersionsRequest) GetFilter() string

func (*ListPipelineVersionsRequest) GetPageSize 

func (x *ListPipelineVersionsRequest) GetPageSize() int32

func (*ListPipelineVersionsRequest) GetPageToken 

func (x *ListPipelineVersionsRequest) GetPageToken() string

func (*ListPipelineVersionsRequest) GetResourceKey 

func (x *ListPipelineVersionsRequest) GetResourceKey() *ResourceKey

func (*ListPipelineVersionsRequest) GetSortBy 

func (x *ListPipelineVersionsRequest) GetSortBy() string

func (*ListPipelineVersionsRequest) ProtoMessage 

func (*ListPipelineVersionsRequest) ProtoMessage()

func (*ListPipelineVersionsRequest) ProtoReflect 

func (x *ListPipelineVersionsRequest) ProtoReflect() protoreflect.Message

func (*ListPipelineVersionsRequest) Reset 

func (x *ListPipelineVersionsRequest) Reset()

func (*ListPipelineVersionsRequest) String 

func (x *ListPipelineVersionsRequest) String() string

type ListPipelineVersionsResponse 

type ListPipelineVersionsResponse struct {
	Versions []*PipelineVersion `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"`
	// The token to list the next page of pipeline versions.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// The total number of pipeline versions for the given query.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPipelineVersionsResponse) Descriptor deprecated 

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

Deprecated: Use ListPipelineVersionsResponse.ProtoReflect.Descriptor instead.

func (*ListPipelineVersionsResponse) GetNextPageToken 

func (x *ListPipelineVersionsResponse) GetNextPageToken() string

func (*ListPipelineVersionsResponse) GetTotalSize 

func (x *ListPipelineVersionsResponse) GetTotalSize() int32

func (*ListPipelineVersionsResponse) GetVersions 

func (x *ListPipelineVersionsResponse) GetVersions() []*PipelineVersion

func (*ListPipelineVersionsResponse) ProtoMessage 

func (*ListPipelineVersionsResponse) ProtoMessage()

func (*ListPipelineVersionsResponse) ProtoReflect 

func (x *ListPipelineVersionsResponse) ProtoReflect() protoreflect.Message

func (*ListPipelineVersionsResponse) Reset 

func (x *ListPipelineVersionsResponse) Reset()

func (*ListPipelineVersionsResponse) String 

func (x *ListPipelineVersionsResponse) String() string

type ListPipelinesRequest 

type ListPipelinesRequest struct {

	// A page token to request the next page of results. The token is acquried
	// from the nextPageToken field of the response from the previous
	// ListPipelines call.
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The number of pipelines to be listed per page. If there are more pipelines
	// than this number, the response message will contain a valid value in the
	// nextPageToken field.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Can be format of "field_name", "field_name asc" or "field_name desc"
	// Ascending by default.
	SortBy string `protobuf:"bytes,3,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// A url-encoded, JSON-serialized Filter protocol buffer (see
	// [filter.proto](https://github.com/kubeflow/pipelines/
	// blob/master/backend/api/filter.proto)).
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// What resource reference to filter on.
	// For Pipeline, the only valid resource type is Namespace. An sample query string could be
	// resource_reference_key.type=NAMESPACE&resource_reference_key.id=ns1
	ResourceReferenceKey *ResourceKey `protobuf:"bytes,5,opt,name=resource_reference_key,json=resourceReferenceKey,proto3" json:"resource_reference_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPipelinesRequest) Descriptor deprecated 

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

Deprecated: Use ListPipelinesRequest.ProtoReflect.Descriptor instead.

func (*ListPipelinesRequest) GetFilter 

func (x *ListPipelinesRequest) GetFilter() string

func (*ListPipelinesRequest) GetPageSize 

func (x *ListPipelinesRequest) GetPageSize() int32

func (*ListPipelinesRequest) GetPageToken 

func (x *ListPipelinesRequest) GetPageToken() string

func (*ListPipelinesRequest) GetResourceReferenceKey 

func (x *ListPipelinesRequest) GetResourceReferenceKey() *ResourceKey

func (*ListPipelinesRequest) GetSortBy 

func (x *ListPipelinesRequest) GetSortBy() string

func (*ListPipelinesRequest) ProtoMessage 

func (*ListPipelinesRequest) ProtoMessage()

func (*ListPipelinesRequest) ProtoReflect 

func (x *ListPipelinesRequest) ProtoReflect() protoreflect.Message

func (*ListPipelinesRequest) Reset 

func (x *ListPipelinesRequest) Reset()

func (*ListPipelinesRequest) String 

func (x *ListPipelinesRequest) String() string

type ListPipelinesResponse 

type ListPipelinesResponse struct {
	Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// The total number of pipelines for the given query.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// The token to list the next page of pipelines.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPipelinesResponse) Descriptor deprecated 

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

Deprecated: Use ListPipelinesResponse.ProtoReflect.Descriptor instead.

func (*ListPipelinesResponse) GetNextPageToken 

func (x *ListPipelinesResponse) GetNextPageToken() string

func (*ListPipelinesResponse) GetPipelines 

func (x *ListPipelinesResponse) GetPipelines() []*Pipeline

func (*ListPipelinesResponse) GetTotalSize 

func (x *ListPipelinesResponse) GetTotalSize() int32

func (*ListPipelinesResponse) ProtoMessage 

func (*ListPipelinesResponse) ProtoMessage()

func (*ListPipelinesResponse) ProtoReflect 

func (x *ListPipelinesResponse) ProtoReflect() protoreflect.Message

func (*ListPipelinesResponse) Reset 

func (x *ListPipelinesResponse) Reset()

func (*ListPipelinesResponse) String 

func (x *ListPipelinesResponse) String() string

type ListRunsRequest 

type ListRunsRequest struct {

	// A page token to request the next page of results. The token is acquried
	// from the nextPageToken field of the response from the previous
	// ListRuns call or can be omitted when fetching the first page.
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The number of runs to be listed per page. If there are more runs than this
	// number, the response message will contain a nextPageToken field you can use
	// to fetch the next page.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Can be format of "field_name", "field_name asc" or "field_name desc"
	// (Example, "name asc" or "id desc"). Ascending by default.
	SortBy string `protobuf:"bytes,3,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// What resource reference to filter on.
	// E.g. If listing run for an experiment, the query string would be
	// resource_reference_key.type=EXPERIMENT&resource_reference_key.id=123
	ResourceReferenceKey *ResourceKey `protobuf:"bytes,4,opt,name=resource_reference_key,json=resourceReferenceKey,proto3" json:"resource_reference_key,omitempty"`
	// A url-encoded, JSON-serialized Filter protocol buffer (see
	// [filter.proto](https://github.com/kubeflow/pipelines/
	// blob/master/backend/api/filter.proto)).
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRunsRequest) Descriptor deprecated 

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

Deprecated: Use ListRunsRequest.ProtoReflect.Descriptor instead.

func (*ListRunsRequest) GetFilter 

func (x *ListRunsRequest) GetFilter() string

func (*ListRunsRequest) GetPageSize 

func (x *ListRunsRequest) GetPageSize() int32

func (*ListRunsRequest) GetPageToken 

func (x *ListRunsRequest) GetPageToken() string

func (*ListRunsRequest) GetResourceReferenceKey 

func (x *ListRunsRequest) GetResourceReferenceKey() *ResourceKey

func (*ListRunsRequest) GetSortBy 

func (x *ListRunsRequest) GetSortBy() string

func (*ListRunsRequest) ProtoMessage 

func (*ListRunsRequest) ProtoMessage()

func (*ListRunsRequest) ProtoReflect 

func (x *ListRunsRequest) ProtoReflect() protoreflect.Message

func (*ListRunsRequest) Reset 

func (x *ListRunsRequest) Reset()

func (*ListRunsRequest) String 

func (x *ListRunsRequest) String() string

type ListRunsResponse 

type ListRunsResponse struct {
	Runs []*Run `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	// The total number of runs for the given query.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// The token to list the next page of runs.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRunsResponse) Descriptor deprecated 

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

Deprecated: Use ListRunsResponse.ProtoReflect.Descriptor instead.

func (*ListRunsResponse) GetNextPageToken 

func (x *ListRunsResponse) GetNextPageToken() string

func (*ListRunsResponse) GetRuns 

func (x *ListRunsResponse) GetRuns() []*Run

func (*ListRunsResponse) GetTotalSize 

func (x *ListRunsResponse) GetTotalSize() int32

func (*ListRunsResponse) ProtoMessage 

func (*ListRunsResponse) ProtoMessage()

func (*ListRunsResponse) ProtoReflect 

func (x *ListRunsResponse) ProtoReflect() protoreflect.Message

func (*ListRunsResponse) Reset 

func (x *ListRunsResponse) Reset()

func (*ListRunsResponse) String 

func (x *ListRunsResponse) String() string

type ListTasksRequest 

type ListTasksRequest struct {

	// A page token to request the next page of results. The token is acquried
	// from the nextPageToken field of the response from the previous
	// ListExperiment call or can be omitted when fetching the first page.
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The number of experiments to be listed per page. If there are more
	// experiments than this number, the response message will contain a
	// nextPageToken field you can use to fetch the next page.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Can be format of "field_name", "field_name asc" or "field_name desc"
	// Ascending by default.
	SortBy string `protobuf:"bytes,3,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// What resource reference to filter on.
	// E.g. If listing tasks for an pipeline run, the query string would be
	// resource_reference_key.type="PIPELINE"&resource_reference_key.id=123
	ResourceReferenceKey *ResourceKey `protobuf:"bytes,4,opt,name=resource_reference_key,json=resourceReferenceKey,proto3" json:"resource_reference_key,omitempty"`
	// A url-encoded, JSON-serialized Filter protocol buffer (see
	// [filter.proto](https://github.com/kubeflow/pipelines/
	// blob/master/backend/api/filter.proto)).
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated 

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetFilter 

func (x *ListTasksRequest) GetFilter() string

func (*ListTasksRequest) GetPageSize 

func (x *ListTasksRequest) GetPageSize() int32

func (*ListTasksRequest) GetPageToken 

func (x *ListTasksRequest) GetPageToken() string

func (*ListTasksRequest) GetResourceReferenceKey 

func (x *ListTasksRequest) GetResourceReferenceKey() *ResourceKey

func (*ListTasksRequest) GetSortBy 

func (x *ListTasksRequest) GetSortBy() string

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect 

func (x *ListTasksRequest) ProtoReflect() protoreflect.Message

func (*ListTasksRequest) Reset 

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

type ListTasksResponse 

type ListTasksResponse struct {

	// A list of tasks returned.
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// The token to list the next page of experiments.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// The total number of experiments for the given query.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse) Descriptor deprecated 

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

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetNextPageToken 

func (x *ListTasksResponse) GetNextPageToken() string

func (*ListTasksResponse) GetTasks 

func (x *ListTasksResponse) GetTasks() []*Task

func (*ListTasksResponse) GetTotalSize 

func (x *ListTasksResponse) GetTotalSize() int32

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect 

func (x *ListTasksResponse) ProtoReflect() protoreflect.Message

func (*ListTasksResponse) Reset 

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String 

func (x *ListTasksResponse) String() string

type LongValues 

type LongValues struct {
	Values []int64 `protobuf:"varint,3,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*LongValues) Descriptor deprecated 

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

Deprecated: Use LongValues.ProtoReflect.Descriptor instead.

func (*LongValues) GetValues 

func (x *LongValues) GetValues() []int64

func (*LongValues) ProtoMessage 

func (*LongValues) ProtoMessage()

func (*LongValues) ProtoReflect 

func (x *LongValues) ProtoReflect() protoreflect.Message

func (*LongValues) Reset 

func (x *LongValues) Reset()

func (*LongValues) String 

func (x *LongValues) String() string

type Parameter 

type Parameter struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Parameter) Descriptor deprecated 

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

Deprecated: Use Parameter.ProtoReflect.Descriptor instead.

func (*Parameter) GetName 

func (x *Parameter) GetName() string

func (*Parameter) GetValue 

func (x *Parameter) GetValue() string

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) ProtoReflect 

func (x *Parameter) ProtoReflect() protoreflect.Message

func (*Parameter) Reset 

func (x *Parameter) Reset()

func (*Parameter) String 

func (x *Parameter) String() string

type PeriodicSchedule 

type PeriodicSchedule struct {

	// The start time of the periodic job
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The end time of the periodic job
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// The time interval between the starting time of consecutive jobs
	IntervalSecond int64 `protobuf:"varint,3,opt,name=interval_second,json=intervalSecond,proto3" json:"interval_second,omitempty"`
	// contains filtered or unexported fields
}

PeriodicSchedule allow scheduling the job periodically with certain interval

func (*PeriodicSchedule) Descriptor deprecated 

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

Deprecated: Use PeriodicSchedule.ProtoReflect.Descriptor instead.

func (*PeriodicSchedule) GetEndTime 

func (x *PeriodicSchedule) GetEndTime() *timestamppb.Timestamp

func (*PeriodicSchedule) GetIntervalSecond 

func (x *PeriodicSchedule) GetIntervalSecond() int64

func (*PeriodicSchedule) GetStartTime 

func (x *PeriodicSchedule) GetStartTime() *timestamppb.Timestamp

func (*PeriodicSchedule) ProtoMessage 

func (*PeriodicSchedule) ProtoMessage()

func (*PeriodicSchedule) ProtoReflect 

func (x *PeriodicSchedule) ProtoReflect() protoreflect.Message

func (*PeriodicSchedule) Reset 

func (x *PeriodicSchedule) Reset()

func (*PeriodicSchedule) String 

func (x *PeriodicSchedule) String() string

type Pipeline 

type Pipeline struct {

	// Output. Unique pipeline ID. Generated by API server.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Output. The time this pipeline is created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Optional input field. Pipeline name provided by user. If not specified,
	// file name is used as pipeline name.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Optional input field. Describing the purpose of the job.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// Output. The input parameters for this pipeline.
	// TODO(jingzhang36): replace this parameters field with the parameters field
	// inside PipelineVersion when all usage of the former has been changed to use
	// the latter.
	Parameters []*Parameter `protobuf:"bytes,5,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// The URL to the source of the pipeline. This is required when creating the
	// pipeine through CreatePipeline API.
	// TODO(jingzhang36): replace this url field with the code_source_urls field
	// inside PipelineVersion when all usage of the former has been changed to use
	// the latter.
	Url *Url `protobuf:"bytes,7,opt,name=url,proto3" json:"url,omitempty"`
	// In case any error happens retrieving a pipeline field, only pipeline ID
	// and the error message is returned. Client has the flexibility of choosing
	// how to handle error. This is especially useful during listing call.
	Error string `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// Output only. The default version of the pipeline. As of now, the latest
	// version is used as default. (In the future, if desired by customers, we
	// can allow them to set default version.)
	DefaultVersion *PipelineVersion `protobuf:"bytes,8,opt,name=default_version,json=defaultVersion,proto3" json:"default_version,omitempty"`
	// Input field. Specify which resource this pipeline belongs to.
	// For Pipeline, the only valid resource reference is a single Namespace.
	ResourceReferences []*ResourceReference `protobuf:"bytes,9,rep,name=resource_references,json=resourceReferences,proto3" json:"resource_references,omitempty"`
	// contains filtered or unexported fields
}

func (*Pipeline) Descriptor deprecated 

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

Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.

func (*Pipeline) GetCreatedAt 

func (x *Pipeline) GetCreatedAt() *timestamppb.Timestamp

func (*Pipeline) GetDefaultVersion 

func (x *Pipeline) GetDefaultVersion() *PipelineVersion

func (*Pipeline) GetDescription 

func (x *Pipeline) GetDescription() string

func (*Pipeline) GetError 

func (x *Pipeline) GetError() string

func (*Pipeline) GetId 

func (x *Pipeline) GetId() string

func (*Pipeline) GetName 

func (x *Pipeline) GetName() string

func (*Pipeline) GetParameters 

func (x *Pipeline) GetParameters() []*Parameter

func (*Pipeline) GetResourceReferences 

func (x *Pipeline) GetResourceReferences() []*ResourceReference

func (*Pipeline) GetUrl 

func (x *Pipeline) GetUrl() *Url

func (*Pipeline) ProtoMessage 

func (*Pipeline) ProtoMessage()

func (*Pipeline) ProtoReflect 

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

func (*Pipeline) Reset 

func (x *Pipeline) Reset()

func (*Pipeline) String 

func (x *Pipeline) String() string

type PipelineRuntime 

type PipelineRuntime struct {

	// Output. The runtime JSON manifest of the pipeline, including the status
	// of pipeline steps and fields need for UI visualization etc.
	PipelineManifest string `protobuf:"bytes,10,opt,name=pipeline_manifest,json=pipelineManifest,proto3" json:"pipeline_manifest,omitempty"`
	// Output. The runtime JSON manifest of the argo workflow.
	// This is deprecated after pipeline_runtime_manifest is in use.
	WorkflowManifest string `protobuf:"bytes,11,opt,name=workflow_manifest,json=workflowManifest,proto3" json:"workflow_manifest,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineRuntime) Descriptor deprecated 

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

Deprecated: Use PipelineRuntime.ProtoReflect.Descriptor instead.

func (*PipelineRuntime) GetPipelineManifest 

func (x *PipelineRuntime) GetPipelineManifest() string

func (*PipelineRuntime) GetWorkflowManifest 

func (x *PipelineRuntime) GetWorkflowManifest() string

func (*PipelineRuntime) ProtoMessage 

func (*PipelineRuntime) ProtoMessage()

func (*PipelineRuntime) ProtoReflect 

func (x *PipelineRuntime) ProtoReflect() protoreflect.Message

func (*PipelineRuntime) Reset 

func (x *PipelineRuntime) Reset()

func (*PipelineRuntime) String 

func (x *PipelineRuntime) String() string

type PipelineServiceClient 

type PipelineServiceClient interface {
	// Creates a pipeline.
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*Pipeline, error)
	// Finds a specific pipeline by ID.
	GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*Pipeline, error)
	// Finds all pipelines.
	ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error)
	// Deletes a pipeline and its pipeline versions.
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Returns a single YAML template that contains the description, parameters, and metadata associated with the pipeline provided.
	GetTemplate(ctx context.Context, in *GetTemplateRequest, opts ...grpc.CallOption) (*GetTemplateResponse, error)
	// Adds a pipeline version to the specified pipeline.
	CreatePipelineVersion(ctx context.Context, in *CreatePipelineVersionRequest, opts ...grpc.CallOption) (*PipelineVersion, error)
	// Gets a pipeline version by pipeline version ID.
	GetPipelineVersion(ctx context.Context, in *GetPipelineVersionRequest, opts ...grpc.CallOption) (*PipelineVersion, error)
	// Lists all pipeline versions of a given pipeline.
	ListPipelineVersions(ctx context.Context, in *ListPipelineVersionsRequest, opts ...grpc.CallOption) (*ListPipelineVersionsResponse, error)
	// Deletes a pipeline version by pipeline version ID. If the deleted pipeline
	// version is the default pipeline version, the pipeline's default version
	// changes to the pipeline's most recent pipeline version. If there are no
	// remaining pipeline versions, the pipeline will have no default version.
	// Examines the run_service_api.ipynb notebook to learn more about creating a
	// run using a pipeline version (https://github.com/kubeflow/pipelines/blob/master/tools/benchmarks/run_service_api.ipynb).
	DeletePipelineVersion(ctx context.Context, in *DeletePipelineVersionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Returns a YAML template that contains the specified pipeline version's description, parameters and metadata.
	GetPipelineVersionTemplate(ctx context.Context, in *GetPipelineVersionTemplateRequest, opts ...grpc.CallOption) (*GetTemplateResponse, error)
	// Update the default pipeline version of a specific pipeline.
	UpdatePipelineDefaultVersion(ctx context.Context, in *UpdatePipelineDefaultVersionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

PipelineServiceClient is the client API for PipelineService service.

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

func NewPipelineServiceClient 

func NewPipelineServiceClient(cc grpc.ClientConnInterface) PipelineServiceClient

type PipelineServiceServer 

type PipelineServiceServer interface {
	// Creates a pipeline.
	CreatePipeline(context.Context, *CreatePipelineRequest) (*Pipeline, error)
	// Finds a specific pipeline by ID.
	GetPipeline(context.Context, *GetPipelineRequest) (*Pipeline, error)
	// Finds all pipelines.
	ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error)
	// Deletes a pipeline and its pipeline versions.
	DeletePipeline(context.Context, *DeletePipelineRequest) (*emptypb.Empty, error)
	// Returns a single YAML template that contains the description, parameters, and metadata associated with the pipeline provided.
	GetTemplate(context.Context, *GetTemplateRequest) (*GetTemplateResponse, error)
	// Adds a pipeline version to the specified pipeline.
	CreatePipelineVersion(context.Context, *CreatePipelineVersionRequest) (*PipelineVersion, error)
	// Gets a pipeline version by pipeline version ID.
	GetPipelineVersion(context.Context, *GetPipelineVersionRequest) (*PipelineVersion, error)
	// Lists all pipeline versions of a given pipeline.
	ListPipelineVersions(context.Context, *ListPipelineVersionsRequest) (*ListPipelineVersionsResponse, error)
	// Deletes a pipeline version by pipeline version ID. If the deleted pipeline
	// version is the default pipeline version, the pipeline's default version
	// changes to the pipeline's most recent pipeline version. If there are no
	// remaining pipeline versions, the pipeline will have no default version.
	// Examines the run_service_api.ipynb notebook to learn more about creating a
	// run using a pipeline version (https://github.com/kubeflow/pipelines/blob/master/tools/benchmarks/run_service_api.ipynb).
	DeletePipelineVersion(context.Context, *DeletePipelineVersionRequest) (*emptypb.Empty, error)
	// Returns a YAML template that contains the specified pipeline version's description, parameters and metadata.
	GetPipelineVersionTemplate(context.Context, *GetPipelineVersionTemplateRequest) (*GetTemplateResponse, error)
	// Update the default pipeline version of a specific pipeline.
	UpdatePipelineDefaultVersion(context.Context, *UpdatePipelineDefaultVersionRequest) (*emptypb.Empty, error)
}

PipelineServiceServer is the server API for PipelineService service.

type PipelineSpec 

type PipelineSpec struct {

	// Optional input field. The ID of the pipeline user uploaded before.
	PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// Optional output field. The name of the pipeline.
	// Not empty if the pipeline id is not empty.
	PipelineName string `protobuf:"bytes,5,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"`
	// Optional input field. The marshalled raw argo JSON workflow.
	// This will be deprecated when pipeline_manifest is in use.
	WorkflowManifest string `protobuf:"bytes,2,opt,name=workflow_manifest,json=workflowManifest,proto3" json:"workflow_manifest,omitempty"`
	// Optional input field. The raw pipeline JSON spec.
	PipelineManifest string `protobuf:"bytes,3,opt,name=pipeline_manifest,json=pipelineManifest,proto3" json:"pipeline_manifest,omitempty"`
	// The parameter user provide to inject to the pipeline JSON.
	// If a default value of a parameter exist in the JSON,
	// the value user provided here will replace.
	Parameters []*Parameter `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineSpec) Descriptor deprecated 

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

Deprecated: Use PipelineSpec.ProtoReflect.Descriptor instead.

func (*PipelineSpec) GetParameters 

func (x *PipelineSpec) GetParameters() []*Parameter

func (*PipelineSpec) GetPipelineId 

func (x *PipelineSpec) GetPipelineId() string

func (*PipelineSpec) GetPipelineManifest 

func (x *PipelineSpec) GetPipelineManifest() string

func (*PipelineSpec) GetPipelineName 

func (x *PipelineSpec) GetPipelineName() string

func (*PipelineSpec) GetWorkflowManifest 

func (x *PipelineSpec) GetWorkflowManifest() string

func (*PipelineSpec) ProtoMessage 

func (*PipelineSpec) ProtoMessage()

func (*PipelineSpec) ProtoReflect 

func (x *PipelineSpec) ProtoReflect() protoreflect.Message

func (*PipelineSpec) Reset 

func (x *PipelineSpec) Reset()

func (*PipelineSpec) String 

func (x *PipelineSpec) String() string

type PipelineVersion 

type PipelineVersion struct {

	// Output. Unique version ID. Generated by API server.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Optional input field. Version name provided by user.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Output. The time this pipeline version is created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Output. The input parameters for this pipeline.
	Parameters []*Parameter `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// Input. Optional. Pipeline version code source.
	CodeSourceUrl string `protobuf:"bytes,5,opt,name=code_source_url,json=codeSourceUrl,proto3" json:"code_source_url,omitempty"`
	// Input. Required. Pipeline version package url.
	// Whe calling CreatePipelineVersion API method, need to provide one package
	// file location.
	PackageUrl *Url `protobuf:"bytes,6,opt,name=package_url,json=packageUrl,proto3" json:"package_url,omitempty"`
	// Input field. Specify which resource this pipeline version belongs to.
	// For Experiment, the only valid resource reference is a single Namespace.
	ResourceReferences []*ResourceReference `protobuf:"bytes,7,rep,name=resource_references,json=resourceReferences,proto3" json:"resource_references,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineVersion) Descriptor deprecated 

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

Deprecated: Use PipelineVersion.ProtoReflect.Descriptor instead.

func (*PipelineVersion) GetCodeSourceUrl 

func (x *PipelineVersion) GetCodeSourceUrl() string

func (*PipelineVersion) GetCreatedAt 

func (x *PipelineVersion) GetCreatedAt() *timestamppb.Timestamp

func (*PipelineVersion) GetId 

func (x *PipelineVersion) GetId() string

func (*PipelineVersion) GetName 

func (x *PipelineVersion) GetName() string

func (*PipelineVersion) GetPackageUrl 

func (x *PipelineVersion) GetPackageUrl() *Url

func (*PipelineVersion) GetParameters 

func (x *PipelineVersion) GetParameters() []*Parameter

func (*PipelineVersion) GetResourceReferences 

func (x *PipelineVersion) GetResourceReferences() []*ResourceReference

func (*PipelineVersion) ProtoMessage 

func (*PipelineVersion) ProtoMessage()

func (*PipelineVersion) ProtoReflect 

func (x *PipelineVersion) ProtoReflect() protoreflect.Message

func (*PipelineVersion) Reset 

func (x *PipelineVersion) Reset()

func (*PipelineVersion) String 

func (x *PipelineVersion) String() string

type Predicate 

type Predicate struct {
	Op  Predicate_Op `protobuf:"varint,1,opt,name=op,proto3,enum=api.Predicate_Op" json:"op,omitempty"`
	Key string       `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Value:
	//	*Predicate_IntValue
	//	*Predicate_LongValue
	//	*Predicate_StringValue
	//	*Predicate_TimestampValue
	//	*Predicate_IntValues
	//	*Predicate_LongValues
	//	*Predicate_StringValues
	Value isPredicate_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

Predicate captures individual conditions that must be true for a resource being filtered.

func (*Predicate) Descriptor deprecated 

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

Deprecated: Use Predicate.ProtoReflect.Descriptor instead.

func (*Predicate) GetIntValue 

func (x *Predicate) GetIntValue() int32

func (*Predicate) GetIntValues 

func (x *Predicate) GetIntValues() *IntValues

func (*Predicate) GetKey 

func (x *Predicate) GetKey() string

func (*Predicate) GetLongValue 

func (x *Predicate) GetLongValue() int64

func (*Predicate) GetLongValues 

func (x *Predicate) GetLongValues() *LongValues

func (*Predicate) GetOp 

func (x *Predicate) GetOp() Predicate_Op

func (*Predicate) GetStringValue 

func (x *Predicate) GetStringValue() string

func (*Predicate) GetStringValues 

func (x *Predicate) GetStringValues() *StringValues

func (*Predicate) GetTimestampValue 

func (x *Predicate) GetTimestampValue() *timestamppb.Timestamp

func (*Predicate) GetValue 

func (m *Predicate) GetValue() isPredicate_Value

func (*Predicate) ProtoMessage 

func (*Predicate) ProtoMessage()

func (*Predicate) ProtoReflect 

func (x *Predicate) ProtoReflect() protoreflect.Message

func (*Predicate) Reset 

func (x *Predicate) Reset()

func (*Predicate) String 

func (x *Predicate) String() string

type Predicate_IntValue 

type Predicate_IntValue struct {
	IntValue int32 `protobuf:"varint,3,opt,name=int_value,json=intValue,proto3,oneof"`
}

type Predicate_IntValues 

type Predicate_IntValues struct {
	// Array values below are only meant to be used by the IN operator.
	IntValues *IntValues `protobuf:"bytes,7,opt,name=int_values,json=intValues,proto3,oneof"`
}

type Predicate_LongValue 

type Predicate_LongValue struct {
	LongValue int64 `protobuf:"varint,4,opt,name=long_value,json=longValue,proto3,oneof"`
}

type Predicate_LongValues 

type Predicate_LongValues struct {
	LongValues *LongValues `protobuf:"bytes,8,opt,name=long_values,json=longValues,proto3,oneof"`
}

type Predicate_Op 

type Predicate_Op int32

Op is the operation to apply. 

const (
	Predicate_UNKNOWN Predicate_Op = 0
	// Operators on scalar values. Only applies to one of |int_value|,
	// |long_value|, |string_value| or |timestamp_value|.
	Predicate_EQUALS              Predicate_Op = 1
	Predicate_NOT_EQUALS          Predicate_Op = 2
	Predicate_GREATER_THAN        Predicate_Op = 3
	Predicate_GREATER_THAN_EQUALS Predicate_Op = 5
	Predicate_LESS_THAN           Predicate_Op = 6
	Predicate_LESS_THAN_EQUALS    Predicate_Op = 7
	// Checks if the value is a member of a given array, which should be one of
	// |int_values|, |long_values| or |string_values|.
	Predicate_IN Predicate_Op = 8
	// Checks if the value contains |string_value| as a substring match. Only
	// applies to |string_value|.
	Predicate_IS_SUBSTRING Predicate_Op = 9
)

func (Predicate_Op) Descriptor 

func (Predicate_Op) Descriptor() protoreflect.EnumDescriptor

func (Predicate_Op) Enum 

func (x Predicate_Op) Enum() *Predicate_Op

func (Predicate_Op) EnumDescriptor deprecated 

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

Deprecated: Use Predicate_Op.Descriptor instead.

func (Predicate_Op) Number 

func (x Predicate_Op) Number() protoreflect.EnumNumber

func (Predicate_Op) String 

func (x Predicate_Op) String() string

func (Predicate_Op) Type 

func (Predicate_Op) Type() protoreflect.EnumType

type Predicate_StringValue 

type Predicate_StringValue struct {
	StringValue string `protobuf:"bytes,5,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Predicate_StringValues 

type Predicate_StringValues struct {
	StringValues *StringValues `protobuf:"bytes,9,opt,name=string_values,json=stringValues,proto3,oneof"`
}

type Predicate_TimestampValue 

type Predicate_TimestampValue struct {
	// Timestamp values will be converted to Unix time (seconds since the epoch)
	// prior to being used in a filtering operation.
	TimestampValue *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

type ReadArtifactRequest 

type ReadArtifactRequest struct {

	// The ID of the run.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// The ID of the running node.
	NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// The name of the artifact.
	ArtifactName string `protobuf:"bytes,3,opt,name=artifact_name,json=artifactName,proto3" json:"artifact_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadArtifactRequest) Descriptor deprecated 

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

Deprecated: Use ReadArtifactRequest.ProtoReflect.Descriptor instead.

func (*ReadArtifactRequest) GetArtifactName 

func (x *ReadArtifactRequest) GetArtifactName() string

func (*ReadArtifactRequest) GetNodeId 

func (x *ReadArtifactRequest) GetNodeId() string

func (*ReadArtifactRequest) GetRunId 

func (x *ReadArtifactRequest) GetRunId() string

func (*ReadArtifactRequest) ProtoMessage 

func (*ReadArtifactRequest) ProtoMessage()

func (*ReadArtifactRequest) ProtoReflect 

func (x *ReadArtifactRequest) ProtoReflect() protoreflect.Message

func (*ReadArtifactRequest) Reset 

func (x *ReadArtifactRequest) Reset()

func (*ReadArtifactRequest) String 

func (x *ReadArtifactRequest) String() string

type ReadArtifactResponse 

type ReadArtifactResponse struct {

	// The bytes of the artifact content.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadArtifactResponse) Descriptor deprecated 

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

Deprecated: Use ReadArtifactResponse.ProtoReflect.Descriptor instead.

func (*ReadArtifactResponse) GetData 

func (x *ReadArtifactResponse) GetData() []byte

func (*ReadArtifactResponse) ProtoMessage 

func (*ReadArtifactResponse) ProtoMessage()

func (*ReadArtifactResponse) ProtoReflect 

func (x *ReadArtifactResponse) ProtoReflect() protoreflect.Message

func (*ReadArtifactResponse) Reset 

func (x *ReadArtifactResponse) Reset()

func (*ReadArtifactResponse) String 

func (x *ReadArtifactResponse) String() string

type Relationship 

type Relationship int32
const (
	Relationship_UNKNOWN_RELATIONSHIP Relationship = 0
	Relationship_OWNER                Relationship = 1
	Relationship_CREATOR              Relationship = 2
)

func (Relationship) Descriptor 

func (Relationship) Descriptor() protoreflect.EnumDescriptor

func (Relationship) Enum 

func (x Relationship) Enum() *Relationship

func (Relationship) EnumDescriptor deprecated 

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

Deprecated: Use Relationship.Descriptor instead.

func (Relationship) Number 

func (x Relationship) Number() protoreflect.EnumNumber

func (Relationship) String 

func (x Relationship) String() string

func (Relationship) Type 

func (Relationship) Type() protoreflect.EnumType

type ReportRunMetricsRequest 

type ReportRunMetricsRequest struct {

	// Required. The parent run ID of the metric.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// List of metrics to report.
	Metrics []*RunMetric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportRunMetricsRequest) Descriptor deprecated 

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

Deprecated: Use ReportRunMetricsRequest.ProtoReflect.Descriptor instead.

func (*ReportRunMetricsRequest) GetMetrics 

func (x *ReportRunMetricsRequest) GetMetrics() []*RunMetric

func (*ReportRunMetricsRequest) GetRunId 

func (x *ReportRunMetricsRequest) GetRunId() string

func (*ReportRunMetricsRequest) ProtoMessage 

func (*ReportRunMetricsRequest) ProtoMessage()

func (*ReportRunMetricsRequest) ProtoReflect 

func (x *ReportRunMetricsRequest) ProtoReflect() protoreflect.Message

func (*ReportRunMetricsRequest) Reset 

func (x *ReportRunMetricsRequest) Reset()

func (*ReportRunMetricsRequest) String 

func (x *ReportRunMetricsRequest) String() string

type ReportRunMetricsResponse 

type ReportRunMetricsResponse struct {
	Results []*ReportRunMetricsResponse_ReportRunMetricResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportRunMetricsResponse) Descriptor deprecated 

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

Deprecated: Use ReportRunMetricsResponse.ProtoReflect.Descriptor instead.

func (*ReportRunMetricsResponse) GetResults 

func (x *ReportRunMetricsResponse) GetResults() []*ReportRunMetricsResponse_ReportRunMetricResult

func (*ReportRunMetricsResponse) ProtoMessage 

func (*ReportRunMetricsResponse) ProtoMessage()

func (*ReportRunMetricsResponse) ProtoReflect 

func (x *ReportRunMetricsResponse) ProtoReflect() protoreflect.Message

func (*ReportRunMetricsResponse) Reset 

func (x *ReportRunMetricsResponse) Reset()

func (*ReportRunMetricsResponse) String 

func (x *ReportRunMetricsResponse) String() string

type ReportRunMetricsResponse_ReportRunMetricResult 

type ReportRunMetricsResponse_ReportRunMetricResult struct {

	// Output. The name of the metric.
	MetricName string `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	// Output. The ID of the node which reports the metric.
	MetricNodeId string `protobuf:"bytes,2,opt,name=metric_node_id,json=metricNodeId,proto3" json:"metric_node_id,omitempty"`
	// Output. The status of the metric reporting.
	Status ReportRunMetricsResponse_ReportRunMetricResult_Status `` /* 129-byte string literal not displayed */
	// Output. The detailed message of the error of the reporting.
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportRunMetricsResponse_ReportRunMetricResult) Descriptor deprecated 

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

Deprecated: Use ReportRunMetricsResponse_ReportRunMetricResult.ProtoReflect.Descriptor instead.

func (*ReportRunMetricsResponse_ReportRunMetricResult) GetMessage 

func (x *ReportRunMetricsResponse_ReportRunMetricResult) GetMessage() string

func (*ReportRunMetricsResponse_ReportRunMetricResult) GetMetricName 

func (x *ReportRunMetricsResponse_ReportRunMetricResult) GetMetricName() string

func (*ReportRunMetricsResponse_ReportRunMetricResult) GetMetricNodeId 

func (x *ReportRunMetricsResponse_ReportRunMetricResult) GetMetricNodeId() string

func (*ReportRunMetricsResponse_ReportRunMetricResult) GetStatus 

func (x *ReportRunMetricsResponse_ReportRunMetricResult) GetStatus() ReportRunMetricsResponse_ReportRunMetricResult_Status

func (*ReportRunMetricsResponse_ReportRunMetricResult) ProtoMessage 

func (*ReportRunMetricsResponse_ReportRunMetricResult) ProtoMessage()

func (*ReportRunMetricsResponse_ReportRunMetricResult) ProtoReflect 

func (x *ReportRunMetricsResponse_ReportRunMetricResult) ProtoReflect() protoreflect.Message

func (*ReportRunMetricsResponse_ReportRunMetricResult) Reset 

func (x *ReportRunMetricsResponse_ReportRunMetricResult) Reset()

func (*ReportRunMetricsResponse_ReportRunMetricResult) String 

func (x *ReportRunMetricsResponse_ReportRunMetricResult) String() string

type ReportRunMetricsResponse_ReportRunMetricResult_Status 

type ReportRunMetricsResponse_ReportRunMetricResult_Status int32
const (
	// Default value if not present.
	ReportRunMetricsResponse_ReportRunMetricResult_UNSPECIFIED ReportRunMetricsResponse_ReportRunMetricResult_Status = 0
	// Indicates successful reporting.
	ReportRunMetricsResponse_ReportRunMetricResult_OK ReportRunMetricsResponse_ReportRunMetricResult_Status = 1
	// Indicates that the payload of the metric is invalid.
	ReportRunMetricsResponse_ReportRunMetricResult_INVALID_ARGUMENT ReportRunMetricsResponse_ReportRunMetricResult_Status = 2
	// Indicates that the metric has been reported before.
	ReportRunMetricsResponse_ReportRunMetricResult_DUPLICATE_REPORTING ReportRunMetricsResponse_ReportRunMetricResult_Status = 3
	// Indicates that something went wrong in the server.
	ReportRunMetricsResponse_ReportRunMetricResult_INTERNAL_ERROR ReportRunMetricsResponse_ReportRunMetricResult_Status = 4
)

func (ReportRunMetricsResponse_ReportRunMetricResult_Status) Descriptor 

func (ReportRunMetricsResponse_ReportRunMetricResult_Status) Descriptor() protoreflect.EnumDescriptor

func (ReportRunMetricsResponse_ReportRunMetricResult_Status) Enum 

func (x ReportRunMetricsResponse_ReportRunMetricResult_Status) Enum() *ReportRunMetricsResponse_ReportRunMetricResult_Status

func (ReportRunMetricsResponse_ReportRunMetricResult_Status) EnumDescriptor deprecated 

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

Deprecated: Use ReportRunMetricsResponse_ReportRunMetricResult_Status.Descriptor instead.

func (ReportRunMetricsResponse_ReportRunMetricResult_Status) Number 

func (x ReportRunMetricsResponse_ReportRunMetricResult_Status) Number() protoreflect.EnumNumber

func (ReportRunMetricsResponse_ReportRunMetricResult_Status) String 

func (x ReportRunMetricsResponse_ReportRunMetricResult_Status) String() string

func (ReportRunMetricsResponse_ReportRunMetricResult_Status) Type 

func (ReportRunMetricsResponse_ReportRunMetricResult_Status) Type() protoreflect.EnumType

type ReportScheduledWorkflowRequest 

type ReportScheduledWorkflowRequest struct {

	// ScheduledWorkflow a ScheduledWorkflow resource marshalled into a json string.
	ScheduledWorkflow string `protobuf:"bytes,1,opt,name=scheduled_workflow,json=scheduledWorkflow,proto3" json:"scheduled_workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportScheduledWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use ReportScheduledWorkflowRequest.ProtoReflect.Descriptor instead.

func (*ReportScheduledWorkflowRequest) GetScheduledWorkflow 

func (x *ReportScheduledWorkflowRequest) GetScheduledWorkflow() string

func (*ReportScheduledWorkflowRequest) ProtoMessage 

func (*ReportScheduledWorkflowRequest) ProtoMessage()

func (*ReportScheduledWorkflowRequest) ProtoReflect 

func (x *ReportScheduledWorkflowRequest) ProtoReflect() protoreflect.Message

func (*ReportScheduledWorkflowRequest) Reset 

func (x *ReportScheduledWorkflowRequest) Reset()

func (*ReportScheduledWorkflowRequest) String 

func (x *ReportScheduledWorkflowRequest) String() string

type ReportServiceClient 

type ReportServiceClient interface {
	ReportWorkflow(ctx context.Context, in *ReportWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReportScheduledWorkflow(ctx context.Context, in *ReportScheduledWorkflowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ReportServiceClient is the client API for ReportService service.

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

func NewReportServiceClient 

func NewReportServiceClient(cc grpc.ClientConnInterface) ReportServiceClient

type ReportServiceServer 

type ReportServiceServer interface {
	ReportWorkflow(context.Context, *ReportWorkflowRequest) (*emptypb.Empty, error)
	ReportScheduledWorkflow(context.Context, *ReportScheduledWorkflowRequest) (*emptypb.Empty, error)
}

ReportServiceServer is the server API for ReportService service.

type ReportWorkflowRequest 

type ReportWorkflowRequest struct {

	// Workflow is a workflow custom resource marshalled into a json string.
	Workflow string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use ReportWorkflowRequest.ProtoReflect.Descriptor instead.

func (*ReportWorkflowRequest) GetWorkflow 

func (x *ReportWorkflowRequest) GetWorkflow() string

func (*ReportWorkflowRequest) ProtoMessage 

func (*ReportWorkflowRequest) ProtoMessage()

func (*ReportWorkflowRequest) ProtoReflect 

func (x *ReportWorkflowRequest) ProtoReflect() protoreflect.Message

func (*ReportWorkflowRequest) Reset 

func (x *ReportWorkflowRequest) Reset()

func (*ReportWorkflowRequest) String 

func (x *ReportWorkflowRequest) String() string

type ResourceKey 

type ResourceKey struct {

	// The type of the resource that referred to.
	Type ResourceType `protobuf:"varint,1,opt,name=type,proto3,enum=api.ResourceType" json:"type,omitempty"`
	// The ID of the resource that referred to.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceKey) Descriptor deprecated 

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

Deprecated: Use ResourceKey.ProtoReflect.Descriptor instead.

func (*ResourceKey) GetId 

func (x *ResourceKey) GetId() string

func (*ResourceKey) GetType 

func (x *ResourceKey) GetType() ResourceType

func (*ResourceKey) ProtoMessage 

func (*ResourceKey) ProtoMessage()

func (*ResourceKey) ProtoReflect 

func (x *ResourceKey) ProtoReflect() protoreflect.Message

func (*ResourceKey) Reset 

func (x *ResourceKey) Reset()

func (*ResourceKey) String 

func (x *ResourceKey) String() string

type ResourceReference 

type ResourceReference struct {
	Key *ResourceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The name of the resource that referred to.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Required field. The relationship from referred resource to the object.
	Relationship Relationship `protobuf:"varint,2,opt,name=relationship,proto3,enum=api.Relationship" json:"relationship,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceReference) Descriptor deprecated 

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

Deprecated: Use ResourceReference.ProtoReflect.Descriptor instead.

func (*ResourceReference) GetKey 

func (x *ResourceReference) GetKey() *ResourceKey

func (*ResourceReference) GetName 

func (x *ResourceReference) GetName() string

func (*ResourceReference) GetRelationship 

func (x *ResourceReference) GetRelationship() Relationship

func (*ResourceReference) ProtoMessage 

func (*ResourceReference) ProtoMessage()

func (*ResourceReference) ProtoReflect 

func (x *ResourceReference) ProtoReflect() protoreflect.Message

func (*ResourceReference) Reset 

func (x *ResourceReference) Reset()

func (*ResourceReference) String 

func (x *ResourceReference) String() string

type ResourceType 

type ResourceType int32
const (
	ResourceType_UNKNOWN_RESOURCE_TYPE ResourceType = 0
	ResourceType_EXPERIMENT            ResourceType = 1
	ResourceType_JOB                   ResourceType = 2
	ResourceType_PIPELINE              ResourceType = 3
	ResourceType_PIPELINE_VERSION      ResourceType = 4
	ResourceType_NAMESPACE             ResourceType = 5
)

func (ResourceType) Descriptor 

func (ResourceType) Descriptor() protoreflect.EnumDescriptor

func (ResourceType) Enum 

func (x ResourceType) Enum() *ResourceType

func (ResourceType) EnumDescriptor deprecated 

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

Deprecated: Use ResourceType.Descriptor instead.

func (ResourceType) Number 

func (x ResourceType) Number() protoreflect.EnumNumber

func (ResourceType) String 

func (x ResourceType) String() string

func (ResourceType) Type 

func (ResourceType) Type() protoreflect.EnumType

type RetryRunRequest 

type RetryRunRequest struct {

	// The ID of the run to be retried.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryRunRequest) Descriptor deprecated 

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

Deprecated: Use RetryRunRequest.ProtoReflect.Descriptor instead.

func (*RetryRunRequest) GetRunId 

func (x *RetryRunRequest) GetRunId() string

func (*RetryRunRequest) ProtoMessage 

func (*RetryRunRequest) ProtoMessage()

func (*RetryRunRequest) ProtoReflect 

func (x *RetryRunRequest) ProtoReflect() protoreflect.Message

func (*RetryRunRequest) Reset 

func (x *RetryRunRequest) Reset()

func (*RetryRunRequest) String 

func (x *RetryRunRequest) String() string

type Run 

type Run struct {

	// Output. Unique run ID. Generated by API server.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Required input field. Name provided by user,
	// or auto generated if run is created by scheduled job. Not unique.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Output. Specify whether this run is in archived or available mode.
	StorageState Run_StorageState `protobuf:"varint,10,opt,name=storage_state,json=storageState,proto3,enum=api.Run_StorageState" json:"storage_state,omitempty"`
	// Optional input field. Describing the purpose of the run
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Required input field.
	// Describing what the pipeline manifest and parameters to use for the run.
	PipelineSpec *PipelineSpec `protobuf:"bytes,4,opt,name=pipeline_spec,json=pipelineSpec,proto3" json:"pipeline_spec,omitempty"`
	// Optional input field. Specify which resource this run belongs to.
	// When creating a run from a particular pipeline version, the pipeline
	// version can be specified here.
	ResourceReferences []*ResourceReference `protobuf:"bytes,5,rep,name=resource_references,json=resourceReferences,proto3" json:"resource_references,omitempty"`
	// Optional input field. Specify which Kubernetes service account this run uses.
	ServiceAccount string `protobuf:"bytes,14,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Output. The time that the run created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Output. When this run is scheduled to run. This could be different from
	// created_at. For example, if a run is from a backfilling job that was
	// supposed to run 2 month ago, the scheduled_at is 2 month ago,
	// v.s. created_at is the current time.
	ScheduledAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	// Output. The time this run is finished.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// Output. The status of the run.
	// One of [Pending, Running, Succeeded, Skipped, Failed, Error]
	Status string `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	// In case any error happens retrieving a run field, only run ID
	// and the error message is returned. Client has the flexibility of choosing
	// how to handle error. This is especially useful during listing call.
	Error string `protobuf:"bytes,12,opt,name=error,proto3" json:"error,omitempty"`
	// Output. The metrics of the run. The metrics are reported by ReportMetrics
	// API.
	Metrics []*RunMetric `protobuf:"bytes,9,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*Run) Descriptor deprecated 

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

Deprecated: Use Run.ProtoReflect.Descriptor instead.

func (*Run) GetCreatedAt 

func (x *Run) GetCreatedAt() *timestamppb.Timestamp

func (*Run) GetDescription 

func (x *Run) GetDescription() string

func (*Run) GetError 

func (x *Run) GetError() string

func (*Run) GetFinishedAt 

func (x *Run) GetFinishedAt() *timestamppb.Timestamp

func (*Run) GetId 

func (x *Run) GetId() string

func (*Run) GetMetrics 

func (x *Run) GetMetrics() []*RunMetric

func (*Run) GetName 

func (x *Run) GetName() string

func (*Run) GetPipelineSpec 

func (x *Run) GetPipelineSpec() *PipelineSpec

func (*Run) GetResourceReferences 

func (x *Run) GetResourceReferences() []*ResourceReference

func (*Run) GetScheduledAt 

func (x *Run) GetScheduledAt() *timestamppb.Timestamp

func (*Run) GetServiceAccount 

func (x *Run) GetServiceAccount() string

func (*Run) GetStatus 

func (x *Run) GetStatus() string

func (*Run) GetStorageState 

func (x *Run) GetStorageState() Run_StorageState

func (*Run) ProtoMessage 

func (*Run) ProtoMessage()

func (*Run) ProtoReflect 

func (x *Run) ProtoReflect() protoreflect.Message

func (*Run) Reset 

func (x *Run) Reset()

func (*Run) String 

func (x *Run) String() string

type RunDetail 

type RunDetail struct {
	Run             *Run             `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	PipelineRuntime *PipelineRuntime `protobuf:"bytes,2,opt,name=pipeline_runtime,json=pipelineRuntime,proto3" json:"pipeline_runtime,omitempty"`
	// contains filtered or unexported fields
}

func (*RunDetail) Descriptor deprecated 

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

Deprecated: Use RunDetail.ProtoReflect.Descriptor instead.

func (*RunDetail) GetPipelineRuntime 

func (x *RunDetail) GetPipelineRuntime() *PipelineRuntime

func (*RunDetail) GetRun 

func (x *RunDetail) GetRun() *Run

func (*RunDetail) ProtoMessage 

func (*RunDetail) ProtoMessage()

func (*RunDetail) ProtoReflect 

func (x *RunDetail) ProtoReflect() protoreflect.Message

func (*RunDetail) Reset 

func (x *RunDetail) Reset()

func (*RunDetail) String 

func (x *RunDetail) String() string

type RunMetric 

type RunMetric struct {

	// Required. The user defined name of the metric. It must between 1 and 63
	// characters long and must conform to the following regular expression:
	// `[a-z]([-a-z0-9]*[a-z0-9])?`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The runtime node ID which reports the metric. The node ID can be
	// found in the RunDetail.workflow.Status. Metric with same (node_id, name)
	// are considerd as duplicate. Only the first reporting will be recorded. Max
	// length is 128.
	NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Types that are assignable to Value:
	//	*RunMetric_NumberValue
	Value isRunMetric_Value `protobuf_oneof:"value"`
	// The display format of metric.
	Format RunMetric_Format `protobuf:"varint,4,opt,name=format,proto3,enum=api.RunMetric_Format" json:"format,omitempty"`
	// contains filtered or unexported fields
}

func (*RunMetric) Descriptor deprecated 

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

Deprecated: Use RunMetric.ProtoReflect.Descriptor instead.

func (*RunMetric) GetFormat 

func (x *RunMetric) GetFormat() RunMetric_Format

func (*RunMetric) GetName 

func (x *RunMetric) GetName() string

func (*RunMetric) GetNodeId 

func (x *RunMetric) GetNodeId() string

func (*RunMetric) GetNumberValue 

func (x *RunMetric) GetNumberValue() float64

func (*RunMetric) GetValue 

func (m *RunMetric) GetValue() isRunMetric_Value

func (*RunMetric) ProtoMessage 

func (*RunMetric) ProtoMessage()

func (*RunMetric) ProtoReflect 

func (x *RunMetric) ProtoReflect() protoreflect.Message

func (*RunMetric) Reset 

func (x *RunMetric) Reset()

func (*RunMetric) String 

func (x *RunMetric) String() string

type RunMetric_Format 

type RunMetric_Format int32
const (
	// Default value if not present.
	RunMetric_UNSPECIFIED RunMetric_Format = 0
	// Display value as its raw format.
	RunMetric_RAW RunMetric_Format = 1
	// Display value in percentage format.
	RunMetric_PERCENTAGE RunMetric_Format = 2
)

func (RunMetric_Format) Descriptor 

func (RunMetric_Format) Descriptor() protoreflect.EnumDescriptor

func (RunMetric_Format) Enum 

func (x RunMetric_Format) Enum() *RunMetric_Format

func (RunMetric_Format) EnumDescriptor deprecated 

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

Deprecated: Use RunMetric_Format.Descriptor instead.

func (RunMetric_Format) Number 

func (x RunMetric_Format) Number() protoreflect.EnumNumber

func (RunMetric_Format) String 

func (x RunMetric_Format) String() string

func (RunMetric_Format) Type 

func (RunMetric_Format) Type() protoreflect.EnumType

type RunMetric_NumberValue 

type RunMetric_NumberValue struct {
	// The number value of the metric.
	NumberValue float64 `protobuf:"fixed64,3,opt,name=number_value,json=numberValue,proto3,oneof"`
}

type RunServiceClient 

type RunServiceClient interface {
	// Creates a new run.
	CreateRun(ctx context.Context, in *CreateRunRequest, opts ...grpc.CallOption) (*RunDetail, error)
	// Finds a specific run by ID.
	GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*RunDetail, error)
	// Finds all runs.
	ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	// Archives a run.
	ArchiveRun(ctx context.Context, in *ArchiveRunRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Restores an archived run.
	UnarchiveRun(ctx context.Context, in *UnarchiveRunRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deletes a run.
	DeleteRun(ctx context.Context, in *DeleteRunRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ReportRunMetrics reports metrics of a run. Each metric is reported in its
	// own transaction, so this API accepts partial failures. Metric can be
	// uniquely identified by (run_id, node_id, name). Duplicate reporting will be
	// ignored by the API. First reporting wins.
	ReportRunMetrics(ctx context.Context, in *ReportRunMetricsRequest, opts ...grpc.CallOption) (*ReportRunMetricsResponse, error)
	// Finds a run's artifact data.
	ReadArtifact(ctx context.Context, in *ReadArtifactRequest, opts ...grpc.CallOption) (*ReadArtifactResponse, error)
	// Terminates an active run.
	TerminateRun(ctx context.Context, in *TerminateRunRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Re-initiates a failed or terminated run.
	RetryRun(ctx context.Context, in *RetryRunRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

RunServiceClient is the client API for RunService service.

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

func NewRunServiceClient 

func NewRunServiceClient(cc grpc.ClientConnInterface) RunServiceClient

type RunServiceServer 

type RunServiceServer interface {
	// Creates a new run.
	CreateRun(context.Context, *CreateRunRequest) (*RunDetail, error)
	// Finds a specific run by ID.
	GetRun(context.Context, *GetRunRequest) (*RunDetail, error)
	// Finds all runs.
	ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
	// Archives a run.
	ArchiveRun(context.Context, *ArchiveRunRequest) (*emptypb.Empty, error)
	// Restores an archived run.
	UnarchiveRun(context.Context, *UnarchiveRunRequest) (*emptypb.Empty, error)
	// Deletes a run.
	DeleteRun(context.Context, *DeleteRunRequest) (*emptypb.Empty, error)
	// ReportRunMetrics reports metrics of a run. Each metric is reported in its
	// own transaction, so this API accepts partial failures. Metric can be
	// uniquely identified by (run_id, node_id, name). Duplicate reporting will be
	// ignored by the API. First reporting wins.
	ReportRunMetrics(context.Context, *ReportRunMetricsRequest) (*ReportRunMetricsResponse, error)
	// Finds a run's artifact data.
	ReadArtifact(context.Context, *ReadArtifactRequest) (*ReadArtifactResponse, error)
	// Terminates an active run.
	TerminateRun(context.Context, *TerminateRunRequest) (*emptypb.Empty, error)
	// Re-initiates a failed or terminated run.
	RetryRun(context.Context, *RetryRunRequest) (*emptypb.Empty, error)
}

RunServiceServer is the server API for RunService service.

type Run_StorageState 

type Run_StorageState int32
const (
	Run_STORAGESTATE_AVAILABLE Run_StorageState = 0
	Run_STORAGESTATE_ARCHIVED  Run_StorageState = 1
)

func (Run_StorageState) Descriptor 

func (Run_StorageState) Descriptor() protoreflect.EnumDescriptor

func (Run_StorageState) Enum 

func (x Run_StorageState) Enum() *Run_StorageState

func (Run_StorageState) EnumDescriptor deprecated 

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

Deprecated: Use Run_StorageState.Descriptor instead.

func (Run_StorageState) Number 

func (x Run_StorageState) Number() protoreflect.EnumNumber

func (Run_StorageState) String 

func (x Run_StorageState) String() string

func (Run_StorageState) Type 

func (Run_StorageState) Type() protoreflect.EnumType

type Status 

type Status struct {
	Error   string       `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Code    int32        `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	Details []*anypb.Any `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode 

func (x *Status) GetCode() int32

func (*Status) GetDetails 

func (x *Status) GetDetails() []*anypb.Any

func (*Status) GetError 

func (x *Status) GetError() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type StringValues 

type StringValues struct {
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*StringValues) Descriptor deprecated 

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

Deprecated: Use StringValues.ProtoReflect.Descriptor instead.

func (*StringValues) GetValues 

func (x *StringValues) GetValues() []string

func (*StringValues) ProtoMessage 

func (*StringValues) ProtoMessage()

func (*StringValues) ProtoReflect 

func (x *StringValues) ProtoReflect() protoreflect.Message

func (*StringValues) Reset 

func (x *StringValues) Reset()

func (*StringValues) String 

func (x *StringValues) String() string

type Task 

type Task struct {

	// Output. Unique task ID. Generated by API server.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Required input field. The Namespace to which this pipeline task belongs.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required input field. The PipelineName to which this pipeline task belongs.
	// Namespace will be encoded in the PipelineName.
	// "namespace/${namespace}/pipeline/${pipelineName}" for namespaced pipelines
	// "pipeline/${pipelineName}" for shared pipelines
	PipelineName string `protobuf:"bytes,3,opt,name=pipelineName,proto3" json:"pipelineName,omitempty"`
	// Required input field.The ID of the PipelineRun that the PipelineTask belongs to.
	RunId string `protobuf:"bytes,4,opt,name=runId,proto3" json:"runId,omitempty"`
	// Required input field. The ID of the MLMD execution associated with the PipelineTask.
	MlmdExecutionID string `protobuf:"bytes,5,opt,name=mlmdExecutionID,proto3" json:"mlmdExecutionID,omitempty"`
	// Required input field. The time this task is created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Optional input field. The time this task is finished.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// Required input field.
	Fingerprint string `protobuf:"bytes,8,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCreatedAt 

func (x *Task) GetCreatedAt() *timestamppb.Timestamp

func (*Task) GetFingerprint 

func (x *Task) GetFingerprint() string

func (*Task) GetFinishedAt 

func (x *Task) GetFinishedAt() *timestamppb.Timestamp

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetMlmdExecutionID 

func (x *Task) GetMlmdExecutionID() string

func (*Task) GetNamespace 

func (x *Task) GetNamespace() string

func (*Task) GetPipelineName 

func (x *Task) GetPipelineName() string

func (*Task) GetRunId 

func (x *Task) GetRunId() string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskServiceClient 

type TaskServiceClient interface {
	// Creates a new task.
	CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*Task, error)
	// Finds all tasks. Supports pagination, and sorting on certain fields.
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
}

TaskServiceClient is the client API for TaskService service.

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

func NewTaskServiceClient 

func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient

type TaskServiceServer 

type TaskServiceServer interface {
	// Creates a new task.
	CreateTask(context.Context, *CreateTaskRequest) (*Task, error)
	// Finds all tasks. Supports pagination, and sorting on certain fields.
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
}

TaskServiceServer is the server API for TaskService service.

type TerminateRunRequest 

type TerminateRunRequest struct {

	// The ID of the run to be terminated.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateRunRequest) Descriptor deprecated 

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

Deprecated: Use TerminateRunRequest.ProtoReflect.Descriptor instead.

func (*TerminateRunRequest) GetRunId 

func (x *TerminateRunRequest) GetRunId() string

func (*TerminateRunRequest) ProtoMessage 

func (*TerminateRunRequest) ProtoMessage()

func (*TerminateRunRequest) ProtoReflect 

func (x *TerminateRunRequest) ProtoReflect() protoreflect.Message

func (*TerminateRunRequest) Reset 

func (x *TerminateRunRequest) Reset()

func (*TerminateRunRequest) String 

func (x *TerminateRunRequest) String() string

type Trigger 

type Trigger struct {

	// Types that are assignable to Trigger:
	//	*Trigger_CronSchedule
	//	*Trigger_PeriodicSchedule
	Trigger isTrigger_Trigger `protobuf_oneof:"trigger"`
	// contains filtered or unexported fields
}

Trigger defines what starts a pipeline run.

func (*Trigger) Descriptor deprecated 

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetCronSchedule 

func (x *Trigger) GetCronSchedule() *CronSchedule

func (*Trigger) GetPeriodicSchedule 

func (x *Trigger) GetPeriodicSchedule() *PeriodicSchedule

func (*Trigger) GetTrigger 

func (m *Trigger) GetTrigger() isTrigger_Trigger

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect 

func (x *Trigger) ProtoReflect() protoreflect.Message

func (*Trigger) Reset 

func (x *Trigger) Reset()

func (*Trigger) String 

func (x *Trigger) String() string

type Trigger_CronSchedule 

type Trigger_CronSchedule struct {
	CronSchedule *CronSchedule `protobuf:"bytes,1,opt,name=cron_schedule,json=cronSchedule,proto3,oneof"`
}

type Trigger_PeriodicSchedule 

type Trigger_PeriodicSchedule struct {
	PeriodicSchedule *PeriodicSchedule `protobuf:"bytes,2,opt,name=periodic_schedule,json=periodicSchedule,proto3,oneof"`
}

type UnarchiveExperimentRequest 

type UnarchiveExperimentRequest struct {

	// The ID of the experiment to be restored.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*UnarchiveExperimentRequest) Descriptor deprecated 

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

Deprecated: Use UnarchiveExperimentRequest.ProtoReflect.Descriptor instead.

func (*UnarchiveExperimentRequest) GetId 

func (x *UnarchiveExperimentRequest) GetId() string

func (*UnarchiveExperimentRequest) ProtoMessage 

func (*UnarchiveExperimentRequest) ProtoMessage()

func (*UnarchiveExperimentRequest) ProtoReflect 

func (x *UnarchiveExperimentRequest) ProtoReflect() protoreflect.Message

func (*UnarchiveExperimentRequest) Reset 

func (x *UnarchiveExperimentRequest) Reset()

func (*UnarchiveExperimentRequest) String 

func (x *UnarchiveExperimentRequest) String() string

type UnarchiveRunRequest 

type UnarchiveRunRequest struct {

	// The ID of the run to be restored.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*UnarchiveRunRequest) Descriptor deprecated 

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

Deprecated: Use UnarchiveRunRequest.ProtoReflect.Descriptor instead.

func (*UnarchiveRunRequest) GetId 

func (x *UnarchiveRunRequest) GetId() string

func (*UnarchiveRunRequest) ProtoMessage 

func (*UnarchiveRunRequest) ProtoMessage()

func (*UnarchiveRunRequest) ProtoReflect 

func (x *UnarchiveRunRequest) ProtoReflect() protoreflect.Message

func (*UnarchiveRunRequest) Reset 

func (x *UnarchiveRunRequest) Reset()

func (*UnarchiveRunRequest) String 

func (x *UnarchiveRunRequest) String() string

type UnimplementedAuthServiceServer 

type UnimplementedAuthServiceServer struct {
}

UnimplementedAuthServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAuthServiceServer) Authorize 

func (*UnimplementedAuthServiceServer) Authorize(context.Context, *AuthorizeRequest) (*emptypb.Empty, error)

type UnimplementedDummyFilterServiceServer 

type UnimplementedDummyFilterServiceServer struct {
}

UnimplementedDummyFilterServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDummyFilterServiceServer) GetFilter 

func (*UnimplementedDummyFilterServiceServer) GetFilter(context.Context, *Filter) (*Filter, error)

type UnimplementedExperimentServiceServer 

type UnimplementedExperimentServiceServer struct {
}

UnimplementedExperimentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedExperimentServiceServer) ArchiveExperiment 

func (*UnimplementedExperimentServiceServer) ArchiveExperiment(context.Context, *ArchiveExperimentRequest) (*emptypb.Empty, error)

func (*UnimplementedExperimentServiceServer) CreateExperiment 

func (*UnimplementedExperimentServiceServer) CreateExperiment(context.Context, *CreateExperimentRequest) (*Experiment, error)

func (*UnimplementedExperimentServiceServer) DeleteExperiment 

func (*UnimplementedExperimentServiceServer) DeleteExperiment(context.Context, *DeleteExperimentRequest) (*emptypb.Empty, error)

func (*UnimplementedExperimentServiceServer) GetExperiment 

func (*UnimplementedExperimentServiceServer) GetExperiment(context.Context, *GetExperimentRequest) (*Experiment, error)

func (*UnimplementedExperimentServiceServer) ListExperiment 

func (*UnimplementedExperimentServiceServer) ListExperiment(context.Context, *ListExperimentsRequest) (*ListExperimentsResponse, error)

func (*UnimplementedExperimentServiceServer) UnarchiveExperiment 

func (*UnimplementedExperimentServiceServer) UnarchiveExperiment(context.Context, *UnarchiveExperimentRequest) (*emptypb.Empty, error)

type UnimplementedHealthzServiceServer 

type UnimplementedHealthzServiceServer struct {
}

UnimplementedHealthzServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedHealthzServiceServer) GetHealthz 

func (*UnimplementedHealthzServiceServer) GetHealthz(context.Context, *emptypb.Empty) (*GetHealthzResponse, error)

type UnimplementedJobServiceServer 

type UnimplementedJobServiceServer struct {
}

UnimplementedJobServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedJobServiceServer) CreateJob 

func (*UnimplementedJobServiceServer) CreateJob(context.Context, *CreateJobRequest) (*Job, error)

func (*UnimplementedJobServiceServer) DeleteJob 

func (*UnimplementedJobServiceServer) DeleteJob(context.Context, *DeleteJobRequest) (*emptypb.Empty, error)

func (*UnimplementedJobServiceServer) DisableJob 

func (*UnimplementedJobServiceServer) DisableJob(context.Context, *DisableJobRequest) (*emptypb.Empty, error)

func (*UnimplementedJobServiceServer) EnableJob 

func (*UnimplementedJobServiceServer) EnableJob(context.Context, *EnableJobRequest) (*emptypb.Empty, error)

func (*UnimplementedJobServiceServer) GetJob 

func (*UnimplementedJobServiceServer) GetJob(context.Context, *GetJobRequest) (*Job, error)

func (*UnimplementedJobServiceServer) ListJobs 

func (*UnimplementedJobServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

type UnimplementedPipelineServiceServer 

type UnimplementedPipelineServiceServer struct {
}

UnimplementedPipelineServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPipelineServiceServer) CreatePipeline 

func (*UnimplementedPipelineServiceServer) CreatePipeline(context.Context, *CreatePipelineRequest) (*Pipeline, error)

func (*UnimplementedPipelineServiceServer) CreatePipelineVersion 

func (*UnimplementedPipelineServiceServer) CreatePipelineVersion(context.Context, *CreatePipelineVersionRequest) (*PipelineVersion, error)

func (*UnimplementedPipelineServiceServer) DeletePipeline 

func (*UnimplementedPipelineServiceServer) DeletePipeline(context.Context, *DeletePipelineRequest) (*emptypb.Empty, error)

func (*UnimplementedPipelineServiceServer) DeletePipelineVersion 

func (*UnimplementedPipelineServiceServer) DeletePipelineVersion(context.Context, *DeletePipelineVersionRequest) (*emptypb.Empty, error)

func (*UnimplementedPipelineServiceServer) GetPipeline 

func (*UnimplementedPipelineServiceServer) GetPipeline(context.Context, *GetPipelineRequest) (*Pipeline, error)

func (*UnimplementedPipelineServiceServer) GetPipelineVersion 

func (*UnimplementedPipelineServiceServer) GetPipelineVersion(context.Context, *GetPipelineVersionRequest) (*PipelineVersion, error)

func (*UnimplementedPipelineServiceServer) GetPipelineVersionTemplate 

func (*UnimplementedPipelineServiceServer) GetPipelineVersionTemplate(context.Context, *GetPipelineVersionTemplateRequest) (*GetTemplateResponse, error)

func (*UnimplementedPipelineServiceServer) GetTemplate 

func (*UnimplementedPipelineServiceServer) GetTemplate(context.Context, *GetTemplateRequest) (*GetTemplateResponse, error)

func (*UnimplementedPipelineServiceServer) ListPipelineVersions 

func (*UnimplementedPipelineServiceServer) ListPipelineVersions(context.Context, *ListPipelineVersionsRequest) (*ListPipelineVersionsResponse, error)

func (*UnimplementedPipelineServiceServer) ListPipelines 

func (*UnimplementedPipelineServiceServer) ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error)

func (*UnimplementedPipelineServiceServer) UpdatePipelineDefaultVersion 

func (*UnimplementedPipelineServiceServer) UpdatePipelineDefaultVersion(context.Context, *UpdatePipelineDefaultVersionRequest) (*emptypb.Empty, error)

type UnimplementedReportServiceServer 

type UnimplementedReportServiceServer struct {
}

UnimplementedReportServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedReportServiceServer) ReportScheduledWorkflow 

func (*UnimplementedReportServiceServer) ReportScheduledWorkflow(context.Context, *ReportScheduledWorkflowRequest) (*emptypb.Empty, error)

func (*UnimplementedReportServiceServer) ReportWorkflow 

func (*UnimplementedReportServiceServer) ReportWorkflow(context.Context, *ReportWorkflowRequest) (*emptypb.Empty, error)

type UnimplementedRunServiceServer 

type UnimplementedRunServiceServer struct {
}

UnimplementedRunServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRunServiceServer) ArchiveRun 

func (*UnimplementedRunServiceServer) ArchiveRun(context.Context, *ArchiveRunRequest) (*emptypb.Empty, error)

func (*UnimplementedRunServiceServer) CreateRun 

func (*UnimplementedRunServiceServer) CreateRun(context.Context, *CreateRunRequest) (*RunDetail, error)

func (*UnimplementedRunServiceServer) DeleteRun 

func (*UnimplementedRunServiceServer) DeleteRun(context.Context, *DeleteRunRequest) (*emptypb.Empty, error)

func (*UnimplementedRunServiceServer) GetRun 

func (*UnimplementedRunServiceServer) GetRun(context.Context, *GetRunRequest) (*RunDetail, error)

func (*UnimplementedRunServiceServer) ListRuns 

func (*UnimplementedRunServiceServer) ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)

func (*UnimplementedRunServiceServer) ReadArtifact 

func (*UnimplementedRunServiceServer) ReadArtifact(context.Context, *ReadArtifactRequest) (*ReadArtifactResponse, error)

func (*UnimplementedRunServiceServer) ReportRunMetrics 

func (*UnimplementedRunServiceServer) ReportRunMetrics(context.Context, *ReportRunMetricsRequest) (*ReportRunMetricsResponse, error)

func (*UnimplementedRunServiceServer) RetryRun 

func (*UnimplementedRunServiceServer) RetryRun(context.Context, *RetryRunRequest) (*emptypb.Empty, error)

func (*UnimplementedRunServiceServer) TerminateRun 

func (*UnimplementedRunServiceServer) TerminateRun(context.Context, *TerminateRunRequest) (*emptypb.Empty, error)

func (*UnimplementedRunServiceServer) UnarchiveRun 

func (*UnimplementedRunServiceServer) UnarchiveRun(context.Context, *UnarchiveRunRequest) (*emptypb.Empty, error)

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTaskServiceServer) CreateTask 

func (*UnimplementedTaskServiceServer) CreateTask(context.Context, *CreateTaskRequest) (*Task, error)

func (*UnimplementedTaskServiceServer) ListTasks 

func (*UnimplementedTaskServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

type UnimplementedVisualizationServiceServer 

type UnimplementedVisualizationServiceServer struct {
}

UnimplementedVisualizationServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedVisualizationServiceServer) CreateVisualization 

func (*UnimplementedVisualizationServiceServer) CreateVisualization(context.Context, *CreateVisualizationRequest) (*Visualization, error)

type UpdatePipelineDefaultVersionRequest 

type UpdatePipelineDefaultVersionRequest struct {

	// The ID of the pipeline to be updated.
	PipelineId string `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// The ID of the default version.
	VersionId string `protobuf:"bytes,2,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdatePipelineDefaultVersionRequest) Descriptor deprecated 

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

Deprecated: Use UpdatePipelineDefaultVersionRequest.ProtoReflect.Descriptor instead.

func (*UpdatePipelineDefaultVersionRequest) GetPipelineId 

func (x *UpdatePipelineDefaultVersionRequest) GetPipelineId() string

func (*UpdatePipelineDefaultVersionRequest) GetVersionId 

func (x *UpdatePipelineDefaultVersionRequest) GetVersionId() string

func (*UpdatePipelineDefaultVersionRequest) ProtoMessage 

func (*UpdatePipelineDefaultVersionRequest) ProtoMessage()

func (*UpdatePipelineDefaultVersionRequest) ProtoReflect 

func (x *UpdatePipelineDefaultVersionRequest) ProtoReflect() protoreflect.Message

func (*UpdatePipelineDefaultVersionRequest) Reset 

func (x *UpdatePipelineDefaultVersionRequest) Reset()

func (*UpdatePipelineDefaultVersionRequest) String 

func (x *UpdatePipelineDefaultVersionRequest) String() string

type Url 

type Url struct {

	// URL of the pipeline definition or the pipeline version definition.
	PipelineUrl string `protobuf:"bytes,1,opt,name=pipeline_url,json=pipelineUrl,proto3" json:"pipeline_url,omitempty"`
	// contains filtered or unexported fields
}

func (*Url) Descriptor deprecated 

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

Deprecated: Use Url.ProtoReflect.Descriptor instead.

func (*Url) GetPipelineUrl 

func (x *Url) GetPipelineUrl() string

func (*Url) ProtoMessage 

func (*Url) ProtoMessage()

func (*Url) ProtoReflect 

func (x *Url) ProtoReflect() protoreflect.Message

func (*Url) Reset 

func (x *Url) Reset()

func (*Url) String 

func (x *Url) String() string

type Visualization 

type Visualization struct {
	Type Visualization_Type `protobuf:"varint,1,opt,name=type,proto3,enum=api.Visualization_Type" json:"type,omitempty"`
	// Path pattern of input data to be used during generation of visualizations.
	// This is required when creating the pipeline through CreateVisualization
	// API.
	Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// Variables to be used during generation of a visualization.
	// This should be provided as a JSON string.
	// This is required when creating the pipeline through CreateVisualization
	// API.
	Arguments string `protobuf:"bytes,3,opt,name=arguments,proto3" json:"arguments,omitempty"`
	// Output. Generated visualization html.
	Html string `protobuf:"bytes,4,opt,name=html,proto3" json:"html,omitempty"`
	// In case any error happens when generating visualizations, only
	// visualization ID and the error message are returned. Client has the
	// flexibility of choosing how to handle the error.
	Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*Visualization) Descriptor deprecated 

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

Deprecated: Use Visualization.ProtoReflect.Descriptor instead.

func (*Visualization) GetArguments 

func (x *Visualization) GetArguments() string

func (*Visualization) GetError 

func (x *Visualization) GetError() string

func (*Visualization) GetHtml 

func (x *Visualization) GetHtml() string

func (*Visualization) GetSource 

func (x *Visualization) GetSource() string

func (*Visualization) GetType 

func (x *Visualization) GetType() Visualization_Type

func (*Visualization) ProtoMessage 

func (*Visualization) ProtoMessage()

func (*Visualization) ProtoReflect 

func (x *Visualization) ProtoReflect() protoreflect.Message

func (*Visualization) Reset 

func (x *Visualization) Reset()

func (*Visualization) String 

func (x *Visualization) String() string

type VisualizationServiceClient 

type VisualizationServiceClient interface {
	CreateVisualization(ctx context.Context, in *CreateVisualizationRequest, opts ...grpc.CallOption) (*Visualization, error)
}

VisualizationServiceClient is the client API for VisualizationService service.

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

func NewVisualizationServiceClient 

func NewVisualizationServiceClient(cc grpc.ClientConnInterface) VisualizationServiceClient

type VisualizationServiceServer 

type VisualizationServiceServer interface {
	CreateVisualization(context.Context, *CreateVisualizationRequest) (*Visualization, error)
}

VisualizationServiceServer is the server API for VisualizationService service.

type Visualization_Type 

type Visualization_Type int32

Type of visualization to be generated. This is required when creating the pipeline through CreateVisualization API. 

const (
	Visualization_ROC_CURVE Visualization_Type = 0
	Visualization_TFDV      Visualization_Type = 1
	Visualization_TFMA      Visualization_Type = 2
	Visualization_TABLE     Visualization_Type = 3
	Visualization_CUSTOM    Visualization_Type = 4
)

func (Visualization_Type) Descriptor 

func (Visualization_Type) Descriptor() protoreflect.EnumDescriptor

func (Visualization_Type) Enum 

func (x Visualization_Type) Enum() *Visualization_Type

func (Visualization_Type) EnumDescriptor deprecated 

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

Deprecated: Use Visualization_Type.Descriptor instead.

func (Visualization_Type) Number 

func (x Visualization_Type) Number() protoreflect.EnumNumber

func (Visualization_Type) String 

func (x Visualization_Type) String() string

func (Visualization_Type) Type 

func (Visualization_Type) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.