go_client

package
v0.0.0-...-4f670de Latest Latest
Warning

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

 Go to latest Published: May 14, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

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.

Index

Constants

This section is empty.

Variables

View Source 
var AuthorizeRequest_Resources_name = map[int32]string{
	0: "UNASSIGNED_RESOURCES",
	1: "VIEWERS",
}
View Source 
var AuthorizeRequest_Resources_value = map[string]int32{
	"UNASSIGNED_RESOURCES": 0,
	"VIEWERS":              1,
}
View Source 
var AuthorizeRequest_Verb_name = map[int32]string{
	0: "UNASSIGNED_VERB",
	1: "CREATE",
	2: "GET",
	3: "DELETE",
}
View Source 
var AuthorizeRequest_Verb_value = map[string]int32{
	"UNASSIGNED_VERB": 0,
	"CREATE":          1,
	"GET":             2,
	"DELETE":          3,
}
View Source 
var Experiment_StorageState_name = map[int32]string{
	0: "STORAGESTATE_UNSPECIFIED",
	1: "STORAGESTATE_AVAILABLE",
	2: "STORAGESTATE_ARCHIVED",
}
View Source 
var Experiment_StorageState_value = map[string]int32{
	"STORAGESTATE_UNSPECIFIED": 0,
	"STORAGESTATE_AVAILABLE":   1,
	"STORAGESTATE_ARCHIVED":    2,
}
View Source 
var Job_Mode_name = map[int32]string{
	0: "UNKNOWN_MODE",
	1: "ENABLED",
	2: "DISABLED",
}
View Source 
var Job_Mode_value = map[string]int32{
	"UNKNOWN_MODE": 0,
	"ENABLED":      1,
	"DISABLED":     2,
}
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",
}
View Source 
var 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,
}
View Source 
var Relationship_name = map[int32]string{
	0: "UNKNOWN_RELATIONSHIP",
	1: "OWNER",
	2: "CREATOR",
}
View Source 
var Relationship_value = map[string]int32{
	"UNKNOWN_RELATIONSHIP": 0,
	"OWNER":                1,
	"CREATOR":              2,
}
View Source 
var ReportRunMetricsResponse_ReportRunMetricResult_Status_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "OK",
	2: "INVALID_ARGUMENT",
	3: "DUPLICATE_REPORTING",
	4: "INTERNAL_ERROR",
}
View Source 
var ReportRunMetricsResponse_ReportRunMetricResult_Status_value = map[string]int32{
	"UNSPECIFIED":         0,
	"OK":                  1,
	"INVALID_ARGUMENT":    2,
	"DUPLICATE_REPORTING": 3,
	"INTERNAL_ERROR":      4,
}
View Source 
var ResourceType_name = map[int32]string{
	0: "UNKNOWN_RESOURCE_TYPE",
	1: "EXPERIMENT",
	2: "JOB",
	3: "PIPELINE",
	4: "PIPELINE_VERSION",
	5: "NAMESPACE",
}
View Source 
var ResourceType_value = map[string]int32{
	"UNKNOWN_RESOURCE_TYPE": 0,
	"EXPERIMENT":            1,
	"JOB":                   2,
	"PIPELINE":              3,
	"PIPELINE_VERSION":      4,
	"NAMESPACE":             5,
}
View Source 
var RunMetric_Format_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "RAW",
	2: "PERCENTAGE",
}
View Source 
var RunMetric_Format_value = map[string]int32{
	"UNSPECIFIED": 0,
	"RAW":         1,
	"PERCENTAGE":  2,
}
View Source 
var Run_StorageState_name = map[int32]string{
	0: "STORAGESTATE_AVAILABLE",
	1: "STORAGESTATE_ARCHIVED",
}
View Source 
var Run_StorageState_value = map[string]int32{
	"STORAGESTATE_AVAILABLE": 0,
	"STORAGESTATE_ARCHIVED":  1,
}
View Source 
var Visualization_Type_name = map[int32]string{
	0: "ROC_CURVE",
	1: "TFDV",
	2: "TFMA",
	3: "TABLE",
	4: "CUSTOM",
}
View Source 
var Visualization_Type_value = map[string]int32{
	"ROC_CURVE": 0,
	"TFDV":      1,
	"TFMA":      2,
	"TABLE":     3,
	"CUSTOM":    4,
}

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 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 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 {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ArchiveExperimentRequest) Descriptor 

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

func (*ArchiveExperimentRequest) GetId 

func (m *ArchiveExperimentRequest) GetId() string

func (*ArchiveExperimentRequest) ProtoMessage 

func (*ArchiveExperimentRequest) ProtoMessage()

func (*ArchiveExperimentRequest) Reset 

func (m *ArchiveExperimentRequest) Reset()

func (*ArchiveExperimentRequest) String 

func (m *ArchiveExperimentRequest) String() string

func (*ArchiveExperimentRequest) XXX_DiscardUnknown 

func (m *ArchiveExperimentRequest) XXX_DiscardUnknown()

func (*ArchiveExperimentRequest) XXX_Marshal 

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

func (*ArchiveExperimentRequest) XXX_Merge 

func (dst *ArchiveExperimentRequest) XXX_Merge(src proto.Message)

func (*ArchiveExperimentRequest) XXX_Size 

func (m *ArchiveExperimentRequest) XXX_Size() int

func (*ArchiveExperimentRequest) XXX_Unmarshal 

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

type ArchiveRunRequest 

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

func (*ArchiveRunRequest) Descriptor 

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

func (*ArchiveRunRequest) GetId 

func (m *ArchiveRunRequest) GetId() string

func (*ArchiveRunRequest) ProtoMessage 

func (*ArchiveRunRequest) ProtoMessage()

func (*ArchiveRunRequest) Reset 

func (m *ArchiveRunRequest) Reset()

func (*ArchiveRunRequest) String 

func (m *ArchiveRunRequest) String() string

func (*ArchiveRunRequest) XXX_DiscardUnknown 

func (m *ArchiveRunRequest) XXX_DiscardUnknown()

func (*ArchiveRunRequest) XXX_Marshal 

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

func (*ArchiveRunRequest) XXX_Merge 

func (dst *ArchiveRunRequest) XXX_Merge(src proto.Message)

func (*ArchiveRunRequest) XXX_Size 

func (m *ArchiveRunRequest) XXX_Size() int

func (*ArchiveRunRequest) XXX_Unmarshal 

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

type AuthServiceClient 

type AuthServiceClient interface {
	Authorize(ctx context.Context, in *AuthorizeRequest, opts ...grpc.CallOption) (*empty.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.ClientConn) AuthServiceClient

type AuthServiceServer 

type AuthServiceServer interface {
	Authorize(context.Context, *AuthorizeRequest) (*empty.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"`
	Resources            AuthorizeRequest_Resources `protobuf:"varint,2,opt,name=resources,proto3,enum=api.AuthorizeRequest_Resources" json:"resources,omitempty"`
	Verb                 AuthorizeRequest_Verb      `protobuf:"varint,3,opt,name=verb,proto3,enum=api.AuthorizeRequest_Verb" json:"verb,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*AuthorizeRequest) Descriptor 

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

func (*AuthorizeRequest) GetNamespace 

func (m *AuthorizeRequest) GetNamespace() string

func (*AuthorizeRequest) GetResources 

func (m *AuthorizeRequest) GetResources() AuthorizeRequest_Resources

func (*AuthorizeRequest) GetVerb 

func (m *AuthorizeRequest) GetVerb() AuthorizeRequest_Verb

func (*AuthorizeRequest) ProtoMessage 

func (*AuthorizeRequest) ProtoMessage()

func (*AuthorizeRequest) Reset 

func (m *AuthorizeRequest) Reset()

func (*AuthorizeRequest) String 

func (m *AuthorizeRequest) String() string

func (*AuthorizeRequest) XXX_DiscardUnknown 

func (m *AuthorizeRequest) XXX_DiscardUnknown()

func (*AuthorizeRequest) XXX_Marshal 

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

func (*AuthorizeRequest) XXX_Merge 

func (dst *AuthorizeRequest) XXX_Merge(src proto.Message)

func (*AuthorizeRequest) XXX_Size 

func (m *AuthorizeRequest) XXX_Size() int

func (*AuthorizeRequest) XXX_Unmarshal 

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

type AuthorizeRequest_Resources 

type AuthorizeRequest_Resources int32
const (
	AuthorizeRequest_UNASSIGNED_RESOURCES AuthorizeRequest_Resources = 0
	AuthorizeRequest_VIEWERS              AuthorizeRequest_Resources = 1
)

func (AuthorizeRequest_Resources) EnumDescriptor 

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

func (AuthorizeRequest_Resources) String 

func (x AuthorizeRequest_Resources) String() string

type AuthorizeRequest_Verb 

type AuthorizeRequest_Verb int32
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) EnumDescriptor 

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

func (AuthorizeRequest_Verb) String 

func (x AuthorizeRequest_Verb) String() string

type CreateExperimentRequest 

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

func (*CreateExperimentRequest) Descriptor 

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

func (*CreateExperimentRequest) GetExperiment 

func (m *CreateExperimentRequest) GetExperiment() *Experiment

func (*CreateExperimentRequest) ProtoMessage 

func (*CreateExperimentRequest) ProtoMessage()

func (*CreateExperimentRequest) Reset 

func (m *CreateExperimentRequest) Reset()

func (*CreateExperimentRequest) String 

func (m *CreateExperimentRequest) String() string

func (*CreateExperimentRequest) XXX_DiscardUnknown 

func (m *CreateExperimentRequest) XXX_DiscardUnknown()

func (*CreateExperimentRequest) XXX_Marshal 

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

func (*CreateExperimentRequest) XXX_Merge 

func (dst *CreateExperimentRequest) XXX_Merge(src proto.Message)

func (*CreateExperimentRequest) XXX_Size 

func (m *CreateExperimentRequest) XXX_Size() int

func (*CreateExperimentRequest) XXX_Unmarshal 

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

type CreateJobRequest 

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

func (*CreateJobRequest) Descriptor 

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

func (*CreateJobRequest) GetJob 

func (m *CreateJobRequest) GetJob() *Job

func (*CreateJobRequest) ProtoMessage 

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) Reset 

func (m *CreateJobRequest) Reset()

func (*CreateJobRequest) String 

func (m *CreateJobRequest) String() string

func (*CreateJobRequest) XXX_DiscardUnknown 

func (m *CreateJobRequest) XXX_DiscardUnknown()

func (*CreateJobRequest) XXX_Marshal 

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

func (*CreateJobRequest) XXX_Merge 

func (dst *CreateJobRequest) XXX_Merge(src proto.Message)

func (*CreateJobRequest) XXX_Size 

func (m *CreateJobRequest) XXX_Size() int

func (*CreateJobRequest) XXX_Unmarshal 

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

type CreatePipelineRequest 

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

func (*CreatePipelineRequest) Descriptor 

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

func (*CreatePipelineRequest) GetPipeline 

func (m *CreatePipelineRequest) GetPipeline() *Pipeline

func (*CreatePipelineRequest) ProtoMessage 

func (*CreatePipelineRequest) ProtoMessage()

func (*CreatePipelineRequest) Reset 

func (m *CreatePipelineRequest) Reset()

func (*CreatePipelineRequest) String 

func (m *CreatePipelineRequest) String() string

func (*CreatePipelineRequest) XXX_DiscardUnknown 

func (m *CreatePipelineRequest) XXX_DiscardUnknown()

func (*CreatePipelineRequest) XXX_Marshal 

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

func (*CreatePipelineRequest) XXX_Merge 

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

func (*CreatePipelineRequest) XXX_Size 

func (m *CreatePipelineRequest) XXX_Size() int

func (*CreatePipelineRequest) XXX_Unmarshal 

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

type CreatePipelineVersionRequest 

type CreatePipelineVersionRequest struct {
	Version              *PipelineVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CreatePipelineVersionRequest) Descriptor 

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

func (*CreatePipelineVersionRequest) GetVersion 

func (m *CreatePipelineVersionRequest) GetVersion() *PipelineVersion

func (*CreatePipelineVersionRequest) ProtoMessage 

func (*CreatePipelineVersionRequest) ProtoMessage()

func (*CreatePipelineVersionRequest) Reset 

func (m *CreatePipelineVersionRequest) Reset()

func (*CreatePipelineVersionRequest) String 

func (m *CreatePipelineVersionRequest) String() string

func (*CreatePipelineVersionRequest) XXX_DiscardUnknown 

func (m *CreatePipelineVersionRequest) XXX_DiscardUnknown()

func (*CreatePipelineVersionRequest) XXX_Marshal 

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

func (*CreatePipelineVersionRequest) XXX_Merge 

func (dst *CreatePipelineVersionRequest) XXX_Merge(src proto.Message)

func (*CreatePipelineVersionRequest) XXX_Size 

func (m *CreatePipelineVersionRequest) XXX_Size() int

func (*CreatePipelineVersionRequest) XXX_Unmarshal 

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

type CreateRunRequest 

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

func (*CreateRunRequest) Descriptor 

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

func (*CreateRunRequest) GetRun 

func (m *CreateRunRequest) GetRun() *Run

func (*CreateRunRequest) ProtoMessage 

func (*CreateRunRequest) ProtoMessage()

func (*CreateRunRequest) Reset 

func (m *CreateRunRequest) Reset()

func (*CreateRunRequest) String 

func (m *CreateRunRequest) String() string

func (*CreateRunRequest) XXX_DiscardUnknown 

func (m *CreateRunRequest) XXX_DiscardUnknown()

func (*CreateRunRequest) XXX_Marshal 

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

func (*CreateRunRequest) XXX_Merge 

func (dst *CreateRunRequest) XXX_Merge(src proto.Message)

func (*CreateRunRequest) XXX_Size 

func (m *CreateRunRequest) XXX_Size() int

func (*CreateRunRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CreateVisualizationRequest) Descriptor 

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

func (*CreateVisualizationRequest) GetNamespace 

func (m *CreateVisualizationRequest) GetNamespace() string

func (*CreateVisualizationRequest) GetVisualization 

func (m *CreateVisualizationRequest) GetVisualization() *Visualization

func (*CreateVisualizationRequest) ProtoMessage 

func (*CreateVisualizationRequest) ProtoMessage()

func (*CreateVisualizationRequest) Reset 

func (m *CreateVisualizationRequest) Reset()

func (*CreateVisualizationRequest) String 

func (m *CreateVisualizationRequest) String() string

func (*CreateVisualizationRequest) XXX_DiscardUnknown 

func (m *CreateVisualizationRequest) XXX_DiscardUnknown()

func (*CreateVisualizationRequest) XXX_Marshal 

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

func (*CreateVisualizationRequest) XXX_Merge 

func (dst *CreateVisualizationRequest) XXX_Merge(src proto.Message)

func (*CreateVisualizationRequest) XXX_Size 

func (m *CreateVisualizationRequest) XXX_Size() int

func (*CreateVisualizationRequest) XXX_Unmarshal 

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

type CronSchedule 

type CronSchedule struct {
	StartTime            *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime              *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Cron                 string               `protobuf:"bytes,3,opt,name=cron,proto3" json:"cron,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CronSchedule) Descriptor 

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

func (*CronSchedule) GetCron 

func (m *CronSchedule) GetCron() string

func (*CronSchedule) GetEndTime 

func (m *CronSchedule) GetEndTime() *timestamp.Timestamp

func (*CronSchedule) GetStartTime 

func (m *CronSchedule) GetStartTime() *timestamp.Timestamp

func (*CronSchedule) ProtoMessage 

func (*CronSchedule) ProtoMessage()

func (*CronSchedule) Reset 

func (m *CronSchedule) Reset()

func (*CronSchedule) String 

func (m *CronSchedule) String() string

func (*CronSchedule) XXX_DiscardUnknown 

func (m *CronSchedule) XXX_DiscardUnknown()

func (*CronSchedule) XXX_Marshal 

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

func (*CronSchedule) XXX_Merge 

func (dst *CronSchedule) XXX_Merge(src proto.Message)

func (*CronSchedule) XXX_Size 

func (m *CronSchedule) XXX_Size() int

func (*CronSchedule) XXX_Unmarshal 

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

type DeleteExperimentRequest 

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

func (*DeleteExperimentRequest) Descriptor 

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

func (*DeleteExperimentRequest) GetId 

func (m *DeleteExperimentRequest) GetId() string

func (*DeleteExperimentRequest) ProtoMessage 

func (*DeleteExperimentRequest) ProtoMessage()

func (*DeleteExperimentRequest) Reset 

func (m *DeleteExperimentRequest) Reset()

func (*DeleteExperimentRequest) String 

func (m *DeleteExperimentRequest) String() string

func (*DeleteExperimentRequest) XXX_DiscardUnknown 

func (m *DeleteExperimentRequest) XXX_DiscardUnknown()

func (*DeleteExperimentRequest) XXX_Marshal 

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

func (*DeleteExperimentRequest) XXX_Merge 

func (dst *DeleteExperimentRequest) XXX_Merge(src proto.Message)

func (*DeleteExperimentRequest) XXX_Size 

func (m *DeleteExperimentRequest) XXX_Size() int

func (*DeleteExperimentRequest) XXX_Unmarshal 

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

type DeleteJobRequest 

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

func (*DeleteJobRequest) Descriptor 

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

func (*DeleteJobRequest) GetId 

func (m *DeleteJobRequest) GetId() string

func (*DeleteJobRequest) ProtoMessage 

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) Reset 

func (m *DeleteJobRequest) Reset()

func (*DeleteJobRequest) String 

func (m *DeleteJobRequest) String() string

func (*DeleteJobRequest) XXX_DiscardUnknown 

func (m *DeleteJobRequest) XXX_DiscardUnknown()

func (*DeleteJobRequest) XXX_Marshal 

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

func (*DeleteJobRequest) XXX_Merge 

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

func (*DeleteJobRequest) XXX_Size 

func (m *DeleteJobRequest) XXX_Size() int

func (*DeleteJobRequest) XXX_Unmarshal 

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

type DeletePipelineRequest 

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

func (*DeletePipelineRequest) Descriptor 

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

func (*DeletePipelineRequest) GetId 

func (m *DeletePipelineRequest) GetId() string

func (*DeletePipelineRequest) ProtoMessage 

func (*DeletePipelineRequest) ProtoMessage()

func (*DeletePipelineRequest) Reset 

func (m *DeletePipelineRequest) Reset()

func (*DeletePipelineRequest) String 

func (m *DeletePipelineRequest) String() string

func (*DeletePipelineRequest) XXX_DiscardUnknown 

func (m *DeletePipelineRequest) XXX_DiscardUnknown()

func (*DeletePipelineRequest) XXX_Marshal 

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

func (*DeletePipelineRequest) XXX_Merge 

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

func (*DeletePipelineRequest) XXX_Size 

func (m *DeletePipelineRequest) XXX_Size() int

func (*DeletePipelineRequest) XXX_Unmarshal 

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

type DeletePipelineVersionRequest 

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

func (*DeletePipelineVersionRequest) Descriptor 

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

func (*DeletePipelineVersionRequest) GetVersionId 

func (m *DeletePipelineVersionRequest) GetVersionId() string

func (*DeletePipelineVersionRequest) ProtoMessage 

func (*DeletePipelineVersionRequest) ProtoMessage()

func (*DeletePipelineVersionRequest) Reset 

func (m *DeletePipelineVersionRequest) Reset()

func (*DeletePipelineVersionRequest) String 

func (m *DeletePipelineVersionRequest) String() string

func (*DeletePipelineVersionRequest) XXX_DiscardUnknown 

func (m *DeletePipelineVersionRequest) XXX_DiscardUnknown()

func (*DeletePipelineVersionRequest) XXX_Marshal 

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

func (*DeletePipelineVersionRequest) XXX_Merge 

func (dst *DeletePipelineVersionRequest) XXX_Merge(src proto.Message)

func (*DeletePipelineVersionRequest) XXX_Size 

func (m *DeletePipelineVersionRequest) XXX_Size() int

func (*DeletePipelineVersionRequest) XXX_Unmarshal 

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

type DeleteRunRequest 

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

func (*DeleteRunRequest) Descriptor 

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

func (*DeleteRunRequest) GetId 

func (m *DeleteRunRequest) GetId() string

func (*DeleteRunRequest) ProtoMessage 

func (*DeleteRunRequest) ProtoMessage()

func (*DeleteRunRequest) Reset 

func (m *DeleteRunRequest) Reset()

func (*DeleteRunRequest) String 

func (m *DeleteRunRequest) String() string

func (*DeleteRunRequest) XXX_DiscardUnknown 

func (m *DeleteRunRequest) XXX_DiscardUnknown()

func (*DeleteRunRequest) XXX_Marshal 

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

func (*DeleteRunRequest) XXX_Merge 

func (dst *DeleteRunRequest) XXX_Merge(src proto.Message)

func (*DeleteRunRequest) XXX_Size 

func (m *DeleteRunRequest) XXX_Size() int

func (*DeleteRunRequest) XXX_Unmarshal 

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

type DisableJobRequest 

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

func (*DisableJobRequest) Descriptor 

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

func (*DisableJobRequest) GetId 

func (m *DisableJobRequest) GetId() string

func (*DisableJobRequest) ProtoMessage 

func (*DisableJobRequest) ProtoMessage()

func (*DisableJobRequest) Reset 

func (m *DisableJobRequest) Reset()

func (*DisableJobRequest) String 

func (m *DisableJobRequest) String() string

func (*DisableJobRequest) XXX_DiscardUnknown 

func (m *DisableJobRequest) XXX_DiscardUnknown()

func (*DisableJobRequest) XXX_Marshal 

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

func (*DisableJobRequest) XXX_Merge 

func (dst *DisableJobRequest) XXX_Merge(src proto.Message)

func (*DisableJobRequest) XXX_Size 

func (m *DisableJobRequest) XXX_Size() int

func (*DisableJobRequest) XXX_Unmarshal 

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

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.ClientConn) 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 {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EnableJobRequest) Descriptor 

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

func (*EnableJobRequest) GetId 

func (m *EnableJobRequest) GetId() string

func (*EnableJobRequest) ProtoMessage 

func (*EnableJobRequest) ProtoMessage()

func (*EnableJobRequest) Reset 

func (m *EnableJobRequest) Reset()

func (*EnableJobRequest) String 

func (m *EnableJobRequest) String() string

func (*EnableJobRequest) XXX_DiscardUnknown 

func (m *EnableJobRequest) XXX_DiscardUnknown()

func (*EnableJobRequest) XXX_Marshal 

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

func (*EnableJobRequest) XXX_Merge 

func (dst *EnableJobRequest) XXX_Merge(src proto.Message)

func (*EnableJobRequest) XXX_Size 

func (m *EnableJobRequest) XXX_Size() int

func (*EnableJobRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetErrorDetails 

func (m *Error) GetErrorDetails() string

func (*Error) GetErrorMessage 

func (m *Error) GetErrorMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

func (dst *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type Experiment 

type Experiment struct {
	Id                   string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string                  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string                  `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	CreatedAt            *timestamp.Timestamp    `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ResourceReferences   []*ResourceReference    `protobuf:"bytes,5,rep,name=resource_references,json=resourceReferences,proto3" json:"resource_references,omitempty"`
	StorageState         Experiment_StorageState `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*Experiment) Descriptor 

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

func (*Experiment) GetCreatedAt 

func (m *Experiment) GetCreatedAt() *timestamp.Timestamp

func (*Experiment) GetDescription 

func (m *Experiment) GetDescription() string

func (*Experiment) GetId 

func (m *Experiment) GetId() string

func (*Experiment) GetName 

func (m *Experiment) GetName() string

func (*Experiment) GetResourceReferences 

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

func (*Experiment) GetStorageState 

func (m *Experiment) GetStorageState() Experiment_StorageState

func (*Experiment) ProtoMessage 

func (*Experiment) ProtoMessage()

func (*Experiment) Reset 

func (m *Experiment) Reset()

func (*Experiment) String 

func (m *Experiment) String() string

func (*Experiment) XXX_DiscardUnknown 

func (m *Experiment) XXX_DiscardUnknown()

func (*Experiment) XXX_Marshal 

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

func (*Experiment) XXX_Merge 

func (dst *Experiment) XXX_Merge(src proto.Message)

func (*Experiment) XXX_Size 

func (m *Experiment) XXX_Size() int

func (*Experiment) XXX_Unmarshal 

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

type ExperimentServiceClient 

type ExperimentServiceClient interface {
	CreateExperiment(ctx context.Context, in *CreateExperimentRequest, opts ...grpc.CallOption) (*Experiment, error)
	GetExperiment(ctx context.Context, in *GetExperimentRequest, opts ...grpc.CallOption) (*Experiment, error)
	ListExperiment(ctx context.Context, in *ListExperimentsRequest, opts ...grpc.CallOption) (*ListExperimentsResponse, error)
	DeleteExperiment(ctx context.Context, in *DeleteExperimentRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ArchiveExperiment(ctx context.Context, in *ArchiveExperimentRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	UnarchiveExperiment(ctx context.Context, in *UnarchiveExperimentRequest, opts ...grpc.CallOption) (*empty.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.ClientConn) ExperimentServiceClient

type ExperimentServiceServer 

type ExperimentServiceServer interface {
	CreateExperiment(context.Context, *CreateExperimentRequest) (*Experiment, error)
	GetExperiment(context.Context, *GetExperimentRequest) (*Experiment, error)
	ListExperiment(context.Context, *ListExperimentsRequest) (*ListExperimentsResponse, error)
	DeleteExperiment(context.Context, *DeleteExperimentRequest) (*empty.Empty, error)
	ArchiveExperiment(context.Context, *ArchiveExperimentRequest) (*empty.Empty, error)
	UnarchiveExperiment(context.Context, *UnarchiveExperimentRequest) (*empty.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) EnumDescriptor 

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

func (Experiment_StorageState) String 

func (x Experiment_StorageState) String() string

type Filter 

type Filter struct {
	Predicates           []*Predicate `protobuf:"bytes,1,rep,name=predicates,proto3" json:"predicates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Filter) Descriptor 

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

func (*Filter) GetPredicates 

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

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

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

func (*Filter) XXX_Merge 

func (dst *Filter) XXX_Merge(src proto.Message)

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

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

type GetExperimentRequest 

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

func (*GetExperimentRequest) Descriptor 

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

func (*GetExperimentRequest) GetId 

func (m *GetExperimentRequest) GetId() string

func (*GetExperimentRequest) ProtoMessage 

func (*GetExperimentRequest) ProtoMessage()

func (*GetExperimentRequest) Reset 

func (m *GetExperimentRequest) Reset()

func (*GetExperimentRequest) String 

func (m *GetExperimentRequest) String() string

func (*GetExperimentRequest) XXX_DiscardUnknown 

func (m *GetExperimentRequest) XXX_DiscardUnknown()

func (*GetExperimentRequest) XXX_Marshal 

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

func (*GetExperimentRequest) XXX_Merge 

func (dst *GetExperimentRequest) XXX_Merge(src proto.Message)

func (*GetExperimentRequest) XXX_Size 

func (m *GetExperimentRequest) XXX_Size() int

func (*GetExperimentRequest) XXX_Unmarshal 

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

type GetJobRequest 

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

func (*GetJobRequest) Descriptor 

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

func (*GetJobRequest) GetId 

func (m *GetJobRequest) GetId() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) Reset 

func (m *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (m *GetJobRequest) String() string

func (*GetJobRequest) XXX_DiscardUnknown 

func (m *GetJobRequest) XXX_DiscardUnknown()

func (*GetJobRequest) XXX_Marshal 

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

func (*GetJobRequest) XXX_Merge 

func (dst *GetJobRequest) XXX_Merge(src proto.Message)

func (*GetJobRequest) XXX_Size 

func (m *GetJobRequest) XXX_Size() int

func (*GetJobRequest) XXX_Unmarshal 

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

type GetPipelineRequest 

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

func (*GetPipelineRequest) Descriptor 

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

func (*GetPipelineRequest) GetId 

func (m *GetPipelineRequest) GetId() string

func (*GetPipelineRequest) ProtoMessage 

func (*GetPipelineRequest) ProtoMessage()

func (*GetPipelineRequest) Reset 

func (m *GetPipelineRequest) Reset()

func (*GetPipelineRequest) String 

func (m *GetPipelineRequest) String() string

func (*GetPipelineRequest) XXX_DiscardUnknown 

func (m *GetPipelineRequest) XXX_DiscardUnknown()

func (*GetPipelineRequest) XXX_Marshal 

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

func (*GetPipelineRequest) XXX_Merge 

func (dst *GetPipelineRequest) XXX_Merge(src proto.Message)

func (*GetPipelineRequest) XXX_Size 

func (m *GetPipelineRequest) XXX_Size() int

func (*GetPipelineRequest) XXX_Unmarshal 

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

type GetPipelineVersionRequest 

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

func (*GetPipelineVersionRequest) Descriptor 

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

func (*GetPipelineVersionRequest) GetVersionId 

func (m *GetPipelineVersionRequest) GetVersionId() string

func (*GetPipelineVersionRequest) ProtoMessage 

func (*GetPipelineVersionRequest) ProtoMessage()

func (*GetPipelineVersionRequest) Reset 

func (m *GetPipelineVersionRequest) Reset()

func (*GetPipelineVersionRequest) String 

func (m *GetPipelineVersionRequest) String() string

func (*GetPipelineVersionRequest) XXX_DiscardUnknown 

func (m *GetPipelineVersionRequest) XXX_DiscardUnknown()

func (*GetPipelineVersionRequest) XXX_Marshal 

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

func (*GetPipelineVersionRequest) XXX_Merge 

func (dst *GetPipelineVersionRequest) XXX_Merge(src proto.Message)

func (*GetPipelineVersionRequest) XXX_Size 

func (m *GetPipelineVersionRequest) XXX_Size() int

func (*GetPipelineVersionRequest) XXX_Unmarshal 

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

type GetPipelineVersionTemplateRequest 

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

func (*GetPipelineVersionTemplateRequest) Descriptor 

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

func (*GetPipelineVersionTemplateRequest) GetVersionId 

func (m *GetPipelineVersionTemplateRequest) GetVersionId() string

func (*GetPipelineVersionTemplateRequest) ProtoMessage 

func (*GetPipelineVersionTemplateRequest) ProtoMessage()

func (*GetPipelineVersionTemplateRequest) Reset 

func (m *GetPipelineVersionTemplateRequest) Reset()

func (*GetPipelineVersionTemplateRequest) String 

func (m *GetPipelineVersionTemplateRequest) String() string

func (*GetPipelineVersionTemplateRequest) XXX_DiscardUnknown 

func (m *GetPipelineVersionTemplateRequest) XXX_DiscardUnknown()

func (*GetPipelineVersionTemplateRequest) XXX_Marshal 

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

func (*GetPipelineVersionTemplateRequest) XXX_Merge 

func (dst *GetPipelineVersionTemplateRequest) XXX_Merge(src proto.Message)

func (*GetPipelineVersionTemplateRequest) XXX_Size 

func (m *GetPipelineVersionTemplateRequest) XXX_Size() int

func (*GetPipelineVersionTemplateRequest) XXX_Unmarshal 

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

type GetRunRequest 

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

func (*GetRunRequest) Descriptor 

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

func (*GetRunRequest) GetRunId 

func (m *GetRunRequest) GetRunId() string

func (*GetRunRequest) ProtoMessage 

func (*GetRunRequest) ProtoMessage()

func (*GetRunRequest) Reset 

func (m *GetRunRequest) Reset()

func (*GetRunRequest) String 

func (m *GetRunRequest) String() string

func (*GetRunRequest) XXX_DiscardUnknown 

func (m *GetRunRequest) XXX_DiscardUnknown()

func (*GetRunRequest) XXX_Marshal 

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

func (*GetRunRequest) XXX_Merge 

func (dst *GetRunRequest) XXX_Merge(src proto.Message)

func (*GetRunRequest) XXX_Size 

func (m *GetRunRequest) XXX_Size() int

func (*GetRunRequest) XXX_Unmarshal 

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

type GetTemplateRequest 

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

func (*GetTemplateRequest) Descriptor 

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

func (*GetTemplateRequest) GetId 

func (m *GetTemplateRequest) GetId() string

func (*GetTemplateRequest) ProtoMessage 

func (*GetTemplateRequest) ProtoMessage()

func (*GetTemplateRequest) Reset 

func (m *GetTemplateRequest) Reset()

func (*GetTemplateRequest) String 

func (m *GetTemplateRequest) String() string

func (*GetTemplateRequest) XXX_DiscardUnknown 

func (m *GetTemplateRequest) XXX_DiscardUnknown()

func (*GetTemplateRequest) XXX_Marshal 

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

func (*GetTemplateRequest) XXX_Merge 

func (dst *GetTemplateRequest) XXX_Merge(src proto.Message)

func (*GetTemplateRequest) XXX_Size 

func (m *GetTemplateRequest) XXX_Size() int

func (*GetTemplateRequest) XXX_Unmarshal 

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

type GetTemplateResponse 

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

func (*GetTemplateResponse) Descriptor 

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

func (*GetTemplateResponse) GetTemplate 

func (m *GetTemplateResponse) GetTemplate() string

func (*GetTemplateResponse) ProtoMessage 

func (*GetTemplateResponse) ProtoMessage()

func (*GetTemplateResponse) Reset 

func (m *GetTemplateResponse) Reset()

func (*GetTemplateResponse) String 

func (m *GetTemplateResponse) String() string

func (*GetTemplateResponse) XXX_DiscardUnknown 

func (m *GetTemplateResponse) XXX_DiscardUnknown()

func (*GetTemplateResponse) XXX_Marshal 

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

func (*GetTemplateResponse) XXX_Merge 

func (dst *GetTemplateResponse) XXX_Merge(src proto.Message)

func (*GetTemplateResponse) XXX_Size 

func (m *GetTemplateResponse) XXX_Size() int

func (*GetTemplateResponse) XXX_Unmarshal 

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

type IntValues 

type IntValues struct {
	Values               []int32  `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IntValues) Descriptor 

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

func (*IntValues) GetValues 

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

func (*IntValues) ProtoMessage 

func (*IntValues) ProtoMessage()

func (*IntValues) Reset 

func (m *IntValues) Reset()

func (*IntValues) String 

func (m *IntValues) String() string

func (*IntValues) XXX_DiscardUnknown 

func (m *IntValues) XXX_DiscardUnknown()

func (*IntValues) XXX_Marshal 

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

func (*IntValues) XXX_Merge 

func (dst *IntValues) XXX_Merge(src proto.Message)

func (*IntValues) XXX_Size 

func (m *IntValues) XXX_Size() int

func (*IntValues) XXX_Unmarshal 

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

type Job 

type Job struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string               `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	PipelineSpec         *PipelineSpec        `protobuf:"bytes,4,opt,name=pipeline_spec,json=pipelineSpec,proto3" json:"pipeline_spec,omitempty"`
	ResourceReferences   []*ResourceReference `protobuf:"bytes,5,rep,name=resource_references,json=resourceReferences,proto3" json:"resource_references,omitempty"`
	ServiceAccount       string               `protobuf:"bytes,18,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	MaxConcurrency       int64                `protobuf:"varint,6,opt,name=max_concurrency,json=maxConcurrency,proto3" json:"max_concurrency,omitempty"`
	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"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Status               string               `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`
	Error                string               `protobuf:"bytes,12,opt,name=error,proto3" json:"error,omitempty"`
	Enabled              bool                 `protobuf:"varint,16,opt,name=enabled,proto3" json:"enabled,omitempty"`
	NoCatchup            bool                 `protobuf:"varint,17,opt,name=no_catchup,json=noCatchup,proto3" json:"no_catchup,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Job) Descriptor 

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

func (*Job) GetCreatedAt 

func (m *Job) GetCreatedAt() *timestamp.Timestamp

func (*Job) GetDescription 

func (m *Job) GetDescription() string

func (*Job) GetEnabled 

func (m *Job) GetEnabled() bool

func (*Job) GetError 

func (m *Job) GetError() string

func (*Job) GetId 

func (m *Job) GetId() string

func (*Job) GetMaxConcurrency 

func (m *Job) GetMaxConcurrency() int64

func (*Job) GetMode 

func (m *Job) GetMode() Job_Mode

func (*Job) GetName 

func (m *Job) GetName() string

func (*Job) GetNoCatchup 

func (m *Job) GetNoCatchup() bool

func (*Job) GetPipelineSpec 

func (m *Job) GetPipelineSpec() *PipelineSpec

func (*Job) GetResourceReferences 

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

func (*Job) GetServiceAccount 

func (m *Job) GetServiceAccount() string

func (*Job) GetStatus 

func (m *Job) GetStatus() string

func (*Job) GetTrigger 

func (m *Job) GetTrigger() *Trigger

func (*Job) GetUpdatedAt 

func (m *Job) GetUpdatedAt() *timestamp.Timestamp

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

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

func (*Job) XXX_Merge 

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

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

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

type JobServiceClient 

type JobServiceClient interface {
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	EnableJob(ctx context.Context, in *EnableJobRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DisableJob(ctx context.Context, in *DisableJobRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*empty.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.ClientConn) JobServiceClient

type JobServiceServer 

type JobServiceServer interface {
	CreateJob(context.Context, *CreateJobRequest) (*Job, error)
	GetJob(context.Context, *GetJobRequest) (*Job, error)
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	EnableJob(context.Context, *EnableJobRequest) (*empty.Empty, error)
	DisableJob(context.Context, *DisableJobRequest) (*empty.Empty, error)
	DeleteJob(context.Context, *DeleteJobRequest) (*empty.Empty, error)
}

JobServiceServer is the server API for JobService service.

type Job_Mode 

type Job_Mode int32
const (
	Job_UNKNOWN_MODE Job_Mode = 0
	Job_ENABLED      Job_Mode = 1
	Job_DISABLED     Job_Mode = 2
)

func (Job_Mode) EnumDescriptor 

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

func (Job_Mode) String 

func (x Job_Mode) String() string

type ListExperimentsRequest 

type ListExperimentsRequest struct {
	PageToken            string       `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	PageSize             int32        `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	SortBy               string       `protobuf:"bytes,3,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	Filter               string       `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	ResourceReferenceKey *ResourceKey `protobuf:"bytes,5,opt,name=resource_reference_key,json=resourceReferenceKey,proto3" json:"resource_reference_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListExperimentsRequest) Descriptor 

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

func (*ListExperimentsRequest) GetFilter 

func (m *ListExperimentsRequest) GetFilter() string

func (*ListExperimentsRequest) GetPageSize 

func (m *ListExperimentsRequest) GetPageSize() int32

func (*ListExperimentsRequest) GetPageToken 

func (m *ListExperimentsRequest) GetPageToken() string

func (*ListExperimentsRequest) GetResourceReferenceKey 

func (m *ListExperimentsRequest) GetResourceReferenceKey() *ResourceKey

func (*ListExperimentsRequest) GetSortBy 

func (m *ListExperimentsRequest) GetSortBy() string

func (*ListExperimentsRequest) ProtoMessage 

func (*ListExperimentsRequest) ProtoMessage()

func (*ListExperimentsRequest) Reset 

func (m *ListExperimentsRequest) Reset()

func (*ListExperimentsRequest) String 

func (m *ListExperimentsRequest) String() string

func (*ListExperimentsRequest) XXX_DiscardUnknown 

func (m *ListExperimentsRequest) XXX_DiscardUnknown()

func (*ListExperimentsRequest) XXX_Marshal 

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

func (*ListExperimentsRequest) XXX_Merge 

func (dst *ListExperimentsRequest) XXX_Merge(src proto.Message)

func (*ListExperimentsRequest) XXX_Size 

func (m *ListExperimentsRequest) XXX_Size() int

func (*ListExperimentsRequest) XXX_Unmarshal 

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

type ListExperimentsResponse 

type ListExperimentsResponse struct {
	Experiments          []*Experiment `protobuf:"bytes,1,rep,name=experiments,proto3" json:"experiments,omitempty"`
	TotalSize            int32         `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	NextPageToken        string        `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListExperimentsResponse) Descriptor 

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

func (*ListExperimentsResponse) GetExperiments 

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

func (*ListExperimentsResponse) GetNextPageToken 

func (m *ListExperimentsResponse) GetNextPageToken() string

func (*ListExperimentsResponse) GetTotalSize 

func (m *ListExperimentsResponse) GetTotalSize() int32

func (*ListExperimentsResponse) ProtoMessage 

func (*ListExperimentsResponse) ProtoMessage()

func (*ListExperimentsResponse) Reset 

func (m *ListExperimentsResponse) Reset()

func (*ListExperimentsResponse) String 

func (m *ListExperimentsResponse) String() string

func (*ListExperimentsResponse) XXX_DiscardUnknown 

func (m *ListExperimentsResponse) XXX_DiscardUnknown()

func (*ListExperimentsResponse) XXX_Marshal 

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

func (*ListExperimentsResponse) XXX_Merge 

func (dst *ListExperimentsResponse) XXX_Merge(src proto.Message)

func (*ListExperimentsResponse) XXX_Size 

func (m *ListExperimentsResponse) XXX_Size() int

func (*ListExperimentsResponse) XXX_Unmarshal 

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

type ListJobsRequest 

type ListJobsRequest struct {
	PageToken            string       `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	PageSize             int32        `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	SortBy               string       `protobuf:"bytes,3,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	ResourceReferenceKey *ResourceKey `protobuf:"bytes,4,opt,name=resource_reference_key,json=resourceReferenceKey,proto3" json:"resource_reference_key,omitempty"`
	Filter               string       `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListJobsRequest) Descriptor 

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

func (*ListJobsRequest) GetFilter 

func (m *ListJobsRequest) GetFilter() string

func (*ListJobsRequest) GetPageSize 

func (m *ListJobsRequest) GetPageSize() int32

func (*ListJobsRequest) GetPageToken 

func (m *ListJobsRequest) GetPageToken() string

func (*ListJobsRequest) GetResourceReferenceKey 

func (m *ListJobsRequest) GetResourceReferenceKey() *ResourceKey

func (*ListJobsRequest) GetSortBy 

func (m *ListJobsRequest) GetSortBy() string

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) Reset 

func (m *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (m *ListJobsRequest) String() string

func (*ListJobsRequest) XXX_DiscardUnknown 

func (m *ListJobsRequest) XXX_DiscardUnknown()

func (*ListJobsRequest) XXX_Marshal 

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

func (*ListJobsRequest) XXX_Merge 

func (dst *ListJobsRequest) XXX_Merge(src proto.Message)

func (*ListJobsRequest) XXX_Size 

func (m *ListJobsRequest) XXX_Size() int

func (*ListJobsRequest) XXX_Unmarshal 

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

type ListJobsResponse 

type ListJobsResponse struct {
	Jobs                 []*Job   `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	TotalSize            int32    `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListJobsResponse) Descriptor 

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

func (*ListJobsResponse) GetJobs 

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

func (*ListJobsResponse) GetNextPageToken 

func (m *ListJobsResponse) GetNextPageToken() string

func (*ListJobsResponse) GetTotalSize 

func (m *ListJobsResponse) GetTotalSize() int32

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) Reset 

func (m *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (m *ListJobsResponse) String() string

func (*ListJobsResponse) XXX_DiscardUnknown 

func (m *ListJobsResponse) XXX_DiscardUnknown()

func (*ListJobsResponse) XXX_Marshal 

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

func (*ListJobsResponse) XXX_Merge 

func (dst *ListJobsResponse) XXX_Merge(src proto.Message)

func (*ListJobsResponse) XXX_Size 

func (m *ListJobsResponse) XXX_Size() int

func (*ListJobsResponse) XXX_Unmarshal 

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

type ListPipelineVersionsRequest 

type ListPipelineVersionsRequest struct {
	ResourceKey          *ResourceKey `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	PageSize             int32        `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken            string       `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	SortBy               string       `protobuf:"bytes,4,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	Filter               string       `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListPipelineVersionsRequest) Descriptor 

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

func (*ListPipelineVersionsRequest) GetFilter 

func (m *ListPipelineVersionsRequest) GetFilter() string

func (*ListPipelineVersionsRequest) GetPageSize 

func (m *ListPipelineVersionsRequest) GetPageSize() int32

func (*ListPipelineVersionsRequest) GetPageToken 

func (m *ListPipelineVersionsRequest) GetPageToken() string

func (*ListPipelineVersionsRequest) GetResourceKey 

func (m *ListPipelineVersionsRequest) GetResourceKey() *ResourceKey

func (*ListPipelineVersionsRequest) GetSortBy 

func (m *ListPipelineVersionsRequest) GetSortBy() string

func (*ListPipelineVersionsRequest) ProtoMessage 

func (*ListPipelineVersionsRequest) ProtoMessage()

func (*ListPipelineVersionsRequest) Reset 

func (m *ListPipelineVersionsRequest) Reset()

func (*ListPipelineVersionsRequest) String 

func (m *ListPipelineVersionsRequest) String() string

func (*ListPipelineVersionsRequest) XXX_DiscardUnknown 

func (m *ListPipelineVersionsRequest) XXX_DiscardUnknown()

func (*ListPipelineVersionsRequest) XXX_Marshal 

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

func (*ListPipelineVersionsRequest) XXX_Merge 

func (dst *ListPipelineVersionsRequest) XXX_Merge(src proto.Message)

func (*ListPipelineVersionsRequest) XXX_Size 

func (m *ListPipelineVersionsRequest) XXX_Size() int

func (*ListPipelineVersionsRequest) XXX_Unmarshal 

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

type ListPipelineVersionsResponse 

type ListPipelineVersionsResponse struct {
	Versions             []*PipelineVersion `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"`
	NextPageToken        string             `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	TotalSize            int32              `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ListPipelineVersionsResponse) Descriptor 

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

func (*ListPipelineVersionsResponse) GetNextPageToken 

func (m *ListPipelineVersionsResponse) GetNextPageToken() string

func (*ListPipelineVersionsResponse) GetTotalSize 

func (m *ListPipelineVersionsResponse) GetTotalSize() int32

func (*ListPipelineVersionsResponse) GetVersions 

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

func (*ListPipelineVersionsResponse) ProtoMessage 

func (*ListPipelineVersionsResponse) ProtoMessage()

func (*ListPipelineVersionsResponse) Reset 

func (m *ListPipelineVersionsResponse) Reset()

func (*ListPipelineVersionsResponse) String 

func (m *ListPipelineVersionsResponse) String() string

func (*ListPipelineVersionsResponse) XXX_DiscardUnknown 

func (m *ListPipelineVersionsResponse) XXX_DiscardUnknown()

func (*ListPipelineVersionsResponse) XXX_Marshal 

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

func (*ListPipelineVersionsResponse) XXX_Merge 

func (dst *ListPipelineVersionsResponse) XXX_Merge(src proto.Message)

func (*ListPipelineVersionsResponse) XXX_Size 

func (m *ListPipelineVersionsResponse) XXX_Size() int

func (*ListPipelineVersionsResponse) XXX_Unmarshal 

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

type ListPipelinesRequest 

type ListPipelinesRequest struct {
	PageToken            string   `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	PageSize             int32    `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	SortBy               string   `protobuf:"bytes,3,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	Filter               string   `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPipelinesRequest) Descriptor 

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

func (*ListPipelinesRequest) GetFilter 

func (m *ListPipelinesRequest) GetFilter() string

func (*ListPipelinesRequest) GetPageSize 

func (m *ListPipelinesRequest) GetPageSize() int32

func (*ListPipelinesRequest) GetPageToken 

func (m *ListPipelinesRequest) GetPageToken() string

func (*ListPipelinesRequest) GetSortBy 

func (m *ListPipelinesRequest) GetSortBy() string

func (*ListPipelinesRequest) ProtoMessage 

func (*ListPipelinesRequest) ProtoMessage()

func (*ListPipelinesRequest) Reset 

func (m *ListPipelinesRequest) Reset()

func (*ListPipelinesRequest) String 

func (m *ListPipelinesRequest) String() string

func (*ListPipelinesRequest) XXX_DiscardUnknown 

func (m *ListPipelinesRequest) XXX_DiscardUnknown()

func (*ListPipelinesRequest) XXX_Marshal 

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

func (*ListPipelinesRequest) XXX_Merge 

func (dst *ListPipelinesRequest) XXX_Merge(src proto.Message)

func (*ListPipelinesRequest) XXX_Size 

func (m *ListPipelinesRequest) XXX_Size() int

func (*ListPipelinesRequest) XXX_Unmarshal 

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

type ListPipelinesResponse 

type ListPipelinesResponse struct {
	Pipelines            []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	TotalSize            int32       `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	NextPageToken        string      `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ListPipelinesResponse) Descriptor 

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

func (*ListPipelinesResponse) GetNextPageToken 

func (m *ListPipelinesResponse) GetNextPageToken() string

func (*ListPipelinesResponse) GetPipelines 

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

func (*ListPipelinesResponse) GetTotalSize 

func (m *ListPipelinesResponse) GetTotalSize() int32

func (*ListPipelinesResponse) ProtoMessage 

func (*ListPipelinesResponse) ProtoMessage()

func (*ListPipelinesResponse) Reset 

func (m *ListPipelinesResponse) Reset()

func (*ListPipelinesResponse) String 

func (m *ListPipelinesResponse) String() string

func (*ListPipelinesResponse) XXX_DiscardUnknown 

func (m *ListPipelinesResponse) XXX_DiscardUnknown()

func (*ListPipelinesResponse) XXX_Marshal 

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

func (*ListPipelinesResponse) XXX_Merge 

func (dst *ListPipelinesResponse) XXX_Merge(src proto.Message)

func (*ListPipelinesResponse) XXX_Size 

func (m *ListPipelinesResponse) XXX_Size() int

func (*ListPipelinesResponse) XXX_Unmarshal 

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

type ListRunsRequest 

type ListRunsRequest struct {
	PageToken            string       `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	PageSize             int32        `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	SortBy               string       `protobuf:"bytes,3,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	ResourceReferenceKey *ResourceKey `protobuf:"bytes,4,opt,name=resource_reference_key,json=resourceReferenceKey,proto3" json:"resource_reference_key,omitempty"`
	Filter               string       `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListRunsRequest) Descriptor 

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

func (*ListRunsRequest) GetFilter 

func (m *ListRunsRequest) GetFilter() string

func (*ListRunsRequest) GetPageSize 

func (m *ListRunsRequest) GetPageSize() int32

func (*ListRunsRequest) GetPageToken 

func (m *ListRunsRequest) GetPageToken() string

func (*ListRunsRequest) GetResourceReferenceKey 

func (m *ListRunsRequest) GetResourceReferenceKey() *ResourceKey

func (*ListRunsRequest) GetSortBy 

func (m *ListRunsRequest) GetSortBy() string

func (*ListRunsRequest) ProtoMessage 

func (*ListRunsRequest) ProtoMessage()

func (*ListRunsRequest) Reset 

func (m *ListRunsRequest) Reset()

func (*ListRunsRequest) String 

func (m *ListRunsRequest) String() string

func (*ListRunsRequest) XXX_DiscardUnknown 

func (m *ListRunsRequest) XXX_DiscardUnknown()

func (*ListRunsRequest) XXX_Marshal 

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

func (*ListRunsRequest) XXX_Merge 

func (dst *ListRunsRequest) XXX_Merge(src proto.Message)

func (*ListRunsRequest) XXX_Size 

func (m *ListRunsRequest) XXX_Size() int

func (*ListRunsRequest) XXX_Unmarshal 

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

type ListRunsResponse 

type ListRunsResponse struct {
	Runs                 []*Run   `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	TotalSize            int32    `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	NextPageToken        string   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListRunsResponse) Descriptor 

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

func (*ListRunsResponse) GetNextPageToken 

func (m *ListRunsResponse) GetNextPageToken() string

func (*ListRunsResponse) GetRuns 

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

func (*ListRunsResponse) GetTotalSize 

func (m *ListRunsResponse) GetTotalSize() int32

func (*ListRunsResponse) ProtoMessage 

func (*ListRunsResponse) ProtoMessage()

func (*ListRunsResponse) Reset 

func (m *ListRunsResponse) Reset()

func (*ListRunsResponse) String 

func (m *ListRunsResponse) String() string

func (*ListRunsResponse) XXX_DiscardUnknown 

func (m *ListRunsResponse) XXX_DiscardUnknown()

func (*ListRunsResponse) XXX_Marshal 

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

func (*ListRunsResponse) XXX_Merge 

func (dst *ListRunsResponse) XXX_Merge(src proto.Message)

func (*ListRunsResponse) XXX_Size 

func (m *ListRunsResponse) XXX_Size() int

func (*ListRunsResponse) XXX_Unmarshal 

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

type LongValues 

type LongValues struct {
	Values               []int64  `protobuf:"varint,3,rep,packed,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LongValues) Descriptor 

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

func (*LongValues) GetValues 

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

func (*LongValues) ProtoMessage 

func (*LongValues) ProtoMessage()

func (*LongValues) Reset 

func (m *LongValues) Reset()

func (*LongValues) String 

func (m *LongValues) String() string

func (*LongValues) XXX_DiscardUnknown 

func (m *LongValues) XXX_DiscardUnknown()

func (*LongValues) XXX_Marshal 

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

func (*LongValues) XXX_Merge 

func (dst *LongValues) XXX_Merge(src proto.Message)

func (*LongValues) XXX_Size 

func (m *LongValues) XXX_Size() int

func (*LongValues) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Parameter) Descriptor 

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

func (*Parameter) GetName 

func (m *Parameter) GetName() string

func (*Parameter) GetValue 

func (m *Parameter) GetValue() string

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) String 

func (m *Parameter) String() string

func (*Parameter) XXX_DiscardUnknown 

func (m *Parameter) XXX_DiscardUnknown()

func (*Parameter) XXX_Marshal 

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

func (*Parameter) XXX_Merge 

func (dst *Parameter) XXX_Merge(src proto.Message)

func (*Parameter) XXX_Size 

func (m *Parameter) XXX_Size() int

func (*Parameter) XXX_Unmarshal 

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

type PeriodicSchedule 

type PeriodicSchedule struct {
	StartTime            *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime              *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	IntervalSecond       int64                `protobuf:"varint,3,opt,name=interval_second,json=intervalSecond,proto3" json:"interval_second,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PeriodicSchedule) Descriptor 

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

func (*PeriodicSchedule) GetEndTime 

func (m *PeriodicSchedule) GetEndTime() *timestamp.Timestamp

func (*PeriodicSchedule) GetIntervalSecond 

func (m *PeriodicSchedule) GetIntervalSecond() int64

func (*PeriodicSchedule) GetStartTime 

func (m *PeriodicSchedule) GetStartTime() *timestamp.Timestamp

func (*PeriodicSchedule) ProtoMessage 

func (*PeriodicSchedule) ProtoMessage()

func (*PeriodicSchedule) Reset 

func (m *PeriodicSchedule) Reset()

func (*PeriodicSchedule) String 

func (m *PeriodicSchedule) String() string

func (*PeriodicSchedule) XXX_DiscardUnknown 

func (m *PeriodicSchedule) XXX_DiscardUnknown()

func (*PeriodicSchedule) XXX_Marshal 

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

func (*PeriodicSchedule) XXX_Merge 

func (dst *PeriodicSchedule) XXX_Merge(src proto.Message)

func (*PeriodicSchedule) XXX_Size 

func (m *PeriodicSchedule) XXX_Size() int

func (*PeriodicSchedule) XXX_Unmarshal 

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

type Pipeline 

type Pipeline struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Name                 string               `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description          string               `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Parameters           []*Parameter         `protobuf:"bytes,5,rep,name=parameters,proto3" json:"parameters,omitempty"`
	Url                  *Url                 `protobuf:"bytes,7,opt,name=url,proto3" json:"url,omitempty"`
	Error                string               `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	DefaultVersion       *PipelineVersion     `protobuf:"bytes,8,opt,name=default_version,json=defaultVersion,proto3" json:"default_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Pipeline) Descriptor 

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

func (*Pipeline) GetCreatedAt 

func (m *Pipeline) GetCreatedAt() *timestamp.Timestamp

func (*Pipeline) GetDefaultVersion 

func (m *Pipeline) GetDefaultVersion() *PipelineVersion

func (*Pipeline) GetDescription 

func (m *Pipeline) GetDescription() string

func (*Pipeline) GetError 

func (m *Pipeline) GetError() string

func (*Pipeline) GetId 

func (m *Pipeline) GetId() string

func (*Pipeline) GetName 

func (m *Pipeline) GetName() string

func (*Pipeline) GetParameters 

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

func (*Pipeline) GetUrl 

func (m *Pipeline) GetUrl() *Url

func (*Pipeline) ProtoMessage 

func (*Pipeline) ProtoMessage()

func (*Pipeline) Reset 

func (m *Pipeline) Reset()

func (*Pipeline) String 

func (m *Pipeline) String() string

func (*Pipeline) XXX_DiscardUnknown 

func (m *Pipeline) XXX_DiscardUnknown()

func (*Pipeline) XXX_Marshal 

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

func (*Pipeline) XXX_Merge 

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

func (*Pipeline) XXX_Size 

func (m *Pipeline) XXX_Size() int

func (*Pipeline) XXX_Unmarshal 

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

type PipelineRuntime 

type PipelineRuntime struct {
	PipelineManifest     string   `protobuf:"bytes,10,opt,name=pipeline_manifest,json=pipelineManifest,proto3" json:"pipeline_manifest,omitempty"`
	WorkflowManifest     string   `protobuf:"bytes,11,opt,name=workflow_manifest,json=workflowManifest,proto3" json:"workflow_manifest,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PipelineRuntime) Descriptor 

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

func (*PipelineRuntime) GetPipelineManifest 

func (m *PipelineRuntime) GetPipelineManifest() string

func (*PipelineRuntime) GetWorkflowManifest 

func (m *PipelineRuntime) GetWorkflowManifest() string

func (*PipelineRuntime) ProtoMessage 

func (*PipelineRuntime) ProtoMessage()

func (*PipelineRuntime) Reset 

func (m *PipelineRuntime) Reset()

func (*PipelineRuntime) String 

func (m *PipelineRuntime) String() string

func (*PipelineRuntime) XXX_DiscardUnknown 

func (m *PipelineRuntime) XXX_DiscardUnknown()

func (*PipelineRuntime) XXX_Marshal 

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

func (*PipelineRuntime) XXX_Merge 

func (dst *PipelineRuntime) XXX_Merge(src proto.Message)

func (*PipelineRuntime) XXX_Size 

func (m *PipelineRuntime) XXX_Size() int

func (*PipelineRuntime) XXX_Unmarshal 

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

type PipelineServiceClient 

type PipelineServiceClient interface {
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*Pipeline, error)
	GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*Pipeline, error)
	ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error)
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetTemplate(ctx context.Context, in *GetTemplateRequest, opts ...grpc.CallOption) (*GetTemplateResponse, error)
	CreatePipelineVersion(ctx context.Context, in *CreatePipelineVersionRequest, opts ...grpc.CallOption) (*PipelineVersion, error)
	GetPipelineVersion(ctx context.Context, in *GetPipelineVersionRequest, opts ...grpc.CallOption) (*PipelineVersion, error)
	ListPipelineVersions(ctx context.Context, in *ListPipelineVersionsRequest, opts ...grpc.CallOption) (*ListPipelineVersionsResponse, error)
	DeletePipelineVersion(ctx context.Context, in *DeletePipelineVersionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetPipelineVersionTemplate(ctx context.Context, in *GetPipelineVersionTemplateRequest, opts ...grpc.CallOption) (*GetTemplateResponse, 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.ClientConn) PipelineServiceClient

type PipelineServiceServer 

type PipelineServiceServer interface {
	CreatePipeline(context.Context, *CreatePipelineRequest) (*Pipeline, error)
	GetPipeline(context.Context, *GetPipelineRequest) (*Pipeline, error)
	ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error)
	DeletePipeline(context.Context, *DeletePipelineRequest) (*empty.Empty, error)
	GetTemplate(context.Context, *GetTemplateRequest) (*GetTemplateResponse, error)
	CreatePipelineVersion(context.Context, *CreatePipelineVersionRequest) (*PipelineVersion, error)
	GetPipelineVersion(context.Context, *GetPipelineVersionRequest) (*PipelineVersion, error)
	ListPipelineVersions(context.Context, *ListPipelineVersionsRequest) (*ListPipelineVersionsResponse, error)
	DeletePipelineVersion(context.Context, *DeletePipelineVersionRequest) (*empty.Empty, error)
	GetPipelineVersionTemplate(context.Context, *GetPipelineVersionTemplateRequest) (*GetTemplateResponse, error)
}

PipelineServiceServer is the server API for PipelineService service.

type PipelineSpec 

type PipelineSpec struct {
	PipelineId           string       `protobuf:"bytes,1,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	PipelineName         string       `protobuf:"bytes,5,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"`
	WorkflowManifest     string       `protobuf:"bytes,2,opt,name=workflow_manifest,json=workflowManifest,proto3" json:"workflow_manifest,omitempty"`
	PipelineManifest     string       `protobuf:"bytes,3,opt,name=pipeline_manifest,json=pipelineManifest,proto3" json:"pipeline_manifest,omitempty"`
	Parameters           []*Parameter `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PipelineSpec) Descriptor 

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

func (*PipelineSpec) GetParameters 

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

func (*PipelineSpec) GetPipelineId 

func (m *PipelineSpec) GetPipelineId() string

func (*PipelineSpec) GetPipelineManifest 

func (m *PipelineSpec) GetPipelineManifest() string

func (*PipelineSpec) GetPipelineName 

func (m *PipelineSpec) GetPipelineName() string

func (*PipelineSpec) GetWorkflowManifest 

func (m *PipelineSpec) GetWorkflowManifest() string

func (*PipelineSpec) ProtoMessage 

func (*PipelineSpec) ProtoMessage()

func (*PipelineSpec) Reset 

func (m *PipelineSpec) Reset()

func (*PipelineSpec) String 

func (m *PipelineSpec) String() string

func (*PipelineSpec) XXX_DiscardUnknown 

func (m *PipelineSpec) XXX_DiscardUnknown()

func (*PipelineSpec) XXX_Marshal 

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

func (*PipelineSpec) XXX_Merge 

func (dst *PipelineSpec) XXX_Merge(src proto.Message)

func (*PipelineSpec) XXX_Size 

func (m *PipelineSpec) XXX_Size() int

func (*PipelineSpec) XXX_Unmarshal 

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

type PipelineVersion 

type PipelineVersion struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Parameters           []*Parameter         `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty"`
	CodeSourceUrl        string               `protobuf:"bytes,5,opt,name=code_source_url,json=codeSourceUrl,proto3" json:"code_source_url,omitempty"`
	PackageUrl           *Url                 `protobuf:"bytes,6,opt,name=package_url,json=packageUrl,proto3" json:"package_url,omitempty"`
	ResourceReferences   []*ResourceReference `protobuf:"bytes,7,rep,name=resource_references,json=resourceReferences,proto3" json:"resource_references,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PipelineVersion) Descriptor 

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

func (*PipelineVersion) GetCodeSourceUrl 

func (m *PipelineVersion) GetCodeSourceUrl() string

func (*PipelineVersion) GetCreatedAt 

func (m *PipelineVersion) GetCreatedAt() *timestamp.Timestamp

func (*PipelineVersion) GetId 

func (m *PipelineVersion) GetId() string

func (*PipelineVersion) GetName 

func (m *PipelineVersion) GetName() string

func (*PipelineVersion) GetPackageUrl 

func (m *PipelineVersion) GetPackageUrl() *Url

func (*PipelineVersion) GetParameters 

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

func (*PipelineVersion) GetResourceReferences 

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

func (*PipelineVersion) ProtoMessage 

func (*PipelineVersion) ProtoMessage()

func (*PipelineVersion) Reset 

func (m *PipelineVersion) Reset()

func (*PipelineVersion) String 

func (m *PipelineVersion) String() string

func (*PipelineVersion) XXX_DiscardUnknown 

func (m *PipelineVersion) XXX_DiscardUnknown()

func (*PipelineVersion) XXX_Marshal 

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

func (*PipelineVersion) XXX_Merge 

func (dst *PipelineVersion) XXX_Merge(src proto.Message)

func (*PipelineVersion) XXX_Size 

func (m *PipelineVersion) XXX_Size() int

func (*PipelineVersion) XXX_Unmarshal 

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

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 valid to be assigned to Value:
	//	*Predicate_IntValue
	//	*Predicate_LongValue
	//	*Predicate_StringValue
	//	*Predicate_TimestampValue
	//	*Predicate_IntValues
	//	*Predicate_LongValues
	//	*Predicate_StringValues
	Value                isPredicate_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Predicate) Descriptor 

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

func (*Predicate) GetIntValue 

func (m *Predicate) GetIntValue() int32

func (*Predicate) GetIntValues 

func (m *Predicate) GetIntValues() *IntValues

func (*Predicate) GetKey 

func (m *Predicate) GetKey() string

func (*Predicate) GetLongValue 

func (m *Predicate) GetLongValue() int64

func (*Predicate) GetLongValues 

func (m *Predicate) GetLongValues() *LongValues

func (*Predicate) GetOp 

func (m *Predicate) GetOp() Predicate_Op

func (*Predicate) GetStringValue 

func (m *Predicate) GetStringValue() string

func (*Predicate) GetStringValues 

func (m *Predicate) GetStringValues() *StringValues

func (*Predicate) GetTimestampValue 

func (m *Predicate) GetTimestampValue() *timestamp.Timestamp

func (*Predicate) GetValue 

func (m *Predicate) GetValue() isPredicate_Value

func (*Predicate) ProtoMessage 

func (*Predicate) ProtoMessage()

func (*Predicate) Reset 

func (m *Predicate) Reset()

func (*Predicate) String 

func (m *Predicate) String() string

func (*Predicate) XXX_DiscardUnknown 

func (m *Predicate) XXX_DiscardUnknown()

func (*Predicate) XXX_Marshal 

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

func (*Predicate) XXX_Merge 

func (dst *Predicate) XXX_Merge(src proto.Message)

func (*Predicate) XXX_OneofFuncs 

func (*Predicate) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Predicate) XXX_Size 

func (m *Predicate) XXX_Size() int

func (*Predicate) XXX_Unmarshal 

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

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 {
	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
const (
	Predicate_UNKNOWN             Predicate_Op = 0
	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
	Predicate_IN                  Predicate_Op = 8
	Predicate_IS_SUBSTRING        Predicate_Op = 9
)

func (Predicate_Op) EnumDescriptor 

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

func (Predicate_Op) String 

func (x Predicate_Op) String() string

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 {
	TimestampValue *timestamp.Timestamp `protobuf:"bytes,6,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

type ReadArtifactRequest 

type ReadArtifactRequest struct {
	RunId                string   `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	NodeId               string   `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ArtifactName         string   `protobuf:"bytes,3,opt,name=artifact_name,json=artifactName,proto3" json:"artifact_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadArtifactRequest) Descriptor 

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

func (*ReadArtifactRequest) GetArtifactName 

func (m *ReadArtifactRequest) GetArtifactName() string

func (*ReadArtifactRequest) GetNodeId 

func (m *ReadArtifactRequest) GetNodeId() string

func (*ReadArtifactRequest) GetRunId 

func (m *ReadArtifactRequest) GetRunId() string

func (*ReadArtifactRequest) ProtoMessage 

func (*ReadArtifactRequest) ProtoMessage()

func (*ReadArtifactRequest) Reset 

func (m *ReadArtifactRequest) Reset()

func (*ReadArtifactRequest) String 

func (m *ReadArtifactRequest) String() string

func (*ReadArtifactRequest) XXX_DiscardUnknown 

func (m *ReadArtifactRequest) XXX_DiscardUnknown()

func (*ReadArtifactRequest) XXX_Marshal 

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

func (*ReadArtifactRequest) XXX_Merge 

func (dst *ReadArtifactRequest) XXX_Merge(src proto.Message)

func (*ReadArtifactRequest) XXX_Size 

func (m *ReadArtifactRequest) XXX_Size() int

func (*ReadArtifactRequest) XXX_Unmarshal 

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

type ReadArtifactResponse 

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

func (*ReadArtifactResponse) Descriptor 

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

func (*ReadArtifactResponse) GetData 

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

func (*ReadArtifactResponse) ProtoMessage 

func (*ReadArtifactResponse) ProtoMessage()

func (*ReadArtifactResponse) Reset 

func (m *ReadArtifactResponse) Reset()

func (*ReadArtifactResponse) String 

func (m *ReadArtifactResponse) String() string

func (*ReadArtifactResponse) XXX_DiscardUnknown 

func (m *ReadArtifactResponse) XXX_DiscardUnknown()

func (*ReadArtifactResponse) XXX_Marshal 

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

func (*ReadArtifactResponse) XXX_Merge 

func (dst *ReadArtifactResponse) XXX_Merge(src proto.Message)

func (*ReadArtifactResponse) XXX_Size 

func (m *ReadArtifactResponse) XXX_Size() int

func (*ReadArtifactResponse) XXX_Unmarshal 

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

type Relationship 

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

func (Relationship) EnumDescriptor 

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

func (Relationship) String 

func (x Relationship) String() string

type ReportRunMetricsRequest 

type ReportRunMetricsRequest struct {
	RunId                string       `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Metrics              []*RunMetric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ReportRunMetricsRequest) Descriptor 

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

func (*ReportRunMetricsRequest) GetMetrics 

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

func (*ReportRunMetricsRequest) GetRunId 

func (m *ReportRunMetricsRequest) GetRunId() string

func (*ReportRunMetricsRequest) ProtoMessage 

func (*ReportRunMetricsRequest) ProtoMessage()

func (*ReportRunMetricsRequest) Reset 

func (m *ReportRunMetricsRequest) Reset()

func (*ReportRunMetricsRequest) String 

func (m *ReportRunMetricsRequest) String() string

func (*ReportRunMetricsRequest) XXX_DiscardUnknown 

func (m *ReportRunMetricsRequest) XXX_DiscardUnknown()

func (*ReportRunMetricsRequest) XXX_Marshal 

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

func (*ReportRunMetricsRequest) XXX_Merge 

func (dst *ReportRunMetricsRequest) XXX_Merge(src proto.Message)

func (*ReportRunMetricsRequest) XXX_Size 

func (m *ReportRunMetricsRequest) XXX_Size() int

func (*ReportRunMetricsRequest) XXX_Unmarshal 

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

type ReportRunMetricsResponse 

type ReportRunMetricsResponse struct {
	Results              []*ReportRunMetricsResponse_ReportRunMetricResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                          `json:"-"`
	XXX_unrecognized     []byte                                            `json:"-"`
	XXX_sizecache        int32                                             `json:"-"`
}

func (*ReportRunMetricsResponse) Descriptor 

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

func (*ReportRunMetricsResponse) GetResults 

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

func (*ReportRunMetricsResponse) ProtoMessage 

func (*ReportRunMetricsResponse) ProtoMessage()

func (*ReportRunMetricsResponse) Reset 

func (m *ReportRunMetricsResponse) Reset()

func (*ReportRunMetricsResponse) String 

func (m *ReportRunMetricsResponse) String() string

func (*ReportRunMetricsResponse) XXX_DiscardUnknown 

func (m *ReportRunMetricsResponse) XXX_DiscardUnknown()

func (*ReportRunMetricsResponse) XXX_Marshal 

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

func (*ReportRunMetricsResponse) XXX_Merge 

func (dst *ReportRunMetricsResponse) XXX_Merge(src proto.Message)

func (*ReportRunMetricsResponse) XXX_Size 

func (m *ReportRunMetricsResponse) XXX_Size() int

func (*ReportRunMetricsResponse) XXX_Unmarshal 

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

type ReportRunMetricsResponse_ReportRunMetricResult 

type ReportRunMetricsResponse_ReportRunMetricResult struct {
	MetricName           string                                                `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	MetricNodeId         string                                                `protobuf:"bytes,2,opt,name=metric_node_id,json=metricNodeId,proto3" json:"metric_node_id,omitempty"`
	Status               ReportRunMetricsResponse_ReportRunMetricResult_Status `` /* 129-byte string literal not displayed */
	Message              string                                                `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                              `json:"-"`
	XXX_unrecognized     []byte                                                `json:"-"`
	XXX_sizecache        int32                                                 `json:"-"`
}

func (*ReportRunMetricsResponse_ReportRunMetricResult) Descriptor 

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

func (*ReportRunMetricsResponse_ReportRunMetricResult) GetMessage 

func (m *ReportRunMetricsResponse_ReportRunMetricResult) GetMessage() string

func (*ReportRunMetricsResponse_ReportRunMetricResult) GetMetricName 

func (m *ReportRunMetricsResponse_ReportRunMetricResult) GetMetricName() string

func (*ReportRunMetricsResponse_ReportRunMetricResult) GetMetricNodeId 

func (m *ReportRunMetricsResponse_ReportRunMetricResult) GetMetricNodeId() string

func (*ReportRunMetricsResponse_ReportRunMetricResult) GetStatus 

func (m *ReportRunMetricsResponse_ReportRunMetricResult) GetStatus() ReportRunMetricsResponse_ReportRunMetricResult_Status

func (*ReportRunMetricsResponse_ReportRunMetricResult) ProtoMessage 

func (*ReportRunMetricsResponse_ReportRunMetricResult) ProtoMessage()

func (*ReportRunMetricsResponse_ReportRunMetricResult) Reset 

func (m *ReportRunMetricsResponse_ReportRunMetricResult) Reset()

func (*ReportRunMetricsResponse_ReportRunMetricResult) String 

func (m *ReportRunMetricsResponse_ReportRunMetricResult) String() string

func (*ReportRunMetricsResponse_ReportRunMetricResult) XXX_DiscardUnknown 

func (m *ReportRunMetricsResponse_ReportRunMetricResult) XXX_DiscardUnknown()

func (*ReportRunMetricsResponse_ReportRunMetricResult) XXX_Marshal 

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

func (*ReportRunMetricsResponse_ReportRunMetricResult) XXX_Merge 

func (dst *ReportRunMetricsResponse_ReportRunMetricResult) XXX_Merge(src proto.Message)

func (*ReportRunMetricsResponse_ReportRunMetricResult) XXX_Size 

func (m *ReportRunMetricsResponse_ReportRunMetricResult) XXX_Size() int

func (*ReportRunMetricsResponse_ReportRunMetricResult) XXX_Unmarshal 

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

type ReportRunMetricsResponse_ReportRunMetricResult_Status 

type ReportRunMetricsResponse_ReportRunMetricResult_Status int32
const (
	ReportRunMetricsResponse_ReportRunMetricResult_UNSPECIFIED         ReportRunMetricsResponse_ReportRunMetricResult_Status = 0
	ReportRunMetricsResponse_ReportRunMetricResult_OK                  ReportRunMetricsResponse_ReportRunMetricResult_Status = 1
	ReportRunMetricsResponse_ReportRunMetricResult_INVALID_ARGUMENT    ReportRunMetricsResponse_ReportRunMetricResult_Status = 2
	ReportRunMetricsResponse_ReportRunMetricResult_DUPLICATE_REPORTING ReportRunMetricsResponse_ReportRunMetricResult_Status = 3
	ReportRunMetricsResponse_ReportRunMetricResult_INTERNAL_ERROR      ReportRunMetricsResponse_ReportRunMetricResult_Status = 4
)

func (ReportRunMetricsResponse_ReportRunMetricResult_Status) EnumDescriptor 

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

func (ReportRunMetricsResponse_ReportRunMetricResult_Status) String 

func (x ReportRunMetricsResponse_ReportRunMetricResult_Status) String() string

type ReportScheduledWorkflowRequest 

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

func (*ReportScheduledWorkflowRequest) Descriptor 

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

func (*ReportScheduledWorkflowRequest) GetScheduledWorkflow 

func (m *ReportScheduledWorkflowRequest) GetScheduledWorkflow() string

func (*ReportScheduledWorkflowRequest) ProtoMessage 

func (*ReportScheduledWorkflowRequest) ProtoMessage()

func (*ReportScheduledWorkflowRequest) Reset 

func (m *ReportScheduledWorkflowRequest) Reset()

func (*ReportScheduledWorkflowRequest) String 

func (m *ReportScheduledWorkflowRequest) String() string

func (*ReportScheduledWorkflowRequest) XXX_DiscardUnknown 

func (m *ReportScheduledWorkflowRequest) XXX_DiscardUnknown()

func (*ReportScheduledWorkflowRequest) XXX_Marshal 

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

func (*ReportScheduledWorkflowRequest) XXX_Merge 

func (dst *ReportScheduledWorkflowRequest) XXX_Merge(src proto.Message)

func (*ReportScheduledWorkflowRequest) XXX_Size 

func (m *ReportScheduledWorkflowRequest) XXX_Size() int

func (*ReportScheduledWorkflowRequest) XXX_Unmarshal 

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

type ReportServiceClient 

type ReportServiceClient interface {
	ReportWorkflow(ctx context.Context, in *ReportWorkflowRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ReportScheduledWorkflow(ctx context.Context, in *ReportScheduledWorkflowRequest, opts ...grpc.CallOption) (*empty.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.ClientConn) ReportServiceClient

type ReportServiceServer 

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

ReportServiceServer is the server API for ReportService service.

type ReportWorkflowRequest 

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

func (*ReportWorkflowRequest) Descriptor 

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

func (*ReportWorkflowRequest) GetWorkflow 

func (m *ReportWorkflowRequest) GetWorkflow() string

func (*ReportWorkflowRequest) ProtoMessage 

func (*ReportWorkflowRequest) ProtoMessage()

func (*ReportWorkflowRequest) Reset 

func (m *ReportWorkflowRequest) Reset()

func (*ReportWorkflowRequest) String 

func (m *ReportWorkflowRequest) String() string

func (*ReportWorkflowRequest) XXX_DiscardUnknown 

func (m *ReportWorkflowRequest) XXX_DiscardUnknown()

func (*ReportWorkflowRequest) XXX_Marshal 

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

func (*ReportWorkflowRequest) XXX_Merge 

func (dst *ReportWorkflowRequest) XXX_Merge(src proto.Message)

func (*ReportWorkflowRequest) XXX_Size 

func (m *ReportWorkflowRequest) XXX_Size() int

func (*ReportWorkflowRequest) XXX_Unmarshal 

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

type ResourceKey 

type ResourceKey struct {
	Type                 ResourceType `protobuf:"varint,1,opt,name=type,proto3,enum=api.ResourceType" json:"type,omitempty"`
	Id                   string       `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ResourceKey) Descriptor 

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

func (*ResourceKey) GetId 

func (m *ResourceKey) GetId() string

func (*ResourceKey) GetType 

func (m *ResourceKey) GetType() ResourceType

func (*ResourceKey) ProtoMessage 

func (*ResourceKey) ProtoMessage()

func (*ResourceKey) Reset 

func (m *ResourceKey) Reset()

func (*ResourceKey) String 

func (m *ResourceKey) String() string

func (*ResourceKey) XXX_DiscardUnknown 

func (m *ResourceKey) XXX_DiscardUnknown()

func (*ResourceKey) XXX_Marshal 

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

func (*ResourceKey) XXX_Merge 

func (dst *ResourceKey) XXX_Merge(src proto.Message)

func (*ResourceKey) XXX_Size 

func (m *ResourceKey) XXX_Size() int

func (*ResourceKey) XXX_Unmarshal 

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

type ResourceReference 

type ResourceReference struct {
	Key                  *ResourceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Name                 string       `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Relationship         Relationship `protobuf:"varint,2,opt,name=relationship,proto3,enum=api.Relationship" json:"relationship,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ResourceReference) Descriptor 

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

func (*ResourceReference) GetKey 

func (m *ResourceReference) GetKey() *ResourceKey

func (*ResourceReference) GetName 

func (m *ResourceReference) GetName() string

func (*ResourceReference) GetRelationship 

func (m *ResourceReference) GetRelationship() Relationship

func (*ResourceReference) ProtoMessage 

func (*ResourceReference) ProtoMessage()

func (*ResourceReference) Reset 

func (m *ResourceReference) Reset()

func (*ResourceReference) String 

func (m *ResourceReference) String() string

func (*ResourceReference) XXX_DiscardUnknown 

func (m *ResourceReference) XXX_DiscardUnknown()

func (*ResourceReference) XXX_Marshal 

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

func (*ResourceReference) XXX_Merge 

func (dst *ResourceReference) XXX_Merge(src proto.Message)

func (*ResourceReference) XXX_Size 

func (m *ResourceReference) XXX_Size() int

func (*ResourceReference) XXX_Unmarshal 

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

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) EnumDescriptor 

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

func (ResourceType) String 

func (x ResourceType) String() string

type RetryRunRequest 

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

func (*RetryRunRequest) Descriptor 

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

func (*RetryRunRequest) GetRunId 

func (m *RetryRunRequest) GetRunId() string

func (*RetryRunRequest) ProtoMessage 

func (*RetryRunRequest) ProtoMessage()

func (*RetryRunRequest) Reset 

func (m *RetryRunRequest) Reset()

func (*RetryRunRequest) String 

func (m *RetryRunRequest) String() string

func (*RetryRunRequest) XXX_DiscardUnknown 

func (m *RetryRunRequest) XXX_DiscardUnknown()

func (*RetryRunRequest) XXX_Marshal 

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

func (*RetryRunRequest) XXX_Merge 

func (dst *RetryRunRequest) XXX_Merge(src proto.Message)

func (*RetryRunRequest) XXX_Size 

func (m *RetryRunRequest) XXX_Size() int

func (*RetryRunRequest) XXX_Unmarshal 

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

type Run 

type Run struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	StorageState         Run_StorageState     `protobuf:"varint,10,opt,name=storage_state,json=storageState,proto3,enum=api.Run_StorageState" json:"storage_state,omitempty"`
	Description          string               `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	PipelineSpec         *PipelineSpec        `protobuf:"bytes,4,opt,name=pipeline_spec,json=pipelineSpec,proto3" json:"pipeline_spec,omitempty"`
	ResourceReferences   []*ResourceReference `protobuf:"bytes,5,rep,name=resource_references,json=resourceReferences,proto3" json:"resource_references,omitempty"`
	ServiceAccount       string               `protobuf:"bytes,14,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ScheduledAt          *timestamp.Timestamp `protobuf:"bytes,7,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	FinishedAt           *timestamp.Timestamp `protobuf:"bytes,13,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	Status               string               `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	Error                string               `protobuf:"bytes,12,opt,name=error,proto3" json:"error,omitempty"`
	Metrics              []*RunMetric         `protobuf:"bytes,9,rep,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Run) Descriptor 

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

func (*Run) GetCreatedAt 

func (m *Run) GetCreatedAt() *timestamp.Timestamp

func (*Run) GetDescription 

func (m *Run) GetDescription() string

func (*Run) GetError 

func (m *Run) GetError() string

func (*Run) GetFinishedAt 

func (m *Run) GetFinishedAt() *timestamp.Timestamp

func (*Run) GetId 

func (m *Run) GetId() string

func (*Run) GetMetrics 

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

func (*Run) GetName 

func (m *Run) GetName() string

func (*Run) GetPipelineSpec 

func (m *Run) GetPipelineSpec() *PipelineSpec

func (*Run) GetResourceReferences 

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

func (*Run) GetScheduledAt 

func (m *Run) GetScheduledAt() *timestamp.Timestamp

func (*Run) GetServiceAccount 

func (m *Run) GetServiceAccount() string

func (*Run) GetStatus 

func (m *Run) GetStatus() string

func (*Run) GetStorageState 

func (m *Run) GetStorageState() Run_StorageState

func (*Run) ProtoMessage 

func (*Run) ProtoMessage()

func (*Run) Reset 

func (m *Run) Reset()

func (*Run) String 

func (m *Run) String() string

func (*Run) XXX_DiscardUnknown 

func (m *Run) XXX_DiscardUnknown()

func (*Run) XXX_Marshal 

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

func (*Run) XXX_Merge 

func (dst *Run) XXX_Merge(src proto.Message)

func (*Run) XXX_Size 

func (m *Run) XXX_Size() int

func (*Run) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*RunDetail) Descriptor 

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

func (*RunDetail) GetPipelineRuntime 

func (m *RunDetail) GetPipelineRuntime() *PipelineRuntime

func (*RunDetail) GetRun 

func (m *RunDetail) GetRun() *Run

func (*RunDetail) ProtoMessage 

func (*RunDetail) ProtoMessage()

func (*RunDetail) Reset 

func (m *RunDetail) Reset()

func (*RunDetail) String 

func (m *RunDetail) String() string

func (*RunDetail) XXX_DiscardUnknown 

func (m *RunDetail) XXX_DiscardUnknown()

func (*RunDetail) XXX_Marshal 

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

func (*RunDetail) XXX_Merge 

func (dst *RunDetail) XXX_Merge(src proto.Message)

func (*RunDetail) XXX_Size 

func (m *RunDetail) XXX_Size() int

func (*RunDetail) XXX_Unmarshal 

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

type RunMetric 

type RunMetric struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*RunMetric_NumberValue
	Value                isRunMetric_Value `protobuf_oneof:"value"`
	Format               RunMetric_Format  `protobuf:"varint,4,opt,name=format,proto3,enum=api.RunMetric_Format" json:"format,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RunMetric) Descriptor 

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

func (*RunMetric) GetFormat 

func (m *RunMetric) GetFormat() RunMetric_Format

func (*RunMetric) GetName 

func (m *RunMetric) GetName() string

func (*RunMetric) GetNodeId 

func (m *RunMetric) GetNodeId() string

func (*RunMetric) GetNumberValue 

func (m *RunMetric) GetNumberValue() float64

func (*RunMetric) GetValue 

func (m *RunMetric) GetValue() isRunMetric_Value

func (*RunMetric) ProtoMessage 

func (*RunMetric) ProtoMessage()

func (*RunMetric) Reset 

func (m *RunMetric) Reset()

func (*RunMetric) String 

func (m *RunMetric) String() string

func (*RunMetric) XXX_DiscardUnknown 

func (m *RunMetric) XXX_DiscardUnknown()

func (*RunMetric) XXX_Marshal 

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

func (*RunMetric) XXX_Merge 

func (dst *RunMetric) XXX_Merge(src proto.Message)

func (*RunMetric) XXX_OneofFuncs 

func (*RunMetric) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*RunMetric) XXX_Size 

func (m *RunMetric) XXX_Size() int

func (*RunMetric) XXX_Unmarshal 

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

type RunMetric_Format 

type RunMetric_Format int32
const (
	RunMetric_UNSPECIFIED RunMetric_Format = 0
	RunMetric_RAW         RunMetric_Format = 1
	RunMetric_PERCENTAGE  RunMetric_Format = 2
)

func (RunMetric_Format) EnumDescriptor 

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

func (RunMetric_Format) String 

func (x RunMetric_Format) String() string

type RunMetric_NumberValue 

type RunMetric_NumberValue struct {
	NumberValue float64 `protobuf:"fixed64,3,opt,name=number_value,json=numberValue,proto3,oneof"`
}

type RunServiceClient 

type RunServiceClient interface {
	CreateRun(ctx context.Context, in *CreateRunRequest, opts ...grpc.CallOption) (*RunDetail, error)
	GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*RunDetail, error)
	ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	ArchiveRun(ctx context.Context, in *ArchiveRunRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	UnarchiveRun(ctx context.Context, in *UnarchiveRunRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeleteRun(ctx context.Context, in *DeleteRunRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	ReportRunMetrics(ctx context.Context, in *ReportRunMetricsRequest, opts ...grpc.CallOption) (*ReportRunMetricsResponse, error)
	ReadArtifact(ctx context.Context, in *ReadArtifactRequest, opts ...grpc.CallOption) (*ReadArtifactResponse, error)
	TerminateRun(ctx context.Context, in *TerminateRunRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	RetryRun(ctx context.Context, in *RetryRunRequest, opts ...grpc.CallOption) (*empty.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.ClientConn) RunServiceClient

type RunServiceServer 

type RunServiceServer interface {
	CreateRun(context.Context, *CreateRunRequest) (*RunDetail, error)
	GetRun(context.Context, *GetRunRequest) (*RunDetail, error)
	ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
	ArchiveRun(context.Context, *ArchiveRunRequest) (*empty.Empty, error)
	UnarchiveRun(context.Context, *UnarchiveRunRequest) (*empty.Empty, error)
	DeleteRun(context.Context, *DeleteRunRequest) (*empty.Empty, error)
	ReportRunMetrics(context.Context, *ReportRunMetricsRequest) (*ReportRunMetricsResponse, error)
	ReadArtifact(context.Context, *ReadArtifactRequest) (*ReadArtifactResponse, error)
	TerminateRun(context.Context, *TerminateRunRequest) (*empty.Empty, error)
	RetryRun(context.Context, *RetryRunRequest) (*empty.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) EnumDescriptor 

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

func (Run_StorageState) String 

func (x Run_StorageState) String() string

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              []*any.Any `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Status) Descriptor 

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

func (*Status) GetCode 

func (m *Status) GetCode() int32

func (*Status) GetDetails 

func (m *Status) GetDetails() []*any.Any

func (*Status) GetError 

func (m *Status) GetError() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

func (dst *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

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

type StringValues 

type StringValues struct {
	Values               []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StringValues) Descriptor 

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

func (*StringValues) GetValues 

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

func (*StringValues) ProtoMessage 

func (*StringValues) ProtoMessage()

func (*StringValues) Reset 

func (m *StringValues) Reset()

func (*StringValues) String 

func (m *StringValues) String() string

func (*StringValues) XXX_DiscardUnknown 

func (m *StringValues) XXX_DiscardUnknown()

func (*StringValues) XXX_Marshal 

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

func (*StringValues) XXX_Merge 

func (dst *StringValues) XXX_Merge(src proto.Message)

func (*StringValues) XXX_Size 

func (m *StringValues) XXX_Size() int

func (*StringValues) XXX_Unmarshal 

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

type TerminateRunRequest 

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

func (*TerminateRunRequest) Descriptor 

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

func (*TerminateRunRequest) GetRunId 

func (m *TerminateRunRequest) GetRunId() string

func (*TerminateRunRequest) ProtoMessage 

func (*TerminateRunRequest) ProtoMessage()

func (*TerminateRunRequest) Reset 

func (m *TerminateRunRequest) Reset()

func (*TerminateRunRequest) String 

func (m *TerminateRunRequest) String() string

func (*TerminateRunRequest) XXX_DiscardUnknown 

func (m *TerminateRunRequest) XXX_DiscardUnknown()

func (*TerminateRunRequest) XXX_Marshal 

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

func (*TerminateRunRequest) XXX_Merge 

func (dst *TerminateRunRequest) XXX_Merge(src proto.Message)

func (*TerminateRunRequest) XXX_Size 

func (m *TerminateRunRequest) XXX_Size() int

func (*TerminateRunRequest) XXX_Unmarshal 

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

type Trigger 

type Trigger struct {
	// Types that are valid to be assigned to Trigger:
	//	*Trigger_CronSchedule
	//	*Trigger_PeriodicSchedule
	Trigger              isTrigger_Trigger `protobuf_oneof:"trigger"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Trigger) Descriptor 

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

func (*Trigger) GetCronSchedule 

func (m *Trigger) GetCronSchedule() *CronSchedule

func (*Trigger) GetPeriodicSchedule 

func (m *Trigger) GetPeriodicSchedule() *PeriodicSchedule

func (*Trigger) GetTrigger 

func (m *Trigger) GetTrigger() isTrigger_Trigger

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) Reset 

func (m *Trigger) Reset()

func (*Trigger) String 

func (m *Trigger) String() string

func (*Trigger) XXX_DiscardUnknown 

func (m *Trigger) XXX_DiscardUnknown()

func (*Trigger) XXX_Marshal 

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

func (*Trigger) XXX_Merge 

func (dst *Trigger) XXX_Merge(src proto.Message)

func (*Trigger) XXX_OneofFuncs 

func (*Trigger) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Trigger) XXX_Size 

func (m *Trigger) XXX_Size() int

func (*Trigger) XXX_Unmarshal 

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

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 {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnarchiveExperimentRequest) Descriptor 

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

func (*UnarchiveExperimentRequest) GetId 

func (m *UnarchiveExperimentRequest) GetId() string

func (*UnarchiveExperimentRequest) ProtoMessage 

func (*UnarchiveExperimentRequest) ProtoMessage()

func (*UnarchiveExperimentRequest) Reset 

func (m *UnarchiveExperimentRequest) Reset()

func (*UnarchiveExperimentRequest) String 

func (m *UnarchiveExperimentRequest) String() string

func (*UnarchiveExperimentRequest) XXX_DiscardUnknown 

func (m *UnarchiveExperimentRequest) XXX_DiscardUnknown()

func (*UnarchiveExperimentRequest) XXX_Marshal 

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

func (*UnarchiveExperimentRequest) XXX_Merge 

func (dst *UnarchiveExperimentRequest) XXX_Merge(src proto.Message)

func (*UnarchiveExperimentRequest) XXX_Size 

func (m *UnarchiveExperimentRequest) XXX_Size() int

func (*UnarchiveExperimentRequest) XXX_Unmarshal 

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

type UnarchiveRunRequest 

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

func (*UnarchiveRunRequest) Descriptor 

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

func (*UnarchiveRunRequest) GetId 

func (m *UnarchiveRunRequest) GetId() string

func (*UnarchiveRunRequest) ProtoMessage 

func (*UnarchiveRunRequest) ProtoMessage()

func (*UnarchiveRunRequest) Reset 

func (m *UnarchiveRunRequest) Reset()

func (*UnarchiveRunRequest) String 

func (m *UnarchiveRunRequest) String() string

func (*UnarchiveRunRequest) XXX_DiscardUnknown 

func (m *UnarchiveRunRequest) XXX_DiscardUnknown()

func (*UnarchiveRunRequest) XXX_Marshal 

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

func (*UnarchiveRunRequest) XXX_Merge 

func (dst *UnarchiveRunRequest) XXX_Merge(src proto.Message)

func (*UnarchiveRunRequest) XXX_Size 

func (m *UnarchiveRunRequest) XXX_Size() int

func (*UnarchiveRunRequest) XXX_Unmarshal 

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

type Url 

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

func (*Url) Descriptor 

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

func (*Url) GetPipelineUrl 

func (m *Url) GetPipelineUrl() string

func (*Url) ProtoMessage 

func (*Url) ProtoMessage()

func (*Url) Reset 

func (m *Url) Reset()

func (*Url) String 

func (m *Url) String() string

func (*Url) XXX_DiscardUnknown 

func (m *Url) XXX_DiscardUnknown()

func (*Url) XXX_Marshal 

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

func (*Url) XXX_Merge 

func (dst *Url) XXX_Merge(src proto.Message)

func (*Url) XXX_Size 

func (m *Url) XXX_Size() int

func (*Url) XXX_Unmarshal 

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

type Visualization 

type Visualization struct {
	Type                 Visualization_Type `protobuf:"varint,1,opt,name=type,proto3,enum=api.Visualization_Type" json:"type,omitempty"`
	Source               string             `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Arguments            string             `protobuf:"bytes,3,opt,name=arguments,proto3" json:"arguments,omitempty"`
	Html                 string             `protobuf:"bytes,4,opt,name=html,proto3" json:"html,omitempty"`
	Error                string             `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Visualization) Descriptor 

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

func (*Visualization) GetArguments 

func (m *Visualization) GetArguments() string

func (*Visualization) GetError 

func (m *Visualization) GetError() string

func (*Visualization) GetHtml 

func (m *Visualization) GetHtml() string

func (*Visualization) GetSource 

func (m *Visualization) GetSource() string

func (*Visualization) GetType 

func (m *Visualization) GetType() Visualization_Type

func (*Visualization) ProtoMessage 

func (*Visualization) ProtoMessage()

func (*Visualization) Reset 

func (m *Visualization) Reset()

func (*Visualization) String 

func (m *Visualization) String() string

func (*Visualization) XXX_DiscardUnknown 

func (m *Visualization) XXX_DiscardUnknown()

func (*Visualization) XXX_Marshal 

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

func (*Visualization) XXX_Merge 

func (dst *Visualization) XXX_Merge(src proto.Message)

func (*Visualization) XXX_Size 

func (m *Visualization) XXX_Size() int

func (*Visualization) XXX_Unmarshal 

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

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.ClientConn) 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
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) EnumDescriptor 

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

func (Visualization_Type) String 

func (x Visualization_Type) String() string

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.