service

package
v1.3.16 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2023 License: Apache-2.0 Imports: 25 Imported by: 36

Documentation

Overview

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package service generated by go-bindata.// sources: ../service/admin.swagger.json

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var ArtifactType_name = map[int32]string{
	0: "ARTIFACT_TYPE_UNDEFINED",
	1: "ARTIFACT_TYPE_DECK",
}
View Source 
var ArtifactType_value = map[string]int32{
	"ARTIFACT_TYPE_UNDEFINED": 0,
	"ARTIFACT_TYPE_DECK":      1,
}
View Source 
var State_name = map[int32]string{
	0: "RETRYABLE_FAILURE",
	1: "PERMANENT_FAILURE",
	2: "PENDING",
	3: "RUNNING",
	4: "SUCCEEDED",
}
View Source 
var State_value = map[string]int32{
	"RETRYABLE_FAILURE": 0,
	"PERMANENT_FAILURE": 1,
	"PENDING":           2,
	"RUNNING":           3,
	"SUCCEEDED":         4,
}

Functions

func Asset 

func Asset(name string) ([]byte, error)

Asset loads and returns the asset for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetDir 

func AssetDir(name string) ([]string, error)

AssetDir returns the file names below a certain directory embedded in the file by go-bindata. For example if you run go-bindata on data/... and data contains the following hierarchy: 

data/
  foo.txt
  img/
    a.png
    b.png

then AssetDir("data") would return []string{"foo.txt", "img"} AssetDir("data/img") would return []string{"a.png", "b.png"} AssetDir("foo.txt") and AssetDir("notexist") would return an error AssetDir("") will return []string{"data"}.

func AssetInfo 

func AssetInfo(name string) (os.FileInfo, error)

AssetInfo loads and returns the asset info for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetNames 

func AssetNames() []string

AssetNames returns the names of the assets.

func MustAsset 

func MustAsset(name string) []byte

MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.

func RegisterAdminServiceHandler 

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

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

func RegisterAdminServiceHandlerClient 

func RegisterAdminServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AdminServiceClient) error

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

func RegisterAdminServiceHandlerFromEndpoint 

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

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

func RegisterAdminServiceServer 

func RegisterAdminServiceServer(s *grpc.Server, srv AdminServiceServer)

func RegisterAuthMetadataServiceHandler added in v0.18.40 

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

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

func RegisterAuthMetadataServiceHandlerClient added in v0.18.40 

func RegisterAuthMetadataServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AuthMetadataServiceClient) error

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

func RegisterAuthMetadataServiceHandlerFromEndpoint added in v0.18.40 

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

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

func RegisterAuthMetadataServiceServer added in v0.18.40 

func RegisterAuthMetadataServiceServer(s *grpc.Server, srv AuthMetadataServiceServer)

func RegisterDataProxyServiceHandler added in v0.24.10 

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

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

func RegisterDataProxyServiceHandlerClient added in v0.24.10 

func RegisterDataProxyServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataProxyServiceClient) error

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

func RegisterDataProxyServiceHandlerFromEndpoint added in v0.24.10 

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

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

func RegisterDataProxyServiceServer added in v0.24.10 

func RegisterDataProxyServiceServer(s *grpc.Server, srv DataProxyServiceServer)

func RegisterExternalPluginServiceServer added in v1.2.10 

func RegisterExternalPluginServiceServer(s *grpc.Server, srv ExternalPluginServiceServer)

func RegisterIdentityServiceHandler added in v0.18.40 

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

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

func RegisterIdentityServiceHandlerClient added in v0.18.40 

func RegisterIdentityServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client IdentityServiceClient) error

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

func RegisterIdentityServiceHandlerFromEndpoint added in v0.18.40 

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

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

func RegisterIdentityServiceServer added in v0.18.40 

func RegisterIdentityServiceServer(s *grpc.Server, srv IdentityServiceServer)

func RegisterSignalServiceHandler added in v1.2.1 

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

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

func RegisterSignalServiceHandlerClient added in v1.2.1 

func RegisterSignalServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SignalServiceClient) error

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

func RegisterSignalServiceHandlerFromEndpoint added in v1.2.1 

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

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

func RegisterSignalServiceServer added in v1.2.1 

func RegisterSignalServiceServer(s *grpc.Server, srv SignalServiceServer)

func RestoreAsset 

func RestoreAsset(dir, name string) error

RestoreAsset restores an asset under the given directory

func RestoreAssets 

func RestoreAssets(dir, name string) error

RestoreAssets restores an asset under the given directory recursively

Types

type AdminServiceClient 

type AdminServiceClient interface {
	// Create and upload a :ref:`ref_flyteidl.admin.Task` definition
	CreateTask(ctx context.Context, in *admin.TaskCreateRequest, opts ...grpc.CallOption) (*admin.TaskCreateResponse, error)
	// Fetch a :ref:`ref_flyteidl.admin.Task` definition.
	GetTask(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.Task, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.NamedEntityIdentifier` of task objects.
	ListTaskIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) (*admin.NamedEntityIdentifierList, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.Task` definitions.
	ListTasks(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.TaskList, error)
	// Create and upload a :ref:`ref_flyteidl.admin.Workflow` definition
	CreateWorkflow(ctx context.Context, in *admin.WorkflowCreateRequest, opts ...grpc.CallOption) (*admin.WorkflowCreateResponse, error)
	// Fetch a :ref:`ref_flyteidl.admin.Workflow` definition.
	GetWorkflow(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.Workflow, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.NamedEntityIdentifier` of workflow objects.
	ListWorkflowIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) (*admin.NamedEntityIdentifierList, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.Workflow` definitions.
	ListWorkflows(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.WorkflowList, error)
	// Create and upload a :ref:`ref_flyteidl.admin.LaunchPlan` definition
	CreateLaunchPlan(ctx context.Context, in *admin.LaunchPlanCreateRequest, opts ...grpc.CallOption) (*admin.LaunchPlanCreateResponse, error)
	// Fetch a :ref:`ref_flyteidl.admin.LaunchPlan` definition.
	GetLaunchPlan(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.LaunchPlan, error)
	// Fetch the active version of a :ref:`ref_flyteidl.admin.LaunchPlan`.
	GetActiveLaunchPlan(ctx context.Context, in *admin.ActiveLaunchPlanRequest, opts ...grpc.CallOption) (*admin.LaunchPlan, error)
	// List active versions of :ref:`ref_flyteidl.admin.LaunchPlan`.
	ListActiveLaunchPlans(ctx context.Context, in *admin.ActiveLaunchPlanListRequest, opts ...grpc.CallOption) (*admin.LaunchPlanList, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.NamedEntityIdentifier` of launch plan objects.
	ListLaunchPlanIds(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, opts ...grpc.CallOption) (*admin.NamedEntityIdentifierList, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.LaunchPlan` definitions.
	ListLaunchPlans(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.LaunchPlanList, error)
	// Updates the status of a registered :ref:`ref_flyteidl.admin.LaunchPlan`.
	UpdateLaunchPlan(ctx context.Context, in *admin.LaunchPlanUpdateRequest, opts ...grpc.CallOption) (*admin.LaunchPlanUpdateResponse, error)
	// Triggers the creation of a :ref:`ref_flyteidl.admin.Execution`
	CreateExecution(ctx context.Context, in *admin.ExecutionCreateRequest, opts ...grpc.CallOption) (*admin.ExecutionCreateResponse, error)
	// Triggers the creation of an identical :ref:`ref_flyteidl.admin.Execution`
	RelaunchExecution(ctx context.Context, in *admin.ExecutionRelaunchRequest, opts ...grpc.CallOption) (*admin.ExecutionCreateResponse, error)
	// Recreates a previously-run workflow execution that will only start executing from the last known failure point.
	// In Recover mode, users cannot change any input parameters or update the version of the execution.
	// This is extremely useful to recover from system errors and byzantine faults like - Loss of K8s cluster, bugs in platform or instability, machine failures,
	// downstream system failures (downstream services), or simply to recover executions that failed because of retry exhaustion and should complete if tried again.
	// See :ref:`ref_flyteidl.admin.ExecutionRecoverRequest` for more details.
	RecoverExecution(ctx context.Context, in *admin.ExecutionRecoverRequest, opts ...grpc.CallOption) (*admin.ExecutionCreateResponse, error)
	// Fetches a :ref:`ref_flyteidl.admin.Execution`.
	GetExecution(ctx context.Context, in *admin.WorkflowExecutionGetRequest, opts ...grpc.CallOption) (*admin.Execution, error)
	// Update execution belonging to project domain :ref:`ref_flyteidl.admin.Execution`.
	UpdateExecution(ctx context.Context, in *admin.ExecutionUpdateRequest, opts ...grpc.CallOption) (*admin.ExecutionUpdateResponse, error)
	// Fetches input and output data for a :ref:`ref_flyteidl.admin.Execution`.
	GetExecutionData(ctx context.Context, in *admin.WorkflowExecutionGetDataRequest, opts ...grpc.CallOption) (*admin.WorkflowExecutionGetDataResponse, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.Execution`.
	ListExecutions(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.ExecutionList, error)
	// Terminates an in-progress :ref:`ref_flyteidl.admin.Execution`.
	TerminateExecution(ctx context.Context, in *admin.ExecutionTerminateRequest, opts ...grpc.CallOption) (*admin.ExecutionTerminateResponse, error)
	// Fetches a :ref:`ref_flyteidl.admin.NodeExecution`.
	GetNodeExecution(ctx context.Context, in *admin.NodeExecutionGetRequest, opts ...grpc.CallOption) (*admin.NodeExecution, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.NodeExecution`.
	ListNodeExecutions(ctx context.Context, in *admin.NodeExecutionListRequest, opts ...grpc.CallOption) (*admin.NodeExecutionList, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.NodeExecution` launched by the reference :ref:`ref_flyteidl.admin.TaskExecution`.
	ListNodeExecutionsForTask(ctx context.Context, in *admin.NodeExecutionForTaskListRequest, opts ...grpc.CallOption) (*admin.NodeExecutionList, error)
	// Fetches input and output data for a :ref:`ref_flyteidl.admin.NodeExecution`.
	GetNodeExecutionData(ctx context.Context, in *admin.NodeExecutionGetDataRequest, opts ...grpc.CallOption) (*admin.NodeExecutionGetDataResponse, error)
	// Registers a :ref:`ref_flyteidl.admin.Project` with the Flyte deployment.
	RegisterProject(ctx context.Context, in *admin.ProjectRegisterRequest, opts ...grpc.CallOption) (*admin.ProjectRegisterResponse, error)
	// Updates an existing :ref:`ref_flyteidl.admin.Project`
	// flyteidl.admin.Project should be passed but the domains property should be empty;
	// it will be ignored in the handler as domains cannot be updated via this API.
	UpdateProject(ctx context.Context, in *admin.Project, opts ...grpc.CallOption) (*admin.ProjectUpdateResponse, error)
	// Fetches a list of :ref:`ref_flyteidl.admin.Project`
	ListProjects(ctx context.Context, in *admin.ProjectListRequest, opts ...grpc.CallOption) (*admin.Projects, error)
	// Indicates a :ref:`ref_flyteidl.event.WorkflowExecutionEvent` has occurred.
	CreateWorkflowEvent(ctx context.Context, in *admin.WorkflowExecutionEventRequest, opts ...grpc.CallOption) (*admin.WorkflowExecutionEventResponse, error)
	// Indicates a :ref:`ref_flyteidl.event.NodeExecutionEvent` has occurred.
	CreateNodeEvent(ctx context.Context, in *admin.NodeExecutionEventRequest, opts ...grpc.CallOption) (*admin.NodeExecutionEventResponse, error)
	// Indicates a :ref:`ref_flyteidl.event.TaskExecutionEvent` has occurred.
	CreateTaskEvent(ctx context.Context, in *admin.TaskExecutionEventRequest, opts ...grpc.CallOption) (*admin.TaskExecutionEventResponse, error)
	// Fetches a :ref:`ref_flyteidl.admin.TaskExecution`.
	GetTaskExecution(ctx context.Context, in *admin.TaskExecutionGetRequest, opts ...grpc.CallOption) (*admin.TaskExecution, error)
	// Fetches a list of :ref:`ref_flyteidl.admin.TaskExecution`.
	ListTaskExecutions(ctx context.Context, in *admin.TaskExecutionListRequest, opts ...grpc.CallOption) (*admin.TaskExecutionList, error)
	// Fetches input and output data for a :ref:`ref_flyteidl.admin.TaskExecution`.
	GetTaskExecutionData(ctx context.Context, in *admin.TaskExecutionGetDataRequest, opts ...grpc.CallOption) (*admin.TaskExecutionGetDataResponse, error)
	// Creates or updates custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project and domain.
	UpdateProjectDomainAttributes(ctx context.Context, in *admin.ProjectDomainAttributesUpdateRequest, opts ...grpc.CallOption) (*admin.ProjectDomainAttributesUpdateResponse, error)
	// Fetches custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project and domain.
	GetProjectDomainAttributes(ctx context.Context, in *admin.ProjectDomainAttributesGetRequest, opts ...grpc.CallOption) (*admin.ProjectDomainAttributesGetResponse, error)
	// Deletes custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project and domain.
	DeleteProjectDomainAttributes(ctx context.Context, in *admin.ProjectDomainAttributesDeleteRequest, opts ...grpc.CallOption) (*admin.ProjectDomainAttributesDeleteResponse, error)
	// Creates or updates custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` at the project level
	UpdateProjectAttributes(ctx context.Context, in *admin.ProjectAttributesUpdateRequest, opts ...grpc.CallOption) (*admin.ProjectAttributesUpdateResponse, error)
	// Fetches custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project and domain.
	GetProjectAttributes(ctx context.Context, in *admin.ProjectAttributesGetRequest, opts ...grpc.CallOption) (*admin.ProjectAttributesGetResponse, error)
	// Deletes custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project and domain.
	DeleteProjectAttributes(ctx context.Context, in *admin.ProjectAttributesDeleteRequest, opts ...grpc.CallOption) (*admin.ProjectAttributesDeleteResponse, error)
	// Creates or updates custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project, domain and workflow.
	UpdateWorkflowAttributes(ctx context.Context, in *admin.WorkflowAttributesUpdateRequest, opts ...grpc.CallOption) (*admin.WorkflowAttributesUpdateResponse, error)
	// Fetches custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project, domain and workflow.
	GetWorkflowAttributes(ctx context.Context, in *admin.WorkflowAttributesGetRequest, opts ...grpc.CallOption) (*admin.WorkflowAttributesGetResponse, error)
	// Deletes custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project, domain and workflow.
	DeleteWorkflowAttributes(ctx context.Context, in *admin.WorkflowAttributesDeleteRequest, opts ...grpc.CallOption) (*admin.WorkflowAttributesDeleteResponse, error)
	// Lists custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a specific resource type.
	ListMatchableAttributes(ctx context.Context, in *admin.ListMatchableAttributesRequest, opts ...grpc.CallOption) (*admin.ListMatchableAttributesResponse, error)
	// Returns a list of :ref:`ref_flyteidl.admin.NamedEntity` objects.
	ListNamedEntities(ctx context.Context, in *admin.NamedEntityListRequest, opts ...grpc.CallOption) (*admin.NamedEntityList, error)
	// Returns a :ref:`ref_flyteidl.admin.NamedEntity` object.
	GetNamedEntity(ctx context.Context, in *admin.NamedEntityGetRequest, opts ...grpc.CallOption) (*admin.NamedEntity, error)
	// Updates a :ref:`ref_flyteidl.admin.NamedEntity` object.
	UpdateNamedEntity(ctx context.Context, in *admin.NamedEntityUpdateRequest, opts ...grpc.CallOption) (*admin.NamedEntityUpdateResponse, error)
	GetVersion(ctx context.Context, in *admin.GetVersionRequest, opts ...grpc.CallOption) (*admin.GetVersionResponse, error)
	// Fetch a :ref:`ref_flyteidl.admin.DescriptionEntity` object.
	GetDescriptionEntity(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.DescriptionEntity, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.DescriptionEntity` definitions.
	ListDescriptionEntities(ctx context.Context, in *admin.DescriptionEntityListRequest, opts ...grpc.CallOption) (*admin.DescriptionEntityList, error)
	// Fetches runtime metrics for a :ref:`ref_flyteidl.admin.Execution`.
	GetExecutionMetrics(ctx context.Context, in *admin.WorkflowExecutionGetMetricsRequest, opts ...grpc.CallOption) (*admin.WorkflowExecutionGetMetricsResponse, error)
}

AdminServiceClient is the client API for AdminService service.

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

func NewAdminServiceClient 

func NewAdminServiceClient(cc *grpc.ClientConn) AdminServiceClient

type AdminServiceServer 

type AdminServiceServer interface {
	// Create and upload a :ref:`ref_flyteidl.admin.Task` definition
	CreateTask(context.Context, *admin.TaskCreateRequest) (*admin.TaskCreateResponse, error)
	// Fetch a :ref:`ref_flyteidl.admin.Task` definition.
	GetTask(context.Context, *admin.ObjectGetRequest) (*admin.Task, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.NamedEntityIdentifier` of task objects.
	ListTaskIds(context.Context, *admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.Task` definitions.
	ListTasks(context.Context, *admin.ResourceListRequest) (*admin.TaskList, error)
	// Create and upload a :ref:`ref_flyteidl.admin.Workflow` definition
	CreateWorkflow(context.Context, *admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error)
	// Fetch a :ref:`ref_flyteidl.admin.Workflow` definition.
	GetWorkflow(context.Context, *admin.ObjectGetRequest) (*admin.Workflow, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.NamedEntityIdentifier` of workflow objects.
	ListWorkflowIds(context.Context, *admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.Workflow` definitions.
	ListWorkflows(context.Context, *admin.ResourceListRequest) (*admin.WorkflowList, error)
	// Create and upload a :ref:`ref_flyteidl.admin.LaunchPlan` definition
	CreateLaunchPlan(context.Context, *admin.LaunchPlanCreateRequest) (*admin.LaunchPlanCreateResponse, error)
	// Fetch a :ref:`ref_flyteidl.admin.LaunchPlan` definition.
	GetLaunchPlan(context.Context, *admin.ObjectGetRequest) (*admin.LaunchPlan, error)
	// Fetch the active version of a :ref:`ref_flyteidl.admin.LaunchPlan`.
	GetActiveLaunchPlan(context.Context, *admin.ActiveLaunchPlanRequest) (*admin.LaunchPlan, error)
	// List active versions of :ref:`ref_flyteidl.admin.LaunchPlan`.
	ListActiveLaunchPlans(context.Context, *admin.ActiveLaunchPlanListRequest) (*admin.LaunchPlanList, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.NamedEntityIdentifier` of launch plan objects.
	ListLaunchPlanIds(context.Context, *admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.LaunchPlan` definitions.
	ListLaunchPlans(context.Context, *admin.ResourceListRequest) (*admin.LaunchPlanList, error)
	// Updates the status of a registered :ref:`ref_flyteidl.admin.LaunchPlan`.
	UpdateLaunchPlan(context.Context, *admin.LaunchPlanUpdateRequest) (*admin.LaunchPlanUpdateResponse, error)
	// Triggers the creation of a :ref:`ref_flyteidl.admin.Execution`
	CreateExecution(context.Context, *admin.ExecutionCreateRequest) (*admin.ExecutionCreateResponse, error)
	// Triggers the creation of an identical :ref:`ref_flyteidl.admin.Execution`
	RelaunchExecution(context.Context, *admin.ExecutionRelaunchRequest) (*admin.ExecutionCreateResponse, error)
	// Recreates a previously-run workflow execution that will only start executing from the last known failure point.
	// In Recover mode, users cannot change any input parameters or update the version of the execution.
	// This is extremely useful to recover from system errors and byzantine faults like - Loss of K8s cluster, bugs in platform or instability, machine failures,
	// downstream system failures (downstream services), or simply to recover executions that failed because of retry exhaustion and should complete if tried again.
	// See :ref:`ref_flyteidl.admin.ExecutionRecoverRequest` for more details.
	RecoverExecution(context.Context, *admin.ExecutionRecoverRequest) (*admin.ExecutionCreateResponse, error)
	// Fetches a :ref:`ref_flyteidl.admin.Execution`.
	GetExecution(context.Context, *admin.WorkflowExecutionGetRequest) (*admin.Execution, error)
	// Update execution belonging to project domain :ref:`ref_flyteidl.admin.Execution`.
	UpdateExecution(context.Context, *admin.ExecutionUpdateRequest) (*admin.ExecutionUpdateResponse, error)
	// Fetches input and output data for a :ref:`ref_flyteidl.admin.Execution`.
	GetExecutionData(context.Context, *admin.WorkflowExecutionGetDataRequest) (*admin.WorkflowExecutionGetDataResponse, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.Execution`.
	ListExecutions(context.Context, *admin.ResourceListRequest) (*admin.ExecutionList, error)
	// Terminates an in-progress :ref:`ref_flyteidl.admin.Execution`.
	TerminateExecution(context.Context, *admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)
	// Fetches a :ref:`ref_flyteidl.admin.NodeExecution`.
	GetNodeExecution(context.Context, *admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.NodeExecution`.
	ListNodeExecutions(context.Context, *admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.NodeExecution` launched by the reference :ref:`ref_flyteidl.admin.TaskExecution`.
	ListNodeExecutionsForTask(context.Context, *admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error)
	// Fetches input and output data for a :ref:`ref_flyteidl.admin.NodeExecution`.
	GetNodeExecutionData(context.Context, *admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error)
	// Registers a :ref:`ref_flyteidl.admin.Project` with the Flyte deployment.
	RegisterProject(context.Context, *admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error)
	// Updates an existing :ref:`ref_flyteidl.admin.Project`
	// flyteidl.admin.Project should be passed but the domains property should be empty;
	// it will be ignored in the handler as domains cannot be updated via this API.
	UpdateProject(context.Context, *admin.Project) (*admin.ProjectUpdateResponse, error)
	// Fetches a list of :ref:`ref_flyteidl.admin.Project`
	ListProjects(context.Context, *admin.ProjectListRequest) (*admin.Projects, error)
	// Indicates a :ref:`ref_flyteidl.event.WorkflowExecutionEvent` has occurred.
	CreateWorkflowEvent(context.Context, *admin.WorkflowExecutionEventRequest) (*admin.WorkflowExecutionEventResponse, error)
	// Indicates a :ref:`ref_flyteidl.event.NodeExecutionEvent` has occurred.
	CreateNodeEvent(context.Context, *admin.NodeExecutionEventRequest) (*admin.NodeExecutionEventResponse, error)
	// Indicates a :ref:`ref_flyteidl.event.TaskExecutionEvent` has occurred.
	CreateTaskEvent(context.Context, *admin.TaskExecutionEventRequest) (*admin.TaskExecutionEventResponse, error)
	// Fetches a :ref:`ref_flyteidl.admin.TaskExecution`.
	GetTaskExecution(context.Context, *admin.TaskExecutionGetRequest) (*admin.TaskExecution, error)
	// Fetches a list of :ref:`ref_flyteidl.admin.TaskExecution`.
	ListTaskExecutions(context.Context, *admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error)
	// Fetches input and output data for a :ref:`ref_flyteidl.admin.TaskExecution`.
	GetTaskExecutionData(context.Context, *admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error)
	// Creates or updates custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project and domain.
	UpdateProjectDomainAttributes(context.Context, *admin.ProjectDomainAttributesUpdateRequest) (*admin.ProjectDomainAttributesUpdateResponse, error)
	// Fetches custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project and domain.
	GetProjectDomainAttributes(context.Context, *admin.ProjectDomainAttributesGetRequest) (*admin.ProjectDomainAttributesGetResponse, error)
	// Deletes custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project and domain.
	DeleteProjectDomainAttributes(context.Context, *admin.ProjectDomainAttributesDeleteRequest) (*admin.ProjectDomainAttributesDeleteResponse, error)
	// Creates or updates custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` at the project level
	UpdateProjectAttributes(context.Context, *admin.ProjectAttributesUpdateRequest) (*admin.ProjectAttributesUpdateResponse, error)
	// Fetches custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project and domain.
	GetProjectAttributes(context.Context, *admin.ProjectAttributesGetRequest) (*admin.ProjectAttributesGetResponse, error)
	// Deletes custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project and domain.
	DeleteProjectAttributes(context.Context, *admin.ProjectAttributesDeleteRequest) (*admin.ProjectAttributesDeleteResponse, error)
	// Creates or updates custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project, domain and workflow.
	UpdateWorkflowAttributes(context.Context, *admin.WorkflowAttributesUpdateRequest) (*admin.WorkflowAttributesUpdateResponse, error)
	// Fetches custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project, domain and workflow.
	GetWorkflowAttributes(context.Context, *admin.WorkflowAttributesGetRequest) (*admin.WorkflowAttributesGetResponse, error)
	// Deletes custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a project, domain and workflow.
	DeleteWorkflowAttributes(context.Context, *admin.WorkflowAttributesDeleteRequest) (*admin.WorkflowAttributesDeleteResponse, error)
	// Lists custom :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for a specific resource type.
	ListMatchableAttributes(context.Context, *admin.ListMatchableAttributesRequest) (*admin.ListMatchableAttributesResponse, error)
	// Returns a list of :ref:`ref_flyteidl.admin.NamedEntity` objects.
	ListNamedEntities(context.Context, *admin.NamedEntityListRequest) (*admin.NamedEntityList, error)
	// Returns a :ref:`ref_flyteidl.admin.NamedEntity` object.
	GetNamedEntity(context.Context, *admin.NamedEntityGetRequest) (*admin.NamedEntity, error)
	// Updates a :ref:`ref_flyteidl.admin.NamedEntity` object.
	UpdateNamedEntity(context.Context, *admin.NamedEntityUpdateRequest) (*admin.NamedEntityUpdateResponse, error)
	GetVersion(context.Context, *admin.GetVersionRequest) (*admin.GetVersionResponse, error)
	// Fetch a :ref:`ref_flyteidl.admin.DescriptionEntity` object.
	GetDescriptionEntity(context.Context, *admin.ObjectGetRequest) (*admin.DescriptionEntity, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.DescriptionEntity` definitions.
	ListDescriptionEntities(context.Context, *admin.DescriptionEntityListRequest) (*admin.DescriptionEntityList, error)
	// Fetches runtime metrics for a :ref:`ref_flyteidl.admin.Execution`.
	GetExecutionMetrics(context.Context, *admin.WorkflowExecutionGetMetricsRequest) (*admin.WorkflowExecutionGetMetricsResponse, error)
}

AdminServiceServer is the server API for AdminService service.

type ArtifactType added in v1.2.5 

type ArtifactType int32

ArtifactType 

const (
	// ARTIFACT_TYPE_UNDEFINED is the default, often invalid, value for the enum.
	ArtifactType_ARTIFACT_TYPE_UNDEFINED ArtifactType = 0
	// ARTIFACT_TYPE_DECK refers to the deck html file optionally generated after a task, a workflow or a launch plan
	// finishes executing.
	ArtifactType_ARTIFACT_TYPE_DECK ArtifactType = 1
)

func (ArtifactType) EnumDescriptor added in v1.2.5 

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

func (ArtifactType) String added in v1.2.5 

func (x ArtifactType) String() string

type AuthMetadataServiceClient added in v0.18.40 

type AuthMetadataServiceClient interface {
	// Anonymously accessible. Retrieves local or external oauth authorization server metadata.
	GetOAuth2Metadata(ctx context.Context, in *OAuth2MetadataRequest, opts ...grpc.CallOption) (*OAuth2MetadataResponse, error)
	// Anonymously accessible. Retrieves the client information clients should use when initiating OAuth2 authorization
	// requests.
	GetPublicClientConfig(ctx context.Context, in *PublicClientAuthConfigRequest, opts ...grpc.CallOption) (*PublicClientAuthConfigResponse, error)
}

AuthMetadataServiceClient is the client API for AuthMetadataService service.

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

func NewAuthMetadataServiceClient added in v0.18.40 

func NewAuthMetadataServiceClient(cc *grpc.ClientConn) AuthMetadataServiceClient

type AuthMetadataServiceServer added in v0.18.40 

type AuthMetadataServiceServer interface {
	// Anonymously accessible. Retrieves local or external oauth authorization server metadata.
	GetOAuth2Metadata(context.Context, *OAuth2MetadataRequest) (*OAuth2MetadataResponse, error)
	// Anonymously accessible. Retrieves the client information clients should use when initiating OAuth2 authorization
	// requests.
	GetPublicClientConfig(context.Context, *PublicClientAuthConfigRequest) (*PublicClientAuthConfigResponse, error)
}

AuthMetadataServiceServer is the server API for AuthMetadataService service.

type CreateDownloadLinkRequest added in v1.2.5 

type CreateDownloadLinkRequest struct {
	// ArtifactType of the artifact requested.
	ArtifactType ArtifactType `` /* 133-byte string literal not displayed */
	// ExpiresIn defines a requested expiration duration for the generated url. The request will be rejected if this
	// exceeds the platform allowed max.
	// +optional. The default value comes from a global config.
	ExpiresIn *duration.Duration `protobuf:"bytes,2,opt,name=expires_in,json=expiresIn,proto3" json:"expires_in,omitempty"`
	// Types that are valid to be assigned to Source:
	//	*CreateDownloadLinkRequest_NodeExecutionId
	Source               isCreateDownloadLinkRequest_Source `protobuf_oneof:"source"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

CreateDownloadLinkRequest defines the request parameters to create a download link (signed url)

func (*CreateDownloadLinkRequest) Descriptor added in v1.2.5 

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

func (*CreateDownloadLinkRequest) GetArtifactType added in v1.2.5 

func (m *CreateDownloadLinkRequest) GetArtifactType() ArtifactType

func (*CreateDownloadLinkRequest) GetExpiresIn added in v1.2.5 

func (m *CreateDownloadLinkRequest) GetExpiresIn() *duration.Duration

func (*CreateDownloadLinkRequest) GetNodeExecutionId added in v1.2.5 

func (m *CreateDownloadLinkRequest) GetNodeExecutionId() *core.NodeExecutionIdentifier

func (*CreateDownloadLinkRequest) GetSource added in v1.2.5 

func (m *CreateDownloadLinkRequest) GetSource() isCreateDownloadLinkRequest_Source

func (*CreateDownloadLinkRequest) ProtoMessage added in v1.2.5 

func (*CreateDownloadLinkRequest) ProtoMessage()

func (*CreateDownloadLinkRequest) Reset added in v1.2.5 

func (m *CreateDownloadLinkRequest) Reset()

func (*CreateDownloadLinkRequest) String added in v1.2.5 

func (m *CreateDownloadLinkRequest) String() string

func (*CreateDownloadLinkRequest) XXX_DiscardUnknown added in v1.2.5 

func (m *CreateDownloadLinkRequest) XXX_DiscardUnknown()

func (*CreateDownloadLinkRequest) XXX_Marshal added in v1.2.5 

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

func (*CreateDownloadLinkRequest) XXX_Merge added in v1.2.5 

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

func (*CreateDownloadLinkRequest) XXX_OneofWrappers added in v1.2.5 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*CreateDownloadLinkRequest) XXX_Size added in v1.2.5 

func (m *CreateDownloadLinkRequest) XXX_Size() int

func (*CreateDownloadLinkRequest) XXX_Unmarshal added in v1.2.5 

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

type CreateDownloadLinkRequest_NodeExecutionId added in v1.2.5 

type CreateDownloadLinkRequest_NodeExecutionId struct {
	NodeExecutionId *core.NodeExecutionIdentifier `protobuf:"bytes,3,opt,name=node_execution_id,json=nodeExecutionId,proto3,oneof"`
}

type CreateDownloadLinkResponse added in v1.2.5 

type CreateDownloadLinkResponse struct {
	// SignedUrl specifies the url to use to download content from (e.g. https://my-bucket.s3.amazonaws.com/randomstring/suffix.tar?X-...)
	SignedUrl []string `protobuf:"bytes,1,rep,name=signed_url,json=signedUrl,proto3" json:"signed_url,omitempty"`
	// ExpiresAt defines when will the signed URL expire.
	ExpiresAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

CreateDownloadLinkResponse defines the response for the generated links

func (*CreateDownloadLinkResponse) Descriptor added in v1.2.5 

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

func (*CreateDownloadLinkResponse) GetExpiresAt added in v1.2.5 

func (m *CreateDownloadLinkResponse) GetExpiresAt() *timestamp.Timestamp

func (*CreateDownloadLinkResponse) GetSignedUrl added in v1.2.5 

func (m *CreateDownloadLinkResponse) GetSignedUrl() []string

func (*CreateDownloadLinkResponse) ProtoMessage added in v1.2.5 

func (*CreateDownloadLinkResponse) ProtoMessage()

func (*CreateDownloadLinkResponse) Reset added in v1.2.5 

func (m *CreateDownloadLinkResponse) Reset()

func (*CreateDownloadLinkResponse) String added in v1.2.5 

func (m *CreateDownloadLinkResponse) String() string

func (*CreateDownloadLinkResponse) XXX_DiscardUnknown added in v1.2.5 

func (m *CreateDownloadLinkResponse) XXX_DiscardUnknown()

func (*CreateDownloadLinkResponse) XXX_Marshal added in v1.2.5 

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

func (*CreateDownloadLinkResponse) XXX_Merge added in v1.2.5 

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

func (*CreateDownloadLinkResponse) XXX_Size added in v1.2.5 

func (m *CreateDownloadLinkResponse) XXX_Size() int

func (*CreateDownloadLinkResponse) XXX_Unmarshal added in v1.2.5 

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

type CreateDownloadLocationRequest deprecated added in v1.1.3 

type CreateDownloadLocationRequest struct {
	// NativeUrl specifies the url in the format of the configured storage provider (e.g. s3://my-bucket/randomstring/suffix.tar)
	NativeUrl string `protobuf:"bytes,1,opt,name=native_url,json=nativeUrl,proto3" json:"native_url,omitempty"`
	// ExpiresIn defines a requested expiration duration for the generated url. The request will be rejected if this
	// exceeds the platform allowed max.
	// +optional. The default value comes from a global config.
	ExpiresIn            *duration.Duration `protobuf:"bytes,2,opt,name=expires_in,json=expiresIn,proto3" json:"expires_in,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

CreateDownloadLocationRequest specified request for the CreateDownloadLocation API.

Deprecated: Do not use.

func (*CreateDownloadLocationRequest) Descriptor added in v1.1.3 

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

func (*CreateDownloadLocationRequest) GetExpiresIn added in v1.1.3 

func (m *CreateDownloadLocationRequest) GetExpiresIn() *duration.Duration

func (*CreateDownloadLocationRequest) GetNativeUrl added in v1.1.3 

func (m *CreateDownloadLocationRequest) GetNativeUrl() string

func (*CreateDownloadLocationRequest) ProtoMessage added in v1.1.3 

func (*CreateDownloadLocationRequest) ProtoMessage()

func (*CreateDownloadLocationRequest) Reset added in v1.1.3 

func (m *CreateDownloadLocationRequest) Reset()

func (*CreateDownloadLocationRequest) String added in v1.1.3 

func (m *CreateDownloadLocationRequest) String() string

func (*CreateDownloadLocationRequest) XXX_DiscardUnknown added in v1.1.3 

func (m *CreateDownloadLocationRequest) XXX_DiscardUnknown()

func (*CreateDownloadLocationRequest) XXX_Marshal added in v1.1.3 

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

func (*CreateDownloadLocationRequest) XXX_Merge added in v1.1.3 

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

func (*CreateDownloadLocationRequest) XXX_Size added in v1.1.3 

func (m *CreateDownloadLocationRequest) XXX_Size() int

func (*CreateDownloadLocationRequest) XXX_Unmarshal added in v1.1.3 

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

type CreateDownloadLocationResponse deprecated added in v1.1.3 

type CreateDownloadLocationResponse struct {
	// SignedUrl specifies the url to use to download content from (e.g. https://my-bucket.s3.amazonaws.com/randomstring/suffix.tar?X-...)
	SignedUrl string `protobuf:"bytes,1,opt,name=signed_url,json=signedUrl,proto3" json:"signed_url,omitempty"`
	// ExpiresAt defines when will the signed URL expires.
	ExpiresAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Deprecated: Do not use.

func (*CreateDownloadLocationResponse) Descriptor added in v1.1.3 

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

func (*CreateDownloadLocationResponse) GetExpiresAt added in v1.1.3 

func (m *CreateDownloadLocationResponse) GetExpiresAt() *timestamp.Timestamp

func (*CreateDownloadLocationResponse) GetSignedUrl added in v1.1.3 

func (m *CreateDownloadLocationResponse) GetSignedUrl() string

func (*CreateDownloadLocationResponse) ProtoMessage added in v1.1.3 

func (*CreateDownloadLocationResponse) ProtoMessage()

func (*CreateDownloadLocationResponse) Reset added in v1.1.3 

func (m *CreateDownloadLocationResponse) Reset()

func (*CreateDownloadLocationResponse) String added in v1.1.3 

func (m *CreateDownloadLocationResponse) String() string

func (*CreateDownloadLocationResponse) XXX_DiscardUnknown added in v1.1.3 

func (m *CreateDownloadLocationResponse) XXX_DiscardUnknown()

func (*CreateDownloadLocationResponse) XXX_Marshal added in v1.1.3 

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

func (*CreateDownloadLocationResponse) XXX_Merge added in v1.1.3 

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

func (*CreateDownloadLocationResponse) XXX_Size added in v1.1.3 

func (m *CreateDownloadLocationResponse) XXX_Size() int

func (*CreateDownloadLocationResponse) XXX_Unmarshal added in v1.1.3 

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

type CreateUploadLocationRequest added in v0.24.3 

type CreateUploadLocationRequest struct {
	// Project to create the upload location for
	// +required
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Domain to create the upload location for.
	// +required
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Filename specifies a desired suffix for the generated location. E.g. `file.py` or `pre/fix/file.zip`.
	// +optional. By default, the service will generate a consistent name based on the provided parameters.
	Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	// ExpiresIn defines a requested expiration duration for the generated url. The request will be rejected if this
	// exceeds the platform allowed max.
	// +optional. The default value comes from a global config.
	ExpiresIn *duration.Duration `protobuf:"bytes,4,opt,name=expires_in,json=expiresIn,proto3" json:"expires_in,omitempty"`
	// ContentMD5 restricts the upload location to the specific MD5 provided. The ContentMD5 will also appear in the
	// generated path.
	// +required
	ContentMd5           []byte   `protobuf:"bytes,5,opt,name=content_md5,json=contentMd5,proto3" json:"content_md5,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateUploadLocationRequest specified request for the CreateUploadLocation API.

func (*CreateUploadLocationRequest) Descriptor added in v0.24.3 

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

func (*CreateUploadLocationRequest) GetContentMd5 added in v0.24.15 

func (m *CreateUploadLocationRequest) GetContentMd5() []byte

func (*CreateUploadLocationRequest) GetDomain added in v0.24.3 

func (m *CreateUploadLocationRequest) GetDomain() string

func (*CreateUploadLocationRequest) GetExpiresIn added in v0.24.3 

func (m *CreateUploadLocationRequest) GetExpiresIn() *duration.Duration

func (*CreateUploadLocationRequest) GetFilename added in v0.24.15 

func (m *CreateUploadLocationRequest) GetFilename() string

func (*CreateUploadLocationRequest) GetProject added in v0.24.3 

func (m *CreateUploadLocationRequest) GetProject() string

func (*CreateUploadLocationRequest) ProtoMessage added in v0.24.3 

func (*CreateUploadLocationRequest) ProtoMessage()

func (*CreateUploadLocationRequest) Reset added in v0.24.3 

func (m *CreateUploadLocationRequest) Reset()

func (*CreateUploadLocationRequest) String added in v0.24.3 

func (m *CreateUploadLocationRequest) String() string

func (*CreateUploadLocationRequest) XXX_DiscardUnknown added in v0.24.3 

func (m *CreateUploadLocationRequest) XXX_DiscardUnknown()

func (*CreateUploadLocationRequest) XXX_Marshal added in v0.24.3 

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

func (*CreateUploadLocationRequest) XXX_Merge added in v0.24.3 

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

func (*CreateUploadLocationRequest) XXX_Size added in v0.24.3 

func (m *CreateUploadLocationRequest) XXX_Size() int

func (*CreateUploadLocationRequest) XXX_Unmarshal added in v0.24.3 

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

type CreateUploadLocationResponse added in v0.24.3 

type CreateUploadLocationResponse struct {
	// SignedUrl specifies the url to use to upload content to (e.g. https://my-bucket.s3.amazonaws.com/randomstring/suffix.tar?X-...)
	SignedUrl string `protobuf:"bytes,1,opt,name=signed_url,json=signedUrl,proto3" json:"signed_url,omitempty"`
	// NativeUrl specifies the url in the format of the configured storage provider (e.g. s3://my-bucket/randomstring/suffix.tar)
	NativeUrl string `protobuf:"bytes,2,opt,name=native_url,json=nativeUrl,proto3" json:"native_url,omitempty"`
	// ExpiresAt defines when will the signed URL expires.
	ExpiresAt            *timestamp.Timestamp `protobuf:"bytes,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CreateUploadLocationResponse) Descriptor added in v0.24.3 

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

func (*CreateUploadLocationResponse) GetExpiresAt added in v0.24.3 

func (m *CreateUploadLocationResponse) GetExpiresAt() *timestamp.Timestamp

func (*CreateUploadLocationResponse) GetNativeUrl added in v0.24.3 

func (m *CreateUploadLocationResponse) GetNativeUrl() string

func (*CreateUploadLocationResponse) GetSignedUrl added in v0.24.3 

func (m *CreateUploadLocationResponse) GetSignedUrl() string

func (*CreateUploadLocationResponse) ProtoMessage added in v0.24.3 

func (*CreateUploadLocationResponse) ProtoMessage()

func (*CreateUploadLocationResponse) Reset added in v0.24.3 

func (m *CreateUploadLocationResponse) Reset()

func (*CreateUploadLocationResponse) String added in v0.24.3 

func (m *CreateUploadLocationResponse) String() string

func (*CreateUploadLocationResponse) XXX_DiscardUnknown added in v0.24.3 

func (m *CreateUploadLocationResponse) XXX_DiscardUnknown()

func (*CreateUploadLocationResponse) XXX_Marshal added in v0.24.3 

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

func (*CreateUploadLocationResponse) XXX_Merge added in v0.24.3 

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

func (*CreateUploadLocationResponse) XXX_Size added in v0.24.3 

func (m *CreateUploadLocationResponse) XXX_Size() int

func (*CreateUploadLocationResponse) XXX_Unmarshal added in v0.24.3 

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

type DataProxyServiceClient added in v0.24.10 

type DataProxyServiceClient interface {
	// CreateUploadLocation creates a signed url to upload artifacts to for a given project/domain.
	CreateUploadLocation(ctx context.Context, in *CreateUploadLocationRequest, opts ...grpc.CallOption) (*CreateUploadLocationResponse, error)
	// CreateDownloadLocation creates a signed url to download artifacts.
	CreateDownloadLocation(ctx context.Context, in *CreateDownloadLocationRequest, opts ...grpc.CallOption) (*CreateDownloadLocationResponse, error)
	// CreateDownloadLocation creates a signed url to download artifacts.
	CreateDownloadLink(ctx context.Context, in *CreateDownloadLinkRequest, opts ...grpc.CallOption) (*CreateDownloadLinkResponse, error)
}

DataProxyServiceClient is the client API for DataProxyService service.

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

func NewDataProxyServiceClient added in v0.24.10 

func NewDataProxyServiceClient(cc *grpc.ClientConn) DataProxyServiceClient

type DataProxyServiceServer added in v0.24.10 

type DataProxyServiceServer interface {
	// CreateUploadLocation creates a signed url to upload artifacts to for a given project/domain.
	CreateUploadLocation(context.Context, *CreateUploadLocationRequest) (*CreateUploadLocationResponse, error)
	// CreateDownloadLocation creates a signed url to download artifacts.
	CreateDownloadLocation(context.Context, *CreateDownloadLocationRequest) (*CreateDownloadLocationResponse, error)
	// CreateDownloadLocation creates a signed url to download artifacts.
	CreateDownloadLink(context.Context, *CreateDownloadLinkRequest) (*CreateDownloadLinkResponse, error)
}

DataProxyServiceServer is the server API for DataProxyService service.

type ExternalPluginServiceClient added in v1.2.10 

type ExternalPluginServiceClient interface {
	// Send a task create request to the backend plugin server.
	CreateTask(ctx context.Context, in *TaskCreateRequest, opts ...grpc.CallOption) (*TaskCreateResponse, error)
	// Get job status.
	GetTask(ctx context.Context, in *TaskGetRequest, opts ...grpc.CallOption) (*TaskGetResponse, error)
	// Delete the task resource.
	DeleteTask(ctx context.Context, in *TaskDeleteRequest, opts ...grpc.CallOption) (*TaskDeleteResponse, error)
}

ExternalPluginServiceClient is the client API for ExternalPluginService service.

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

func NewExternalPluginServiceClient added in v1.2.10 

func NewExternalPluginServiceClient(cc *grpc.ClientConn) ExternalPluginServiceClient

type ExternalPluginServiceServer added in v1.2.10 

type ExternalPluginServiceServer interface {
	// Send a task create request to the backend plugin server.
	CreateTask(context.Context, *TaskCreateRequest) (*TaskCreateResponse, error)
	// Get job status.
	GetTask(context.Context, *TaskGetRequest) (*TaskGetResponse, error)
	// Delete the task resource.
	DeleteTask(context.Context, *TaskDeleteRequest) (*TaskDeleteResponse, error)
}

ExternalPluginServiceServer is the server API for ExternalPluginService service.

type IdentityServiceClient added in v0.18.40 

type IdentityServiceClient interface {
	// Retrieves user information about the currently logged in user.
	UserInfo(ctx context.Context, in *UserInfoRequest, opts ...grpc.CallOption) (*UserInfoResponse, error)
}

IdentityServiceClient is the client API for IdentityService service.

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

func NewIdentityServiceClient added in v0.18.40 

func NewIdentityServiceClient(cc *grpc.ClientConn) IdentityServiceClient

type IdentityServiceServer added in v0.18.40 

type IdentityServiceServer interface {
	// Retrieves user information about the currently logged in user.
	UserInfo(context.Context, *UserInfoRequest) (*UserInfoResponse, error)
}

IdentityServiceServer is the server API for IdentityService service.

type OAuth2MetadataRequest added in v0.18.40 

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

func (*OAuth2MetadataRequest) Descriptor added in v0.18.40 

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

func (*OAuth2MetadataRequest) ProtoMessage added in v0.18.40 

func (*OAuth2MetadataRequest) ProtoMessage()

func (*OAuth2MetadataRequest) Reset added in v0.18.40 

func (m *OAuth2MetadataRequest) Reset()

func (*OAuth2MetadataRequest) String added in v0.18.40 

func (m *OAuth2MetadataRequest) String() string

func (*OAuth2MetadataRequest) XXX_DiscardUnknown added in v0.18.40 

func (m *OAuth2MetadataRequest) XXX_DiscardUnknown()

func (*OAuth2MetadataRequest) XXX_Marshal added in v0.18.40 

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

func (*OAuth2MetadataRequest) XXX_Merge added in v0.18.40 

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

func (*OAuth2MetadataRequest) XXX_Size added in v0.18.40 

func (m *OAuth2MetadataRequest) XXX_Size() int

func (*OAuth2MetadataRequest) XXX_Unmarshal added in v0.18.40 

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

type OAuth2MetadataResponse added in v0.18.40 

type OAuth2MetadataResponse struct {
	// Defines the issuer string in all JWT tokens this server issues. The issuer can be admin itself or an external
	// issuer.
	Issuer string `protobuf:"bytes,1,opt,name=issuer,proto3" json:"issuer,omitempty"`
	// URL of the authorization server's authorization endpoint [RFC6749]. This is REQUIRED unless no grant types are
	// supported that use the authorization endpoint.
	AuthorizationEndpoint string `protobuf:"bytes,2,opt,name=authorization_endpoint,json=authorizationEndpoint,proto3" json:"authorization_endpoint,omitempty"`
	// URL of the authorization server's token endpoint [RFC6749].
	TokenEndpoint string `protobuf:"bytes,3,opt,name=token_endpoint,json=tokenEndpoint,proto3" json:"token_endpoint,omitempty"`
	// Array containing a list of the OAuth 2.0 response_type values that this authorization server supports.
	ResponseTypesSupported []string `` /* 129-byte string literal not displayed */
	// JSON array containing a list of the OAuth 2.0 [RFC6749] scope values that this authorization server supports.
	ScopesSupported []string `protobuf:"bytes,5,rep,name=scopes_supported,json=scopesSupported,proto3" json:"scopes_supported,omitempty"`
	// JSON array containing a list of client authentication methods supported by this token endpoint.
	TokenEndpointAuthMethodsSupported []string `` /* 166-byte string literal not displayed */
	// URL of the authorization server's JWK Set [JWK] document. The referenced document contains the signing key(s) the
	// client uses to validate signatures from the authorization server.
	JwksUri string `protobuf:"bytes,7,opt,name=jwks_uri,json=jwksUri,proto3" json:"jwks_uri,omitempty"`
	// JSON array containing a list of Proof Key for Code Exchange (PKCE) [RFC7636] code challenge methods supported by
	// this authorization server.
	CodeChallengeMethodsSupported []string `` /* 152-byte string literal not displayed */
	// JSON array containing a list of the OAuth 2.0 grant type values that this authorization server supports.
	GrantTypesSupported []string `protobuf:"bytes,9,rep,name=grant_types_supported,json=grantTypesSupported,proto3" json:"grant_types_supported,omitempty"`
	// URL of the authorization server's device authorization endpoint, as defined in Section 3.1 of [RFC8628]
	DeviceAuthorizationEndpoint string   `` /* 145-byte string literal not displayed */
	XXX_NoUnkeyedLiteral        struct{} `json:"-"`
	XXX_unrecognized            []byte   `json:"-"`
	XXX_sizecache               int32    `json:"-"`
}

OAuth2MetadataResponse defines an RFC-Compliant response for /.well-known/oauth-authorization-server metadata as defined in https://tools.ietf.org/html/rfc8414

func (*OAuth2MetadataResponse) Descriptor added in v0.18.40 

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

func (*OAuth2MetadataResponse) GetAuthorizationEndpoint added in v0.18.40 

func (m *OAuth2MetadataResponse) GetAuthorizationEndpoint() string

func (*OAuth2MetadataResponse) GetCodeChallengeMethodsSupported added in v0.18.40 

func (m *OAuth2MetadataResponse) GetCodeChallengeMethodsSupported() []string

func (*OAuth2MetadataResponse) GetDeviceAuthorizationEndpoint added in v1.1.13 

func (m *OAuth2MetadataResponse) GetDeviceAuthorizationEndpoint() string

func (*OAuth2MetadataResponse) GetGrantTypesSupported added in v0.18.40 

func (m *OAuth2MetadataResponse) GetGrantTypesSupported() []string

func (*OAuth2MetadataResponse) GetIssuer added in v0.18.40 

func (m *OAuth2MetadataResponse) GetIssuer() string

func (*OAuth2MetadataResponse) GetJwksUri added in v0.18.40 

func (m *OAuth2MetadataResponse) GetJwksUri() string

func (*OAuth2MetadataResponse) GetResponseTypesSupported added in v0.18.40 

func (m *OAuth2MetadataResponse) GetResponseTypesSupported() []string

func (*OAuth2MetadataResponse) GetScopesSupported added in v0.18.40 

func (m *OAuth2MetadataResponse) GetScopesSupported() []string

func (*OAuth2MetadataResponse) GetTokenEndpoint added in v0.18.40 

func (m *OAuth2MetadataResponse) GetTokenEndpoint() string

func (*OAuth2MetadataResponse) GetTokenEndpointAuthMethodsSupported added in v0.18.40 

func (m *OAuth2MetadataResponse) GetTokenEndpointAuthMethodsSupported() []string

func (*OAuth2MetadataResponse) ProtoMessage added in v0.18.40 

func (*OAuth2MetadataResponse) ProtoMessage()

func (*OAuth2MetadataResponse) Reset added in v0.18.40 

func (m *OAuth2MetadataResponse) Reset()

func (*OAuth2MetadataResponse) String added in v0.18.40 

func (m *OAuth2MetadataResponse) String() string

func (*OAuth2MetadataResponse) XXX_DiscardUnknown added in v0.18.40 

func (m *OAuth2MetadataResponse) XXX_DiscardUnknown()

func (*OAuth2MetadataResponse) XXX_Marshal added in v0.18.40 

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

func (*OAuth2MetadataResponse) XXX_Merge added in v0.18.40 

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

func (*OAuth2MetadataResponse) XXX_Size added in v0.18.40 

func (m *OAuth2MetadataResponse) XXX_Size() int

func (*OAuth2MetadataResponse) XXX_Unmarshal added in v0.18.40 

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

type PublicClientAuthConfigRequest added in v0.18.40 

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

func (*PublicClientAuthConfigRequest) Descriptor added in v0.18.40 

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

func (*PublicClientAuthConfigRequest) ProtoMessage added in v0.18.40 

func (*PublicClientAuthConfigRequest) ProtoMessage()

func (*PublicClientAuthConfigRequest) Reset added in v0.18.40 

func (m *PublicClientAuthConfigRequest) Reset()

func (*PublicClientAuthConfigRequest) String added in v0.18.40 

func (m *PublicClientAuthConfigRequest) String() string

func (*PublicClientAuthConfigRequest) XXX_DiscardUnknown added in v0.18.40 

func (m *PublicClientAuthConfigRequest) XXX_DiscardUnknown()

func (*PublicClientAuthConfigRequest) XXX_Marshal added in v0.18.40 

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

func (*PublicClientAuthConfigRequest) XXX_Merge added in v0.18.40 

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

func (*PublicClientAuthConfigRequest) XXX_Size added in v0.18.40 

func (m *PublicClientAuthConfigRequest) XXX_Size() int

func (*PublicClientAuthConfigRequest) XXX_Unmarshal added in v0.18.40 

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

type PublicClientAuthConfigResponse added in v0.18.40 

type PublicClientAuthConfigResponse struct {
	// client_id to use when initiating OAuth2 authorization requests.
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// redirect uri to use when initiating OAuth2 authorization requests.
	RedirectUri string `protobuf:"bytes,2,opt,name=redirect_uri,json=redirectUri,proto3" json:"redirect_uri,omitempty"`
	// scopes to request when initiating OAuth2 authorization requests.
	Scopes []string `protobuf:"bytes,3,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// Authorization Header to use when passing Access Tokens to the server. If not provided, the client should use the
	// default http `Authorization` header.
	AuthorizationMetadataKey string `` /* 135-byte string literal not displayed */
	// ServiceHttpEndpoint points to the http endpoint for the backend. If empty, clients can assume the endpoint used
	// to configure the gRPC connection can be used for the http one respecting the insecure flag to choose between
	// SSL or no SSL connections.
	ServiceHttpEndpoint string `protobuf:"bytes,5,opt,name=service_http_endpoint,json=serviceHttpEndpoint,proto3" json:"service_http_endpoint,omitempty"`
	// audience to use when initiating OAuth2 authorization requests.
	Audience             string   `protobuf:"bytes,6,opt,name=audience,proto3" json:"audience,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FlyteClientResponse encapsulates public information that flyte clients (CLIs... etc.) can use to authenticate users.

func (*PublicClientAuthConfigResponse) Descriptor added in v0.18.40 

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

func (*PublicClientAuthConfigResponse) GetAudience added in v1.1.22 

func (m *PublicClientAuthConfigResponse) GetAudience() string

func (*PublicClientAuthConfigResponse) GetAuthorizationMetadataKey added in v0.18.40 

func (m *PublicClientAuthConfigResponse) GetAuthorizationMetadataKey() string

func (*PublicClientAuthConfigResponse) GetClientId added in v0.18.40 

func (m *PublicClientAuthConfigResponse) GetClientId() string

func (*PublicClientAuthConfigResponse) GetRedirectUri added in v0.18.40 

func (m *PublicClientAuthConfigResponse) GetRedirectUri() string

func (*PublicClientAuthConfigResponse) GetScopes added in v0.18.40 

func (m *PublicClientAuthConfigResponse) GetScopes() []string

func (*PublicClientAuthConfigResponse) GetServiceHttpEndpoint added in v0.24.18 

func (m *PublicClientAuthConfigResponse) GetServiceHttpEndpoint() string

func (*PublicClientAuthConfigResponse) ProtoMessage added in v0.18.40 

func (*PublicClientAuthConfigResponse) ProtoMessage()

func (*PublicClientAuthConfigResponse) Reset added in v0.18.40 

func (m *PublicClientAuthConfigResponse) Reset()

func (*PublicClientAuthConfigResponse) String added in v0.18.40 

func (m *PublicClientAuthConfigResponse) String() string

func (*PublicClientAuthConfigResponse) XXX_DiscardUnknown added in v0.18.40 

func (m *PublicClientAuthConfigResponse) XXX_DiscardUnknown()

func (*PublicClientAuthConfigResponse) XXX_Marshal added in v0.18.40 

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

func (*PublicClientAuthConfigResponse) XXX_Merge added in v0.18.40 

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

func (*PublicClientAuthConfigResponse) XXX_Size added in v0.18.40 

func (m *PublicClientAuthConfigResponse) XXX_Size() int

func (*PublicClientAuthConfigResponse) XXX_Unmarshal added in v0.18.40 

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

type SignalServiceClient added in v1.2.1 

type SignalServiceClient interface {
	// Fetches or creates a :ref:`ref_flyteidl.admin.Signal`.
	GetOrCreateSignal(ctx context.Context, in *admin.SignalGetOrCreateRequest, opts ...grpc.CallOption) (*admin.Signal, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.Signal` definitions.
	ListSignals(ctx context.Context, in *admin.SignalListRequest, opts ...grpc.CallOption) (*admin.SignalList, error)
	// Sets the value on a :ref:`ref_flyteidl.admin.Signal` definition
	SetSignal(ctx context.Context, in *admin.SignalSetRequest, opts ...grpc.CallOption) (*admin.SignalSetResponse, error)
}

SignalServiceClient is the client API for SignalService service.

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

func NewSignalServiceClient added in v1.2.1 

func NewSignalServiceClient(cc *grpc.ClientConn) SignalServiceClient

type SignalServiceServer added in v1.2.1 

type SignalServiceServer interface {
	// Fetches or creates a :ref:`ref_flyteidl.admin.Signal`.
	GetOrCreateSignal(context.Context, *admin.SignalGetOrCreateRequest) (*admin.Signal, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.Signal` definitions.
	ListSignals(context.Context, *admin.SignalListRequest) (*admin.SignalList, error)
	// Sets the value on a :ref:`ref_flyteidl.admin.Signal` definition
	SetSignal(context.Context, *admin.SignalSetRequest) (*admin.SignalSetResponse, error)
}

SignalServiceServer is the server API for SignalService service.

type State added in v1.2.10 

type State int32

The state of the execution is used to control its visibility in the UI/CLI. 

const (
	State_RETRYABLE_FAILURE State = 0
	State_PERMANENT_FAILURE State = 1
	State_PENDING           State = 2
	State_RUNNING           State = 3
	State_SUCCEEDED         State = 4
)

func (State) EnumDescriptor added in v1.2.10 

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

func (State) String added in v1.2.10 

func (x State) String() string

type TaskCreateRequest added in v1.2.10 

type TaskCreateRequest struct {
	// The inputs required to start the execution. All required inputs must be
	// included in this map. If not required and not provided, defaults apply.
	// +optional
	Inputs *core.LiteralMap `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Template of the task that encapsulates all the metadata of the task.
	Template *core.TaskTemplate `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
	// Prefix for where task output data will be written. (e.g. s3://my-bucket/randomstring)
	OutputPrefix         string   `protobuf:"bytes,3,opt,name=output_prefix,json=outputPrefix,proto3" json:"output_prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents a request structure to create task.

func (*TaskCreateRequest) Descriptor added in v1.2.10 

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

func (*TaskCreateRequest) GetInputs added in v1.2.10 

func (m *TaskCreateRequest) GetInputs() *core.LiteralMap

func (*TaskCreateRequest) GetOutputPrefix added in v1.2.10 

func (m *TaskCreateRequest) GetOutputPrefix() string

func (*TaskCreateRequest) GetTemplate added in v1.2.10 

func (m *TaskCreateRequest) GetTemplate() *core.TaskTemplate

func (*TaskCreateRequest) ProtoMessage added in v1.2.10 

func (*TaskCreateRequest) ProtoMessage()

func (*TaskCreateRequest) Reset added in v1.2.10 

func (m *TaskCreateRequest) Reset()

func (*TaskCreateRequest) String added in v1.2.10 

func (m *TaskCreateRequest) String() string

func (*TaskCreateRequest) XXX_DiscardUnknown added in v1.2.10 

func (m *TaskCreateRequest) XXX_DiscardUnknown()

func (*TaskCreateRequest) XXX_Marshal added in v1.2.10 

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

func (*TaskCreateRequest) XXX_Merge added in v1.2.10 

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

func (*TaskCreateRequest) XXX_Size added in v1.2.10 

func (m *TaskCreateRequest) XXX_Size() int

func (*TaskCreateRequest) XXX_Unmarshal added in v1.2.10 

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

type TaskCreateResponse added in v1.2.10 

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

Represents a create response structure.

func (*TaskCreateResponse) Descriptor added in v1.2.10 

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

func (*TaskCreateResponse) GetJobId added in v1.2.10 

func (m *TaskCreateResponse) GetJobId() string

func (*TaskCreateResponse) ProtoMessage added in v1.2.10 

func (*TaskCreateResponse) ProtoMessage()

func (*TaskCreateResponse) Reset added in v1.2.10 

func (m *TaskCreateResponse) Reset()

func (*TaskCreateResponse) String added in v1.2.10 

func (m *TaskCreateResponse) String() string

func (*TaskCreateResponse) XXX_DiscardUnknown added in v1.2.10 

func (m *TaskCreateResponse) XXX_DiscardUnknown()

func (*TaskCreateResponse) XXX_Marshal added in v1.2.10 

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

func (*TaskCreateResponse) XXX_Merge added in v1.2.10 

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

func (*TaskCreateResponse) XXX_Size added in v1.2.10 

func (m *TaskCreateResponse) XXX_Size() int

func (*TaskCreateResponse) XXX_Unmarshal added in v1.2.10 

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

type TaskDeleteRequest added in v1.2.10 

type TaskDeleteRequest struct {
	// A predefined yet extensible Task type identifier.
	TaskType string `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// The unique id identifying the job.
	JobId                string   `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A message used to delete a task.

func (*TaskDeleteRequest) Descriptor added in v1.2.10 

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

func (*TaskDeleteRequest) GetJobId added in v1.2.10 

func (m *TaskDeleteRequest) GetJobId() string

func (*TaskDeleteRequest) GetTaskType added in v1.2.10 

func (m *TaskDeleteRequest) GetTaskType() string

func (*TaskDeleteRequest) ProtoMessage added in v1.2.10 

func (*TaskDeleteRequest) ProtoMessage()

func (*TaskDeleteRequest) Reset added in v1.2.10 

func (m *TaskDeleteRequest) Reset()

func (*TaskDeleteRequest) String added in v1.2.10 

func (m *TaskDeleteRequest) String() string

func (*TaskDeleteRequest) XXX_DiscardUnknown added in v1.2.10 

func (m *TaskDeleteRequest) XXX_DiscardUnknown()

func (*TaskDeleteRequest) XXX_Marshal added in v1.2.10 

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

func (*TaskDeleteRequest) XXX_Merge added in v1.2.10 

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

func (*TaskDeleteRequest) XXX_Size added in v1.2.10 

func (m *TaskDeleteRequest) XXX_Size() int

func (*TaskDeleteRequest) XXX_Unmarshal added in v1.2.10 

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

type TaskDeleteResponse added in v1.2.10 

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

Response to delete a task.

func (*TaskDeleteResponse) Descriptor added in v1.2.10 

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

func (*TaskDeleteResponse) ProtoMessage added in v1.2.10 

func (*TaskDeleteResponse) ProtoMessage()

func (*TaskDeleteResponse) Reset added in v1.2.10 

func (m *TaskDeleteResponse) Reset()

func (*TaskDeleteResponse) String added in v1.2.10 

func (m *TaskDeleteResponse) String() string

func (*TaskDeleteResponse) XXX_DiscardUnknown added in v1.2.10 

func (m *TaskDeleteResponse) XXX_DiscardUnknown()

func (*TaskDeleteResponse) XXX_Marshal added in v1.2.10 

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

func (*TaskDeleteResponse) XXX_Merge added in v1.2.10 

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

func (*TaskDeleteResponse) XXX_Size added in v1.2.10 

func (m *TaskDeleteResponse) XXX_Size() int

func (*TaskDeleteResponse) XXX_Unmarshal added in v1.2.10 

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

type TaskGetRequest added in v1.2.10 

type TaskGetRequest struct {
	// A predefined yet extensible Task type identifier.
	TaskType string `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// The unique id identifying the job.
	JobId                string   `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A message used to fetch a job state from backend plugin server.

func (*TaskGetRequest) Descriptor added in v1.2.10 

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

func (*TaskGetRequest) GetJobId added in v1.2.10 

func (m *TaskGetRequest) GetJobId() string

func (*TaskGetRequest) GetTaskType added in v1.2.10 

func (m *TaskGetRequest) GetTaskType() string

func (*TaskGetRequest) ProtoMessage added in v1.2.10 

func (*TaskGetRequest) ProtoMessage()

func (*TaskGetRequest) Reset added in v1.2.10 

func (m *TaskGetRequest) Reset()

func (*TaskGetRequest) String added in v1.2.10 

func (m *TaskGetRequest) String() string

func (*TaskGetRequest) XXX_DiscardUnknown added in v1.2.10 

func (m *TaskGetRequest) XXX_DiscardUnknown()

func (*TaskGetRequest) XXX_Marshal added in v1.2.10 

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

func (*TaskGetRequest) XXX_Merge added in v1.2.10 

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

func (*TaskGetRequest) XXX_Size added in v1.2.10 

func (m *TaskGetRequest) XXX_Size() int

func (*TaskGetRequest) XXX_Unmarshal added in v1.2.10 

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

type TaskGetResponse added in v1.2.10 

type TaskGetResponse struct {
	// The state of the execution is used to control its visibility in the UI/CLI.
	State State `protobuf:"varint,1,opt,name=state,proto3,enum=flyteidl.service.State" json:"state,omitempty"`
	// The outputs of the execution. It's typically used by sql task. Flyteplugins service will create a
	// Structured dataset pointing to the query result table.
	// +optional
	Outputs              *core.LiteralMap `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Response to get an individual task state.

func (*TaskGetResponse) Descriptor added in v1.2.10 

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

func (*TaskGetResponse) GetOutputs added in v1.2.10 

func (m *TaskGetResponse) GetOutputs() *core.LiteralMap

func (*TaskGetResponse) GetState added in v1.2.10 

func (m *TaskGetResponse) GetState() State

func (*TaskGetResponse) ProtoMessage added in v1.2.10 

func (*TaskGetResponse) ProtoMessage()

func (*TaskGetResponse) Reset added in v1.2.10 

func (m *TaskGetResponse) Reset()

func (*TaskGetResponse) String added in v1.2.10 

func (m *TaskGetResponse) String() string

func (*TaskGetResponse) XXX_DiscardUnknown added in v1.2.10 

func (m *TaskGetResponse) XXX_DiscardUnknown()

func (*TaskGetResponse) XXX_Marshal added in v1.2.10 

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

func (*TaskGetResponse) XXX_Merge added in v1.2.10 

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

func (*TaskGetResponse) XXX_Size added in v1.2.10 

func (m *TaskGetResponse) XXX_Size() int

func (*TaskGetResponse) XXX_Unmarshal added in v1.2.10 

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

type UnimplementedAdminServiceServer added in v0.16.1 

type UnimplementedAdminServiceServer struct {
}

UnimplementedAdminServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdminServiceServer) CreateExecution added in v0.16.1 

func (*UnimplementedAdminServiceServer) CreateExecution(ctx context.Context, req *admin.ExecutionCreateRequest) (*admin.ExecutionCreateResponse, error)

func (*UnimplementedAdminServiceServer) CreateLaunchPlan added in v0.16.1 

func (*UnimplementedAdminServiceServer) CreateLaunchPlan(ctx context.Context, req *admin.LaunchPlanCreateRequest) (*admin.LaunchPlanCreateResponse, error)

func (*UnimplementedAdminServiceServer) CreateNodeEvent added in v0.16.1 

func (*UnimplementedAdminServiceServer) CreateNodeEvent(ctx context.Context, req *admin.NodeExecutionEventRequest) (*admin.NodeExecutionEventResponse, error)

func (*UnimplementedAdminServiceServer) CreateTask added in v0.16.1 

func (*UnimplementedAdminServiceServer) CreateTask(ctx context.Context, req *admin.TaskCreateRequest) (*admin.TaskCreateResponse, error)

func (*UnimplementedAdminServiceServer) CreateTaskEvent added in v0.16.1 

func (*UnimplementedAdminServiceServer) CreateTaskEvent(ctx context.Context, req *admin.TaskExecutionEventRequest) (*admin.TaskExecutionEventResponse, error)

func (*UnimplementedAdminServiceServer) CreateWorkflow added in v0.16.1 

func (*UnimplementedAdminServiceServer) CreateWorkflow(ctx context.Context, req *admin.WorkflowCreateRequest) (*admin.WorkflowCreateResponse, error)

func (*UnimplementedAdminServiceServer) CreateWorkflowEvent added in v0.16.1 

func (*UnimplementedAdminServiceServer) CreateWorkflowEvent(ctx context.Context, req *admin.WorkflowExecutionEventRequest) (*admin.WorkflowExecutionEventResponse, error)

func (*UnimplementedAdminServiceServer) DeleteProjectAttributes added in v0.16.5 

func (*UnimplementedAdminServiceServer) DeleteProjectAttributes(ctx context.Context, req *admin.ProjectAttributesDeleteRequest) (*admin.ProjectAttributesDeleteResponse, error)

func (*UnimplementedAdminServiceServer) DeleteProjectDomainAttributes added in v0.16.5 

func (*UnimplementedAdminServiceServer) DeleteProjectDomainAttributes(ctx context.Context, req *admin.ProjectDomainAttributesDeleteRequest) (*admin.ProjectDomainAttributesDeleteResponse, error)

func (*UnimplementedAdminServiceServer) DeleteWorkflowAttributes added in v0.16.5 

func (*UnimplementedAdminServiceServer) DeleteWorkflowAttributes(ctx context.Context, req *admin.WorkflowAttributesDeleteRequest) (*admin.WorkflowAttributesDeleteResponse, error)

func (*UnimplementedAdminServiceServer) GetActiveLaunchPlan added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetActiveLaunchPlan(ctx context.Context, req *admin.ActiveLaunchPlanRequest) (*admin.LaunchPlan, error)

func (*UnimplementedAdminServiceServer) GetDescriptionEntity added in v1.2.4 

func (*UnimplementedAdminServiceServer) GetDescriptionEntity(ctx context.Context, req *admin.ObjectGetRequest) (*admin.DescriptionEntity, error)

func (*UnimplementedAdminServiceServer) GetExecution added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetExecution(ctx context.Context, req *admin.WorkflowExecutionGetRequest) (*admin.Execution, error)

func (*UnimplementedAdminServiceServer) GetExecutionData added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetExecutionData(ctx context.Context, req *admin.WorkflowExecutionGetDataRequest) (*admin.WorkflowExecutionGetDataResponse, error)

func (*UnimplementedAdminServiceServer) GetExecutionMetrics added in v1.2.10 

func (*UnimplementedAdminServiceServer) GetExecutionMetrics(ctx context.Context, req *admin.WorkflowExecutionGetMetricsRequest) (*admin.WorkflowExecutionGetMetricsResponse, error)

func (*UnimplementedAdminServiceServer) GetLaunchPlan added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetLaunchPlan(ctx context.Context, req *admin.ObjectGetRequest) (*admin.LaunchPlan, error)

func (*UnimplementedAdminServiceServer) GetNamedEntity added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetNamedEntity(ctx context.Context, req *admin.NamedEntityGetRequest) (*admin.NamedEntity, error)

func (*UnimplementedAdminServiceServer) GetNodeExecution added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetNodeExecution(ctx context.Context, req *admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)

func (*UnimplementedAdminServiceServer) GetNodeExecutionData added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetNodeExecutionData(ctx context.Context, req *admin.NodeExecutionGetDataRequest) (*admin.NodeExecutionGetDataResponse, error)

func (*UnimplementedAdminServiceServer) GetProjectAttributes added in v0.16.5 

func (*UnimplementedAdminServiceServer) GetProjectAttributes(ctx context.Context, req *admin.ProjectAttributesGetRequest) (*admin.ProjectAttributesGetResponse, error)

func (*UnimplementedAdminServiceServer) GetProjectDomainAttributes added in v0.16.5 

func (*UnimplementedAdminServiceServer) GetProjectDomainAttributes(ctx context.Context, req *admin.ProjectDomainAttributesGetRequest) (*admin.ProjectDomainAttributesGetResponse, error)

func (*UnimplementedAdminServiceServer) GetTask added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetTask(ctx context.Context, req *admin.ObjectGetRequest) (*admin.Task, error)

func (*UnimplementedAdminServiceServer) GetTaskExecution added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetTaskExecution(ctx context.Context, req *admin.TaskExecutionGetRequest) (*admin.TaskExecution, error)

func (*UnimplementedAdminServiceServer) GetTaskExecutionData added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetTaskExecutionData(ctx context.Context, req *admin.TaskExecutionGetDataRequest) (*admin.TaskExecutionGetDataResponse, error)

func (*UnimplementedAdminServiceServer) GetVersion added in v0.18.17 

func (*UnimplementedAdminServiceServer) GetVersion(ctx context.Context, req *admin.GetVersionRequest) (*admin.GetVersionResponse, error)

func (*UnimplementedAdminServiceServer) GetWorkflow added in v0.16.1 

func (*UnimplementedAdminServiceServer) GetWorkflow(ctx context.Context, req *admin.ObjectGetRequest) (*admin.Workflow, error)

func (*UnimplementedAdminServiceServer) GetWorkflowAttributes added in v0.16.5 

func (*UnimplementedAdminServiceServer) GetWorkflowAttributes(ctx context.Context, req *admin.WorkflowAttributesGetRequest) (*admin.WorkflowAttributesGetResponse, error)

func (*UnimplementedAdminServiceServer) ListActiveLaunchPlans added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListActiveLaunchPlans(ctx context.Context, req *admin.ActiveLaunchPlanListRequest) (*admin.LaunchPlanList, error)

func (*UnimplementedAdminServiceServer) ListDescriptionEntities added in v1.2.4 

func (*UnimplementedAdminServiceServer) ListDescriptionEntities(ctx context.Context, req *admin.DescriptionEntityListRequest) (*admin.DescriptionEntityList, error)

func (*UnimplementedAdminServiceServer) ListExecutions added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListExecutions(ctx context.Context, req *admin.ResourceListRequest) (*admin.ExecutionList, error)

func (*UnimplementedAdminServiceServer) ListLaunchPlanIds added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListLaunchPlanIds(ctx context.Context, req *admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)

func (*UnimplementedAdminServiceServer) ListLaunchPlans added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListLaunchPlans(ctx context.Context, req *admin.ResourceListRequest) (*admin.LaunchPlanList, error)

func (*UnimplementedAdminServiceServer) ListMatchableAttributes added in v0.18.15 

func (*UnimplementedAdminServiceServer) ListMatchableAttributes(ctx context.Context, req *admin.ListMatchableAttributesRequest) (*admin.ListMatchableAttributesResponse, error)

func (*UnimplementedAdminServiceServer) ListNamedEntities added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListNamedEntities(ctx context.Context, req *admin.NamedEntityListRequest) (*admin.NamedEntityList, error)

func (*UnimplementedAdminServiceServer) ListNodeExecutions added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListNodeExecutions(ctx context.Context, req *admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)

func (*UnimplementedAdminServiceServer) ListNodeExecutionsForTask added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListNodeExecutionsForTask(ctx context.Context, req *admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error)

func (*UnimplementedAdminServiceServer) ListProjects added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListProjects(ctx context.Context, req *admin.ProjectListRequest) (*admin.Projects, error)

func (*UnimplementedAdminServiceServer) ListTaskExecutions added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListTaskExecutions(ctx context.Context, req *admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error)

func (*UnimplementedAdminServiceServer) ListTaskIds added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListTaskIds(ctx context.Context, req *admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)

func (*UnimplementedAdminServiceServer) ListTasks added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListTasks(ctx context.Context, req *admin.ResourceListRequest) (*admin.TaskList, error)

func (*UnimplementedAdminServiceServer) ListWorkflowIds added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListWorkflowIds(ctx context.Context, req *admin.NamedEntityIdentifierListRequest) (*admin.NamedEntityIdentifierList, error)

func (*UnimplementedAdminServiceServer) ListWorkflows added in v0.16.1 

func (*UnimplementedAdminServiceServer) ListWorkflows(ctx context.Context, req *admin.ResourceListRequest) (*admin.WorkflowList, error)

func (*UnimplementedAdminServiceServer) RecoverExecution added in v0.19.14 

func (*UnimplementedAdminServiceServer) RecoverExecution(ctx context.Context, req *admin.ExecutionRecoverRequest) (*admin.ExecutionCreateResponse, error)

func (*UnimplementedAdminServiceServer) RegisterProject added in v0.16.1 

func (*UnimplementedAdminServiceServer) RegisterProject(ctx context.Context, req *admin.ProjectRegisterRequest) (*admin.ProjectRegisterResponse, error)

func (*UnimplementedAdminServiceServer) RelaunchExecution added in v0.16.1 

func (*UnimplementedAdminServiceServer) RelaunchExecution(ctx context.Context, req *admin.ExecutionRelaunchRequest) (*admin.ExecutionCreateResponse, error)

func (*UnimplementedAdminServiceServer) TerminateExecution added in v0.16.1 

func (*UnimplementedAdminServiceServer) TerminateExecution(ctx context.Context, req *admin.ExecutionTerminateRequest) (*admin.ExecutionTerminateResponse, error)

func (*UnimplementedAdminServiceServer) UpdateExecution added in v0.21.24 

func (*UnimplementedAdminServiceServer) UpdateExecution(ctx context.Context, req *admin.ExecutionUpdateRequest) (*admin.ExecutionUpdateResponse, error)

func (*UnimplementedAdminServiceServer) UpdateLaunchPlan added in v0.16.1 

func (*UnimplementedAdminServiceServer) UpdateLaunchPlan(ctx context.Context, req *admin.LaunchPlanUpdateRequest) (*admin.LaunchPlanUpdateResponse, error)

func (*UnimplementedAdminServiceServer) UpdateNamedEntity added in v0.16.1 

func (*UnimplementedAdminServiceServer) UpdateNamedEntity(ctx context.Context, req *admin.NamedEntityUpdateRequest) (*admin.NamedEntityUpdateResponse, error)

func (*UnimplementedAdminServiceServer) UpdateProject added in v0.18.15 

func (*UnimplementedAdminServiceServer) UpdateProject(ctx context.Context, req *admin.Project) (*admin.ProjectUpdateResponse, error)

func (*UnimplementedAdminServiceServer) UpdateProjectAttributes added in v0.16.4 

func (*UnimplementedAdminServiceServer) UpdateProjectAttributes(ctx context.Context, req *admin.ProjectAttributesUpdateRequest) (*admin.ProjectAttributesUpdateResponse, error)

func (*UnimplementedAdminServiceServer) UpdateProjectDomainAttributes added in v0.16.1 

func (*UnimplementedAdminServiceServer) UpdateProjectDomainAttributes(ctx context.Context, req *admin.ProjectDomainAttributesUpdateRequest) (*admin.ProjectDomainAttributesUpdateResponse, error)

func (*UnimplementedAdminServiceServer) UpdateWorkflowAttributes added in v0.16.4 

func (*UnimplementedAdminServiceServer) UpdateWorkflowAttributes(ctx context.Context, req *admin.WorkflowAttributesUpdateRequest) (*admin.WorkflowAttributesUpdateResponse, error)

type UnimplementedAuthMetadataServiceServer added in v0.18.40 

type UnimplementedAuthMetadataServiceServer struct {
}

UnimplementedAuthMetadataServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAuthMetadataServiceServer) GetOAuth2Metadata added in v0.18.40 

func (*UnimplementedAuthMetadataServiceServer) GetOAuth2Metadata(ctx context.Context, req *OAuth2MetadataRequest) (*OAuth2MetadataResponse, error)

func (*UnimplementedAuthMetadataServiceServer) GetPublicClientConfig added in v0.18.40 

func (*UnimplementedAuthMetadataServiceServer) GetPublicClientConfig(ctx context.Context, req *PublicClientAuthConfigRequest) (*PublicClientAuthConfigResponse, error)

type UnimplementedDataProxyServiceServer added in v0.24.10 

type UnimplementedDataProxyServiceServer struct {
}

UnimplementedDataProxyServiceServer can be embedded to have forward compatible implementations. 

func (*UnimplementedDataProxyServiceServer) CreateDownloadLink(ctx context.Context, req *CreateDownloadLinkRequest) (*CreateDownloadLinkResponse, error)

func (*UnimplementedDataProxyServiceServer) CreateDownloadLocation added in v1.1.3 

func (*UnimplementedDataProxyServiceServer) CreateDownloadLocation(ctx context.Context, req *CreateDownloadLocationRequest) (*CreateDownloadLocationResponse, error)

func (*UnimplementedDataProxyServiceServer) CreateUploadLocation added in v0.24.10 

func (*UnimplementedDataProxyServiceServer) CreateUploadLocation(ctx context.Context, req *CreateUploadLocationRequest) (*CreateUploadLocationResponse, error)

type UnimplementedExternalPluginServiceServer added in v1.2.10 

type UnimplementedExternalPluginServiceServer struct {
}

UnimplementedExternalPluginServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedExternalPluginServiceServer) CreateTask added in v1.2.10 

func (*UnimplementedExternalPluginServiceServer) CreateTask(ctx context.Context, req *TaskCreateRequest) (*TaskCreateResponse, error)

func (*UnimplementedExternalPluginServiceServer) DeleteTask added in v1.2.10 

func (*UnimplementedExternalPluginServiceServer) DeleteTask(ctx context.Context, req *TaskDeleteRequest) (*TaskDeleteResponse, error)

func (*UnimplementedExternalPluginServiceServer) GetTask added in v1.2.10 

func (*UnimplementedExternalPluginServiceServer) GetTask(ctx context.Context, req *TaskGetRequest) (*TaskGetResponse, error)

type UnimplementedIdentityServiceServer added in v0.18.40 

type UnimplementedIdentityServiceServer struct {
}

UnimplementedIdentityServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIdentityServiceServer) UserInfo added in v0.18.40 

func (*UnimplementedIdentityServiceServer) UserInfo(ctx context.Context, req *UserInfoRequest) (*UserInfoResponse, error)

type UnimplementedSignalServiceServer added in v1.2.1 

type UnimplementedSignalServiceServer struct {
}

UnimplementedSignalServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSignalServiceServer) GetOrCreateSignal added in v1.2.1 

func (*UnimplementedSignalServiceServer) GetOrCreateSignal(ctx context.Context, req *admin.SignalGetOrCreateRequest) (*admin.Signal, error)

func (*UnimplementedSignalServiceServer) ListSignals added in v1.2.1 

func (*UnimplementedSignalServiceServer) ListSignals(ctx context.Context, req *admin.SignalListRequest) (*admin.SignalList, error)

func (*UnimplementedSignalServiceServer) SetSignal added in v1.2.1 

func (*UnimplementedSignalServiceServer) SetSignal(ctx context.Context, req *admin.SignalSetRequest) (*admin.SignalSetResponse, error)

type UserInfoRequest added in v0.18.40 

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

func (*UserInfoRequest) Descriptor added in v0.18.40 

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

func (*UserInfoRequest) ProtoMessage added in v0.18.40 

func (*UserInfoRequest) ProtoMessage()

func (*UserInfoRequest) Reset added in v0.18.40 

func (m *UserInfoRequest) Reset()

func (*UserInfoRequest) String added in v0.18.40 

func (m *UserInfoRequest) String() string

func (*UserInfoRequest) XXX_DiscardUnknown added in v0.18.40 

func (m *UserInfoRequest) XXX_DiscardUnknown()

func (*UserInfoRequest) XXX_Marshal added in v0.18.40 

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

func (*UserInfoRequest) XXX_Merge added in v0.18.40 

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

func (*UserInfoRequest) XXX_Size added in v0.18.40 

func (m *UserInfoRequest) XXX_Size() int

func (*UserInfoRequest) XXX_Unmarshal added in v0.18.40 

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

type UserInfoResponse added in v0.18.40 

type UserInfoResponse struct {
	// Locally unique and never reassigned identifier within the Issuer for the End-User, which is intended to be consumed
	// by the Client.
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	// Full name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Shorthand name by which the End-User wishes to be referred to
	PreferredUsername string `protobuf:"bytes,3,opt,name=preferred_username,json=preferredUsername,proto3" json:"preferred_username,omitempty"`
	// Given name(s) or first name(s)
	GivenName string `protobuf:"bytes,4,opt,name=given_name,json=givenName,proto3" json:"given_name,omitempty"`
	// Surname(s) or last name(s)
	FamilyName string `protobuf:"bytes,5,opt,name=family_name,json=familyName,proto3" json:"family_name,omitempty"`
	// Preferred e-mail address
	Email string `protobuf:"bytes,6,opt,name=email,proto3" json:"email,omitempty"`
	// Profile picture URL
	Picture string `protobuf:"bytes,7,opt,name=picture,proto3" json:"picture,omitempty"`
	// Additional claims
	AdditionalClaims     *_struct.Struct `protobuf:"bytes,8,opt,name=additional_claims,json=additionalClaims,proto3" json:"additional_claims,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

See the OpenID Connect spec at https://openid.net/specs/openid-connect-core-1_0.html#UserInfoResponse for more information.

func (*UserInfoResponse) Descriptor added in v0.18.40 

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

func (*UserInfoResponse) GetAdditionalClaims added in v1.2.9 

func (m *UserInfoResponse) GetAdditionalClaims() *_struct.Struct

func (*UserInfoResponse) GetEmail added in v0.18.40 

func (m *UserInfoResponse) GetEmail() string

func (*UserInfoResponse) GetFamilyName added in v0.18.40 

func (m *UserInfoResponse) GetFamilyName() string

func (*UserInfoResponse) GetGivenName added in v0.18.40 

func (m *UserInfoResponse) GetGivenName() string

func (*UserInfoResponse) GetName added in v0.18.40 

func (m *UserInfoResponse) GetName() string

func (*UserInfoResponse) GetPicture added in v0.18.40 

func (m *UserInfoResponse) GetPicture() string

func (*UserInfoResponse) GetPreferredUsername added in v0.18.40 

func (m *UserInfoResponse) GetPreferredUsername() string

func (*UserInfoResponse) GetSubject added in v0.18.40 

func (m *UserInfoResponse) GetSubject() string

func (*UserInfoResponse) ProtoMessage added in v0.18.40 

func (*UserInfoResponse) ProtoMessage()

func (*UserInfoResponse) Reset added in v0.18.40 

func (m *UserInfoResponse) Reset()

func (*UserInfoResponse) String added in v0.18.40 

func (m *UserInfoResponse) String() string

func (*UserInfoResponse) XXX_DiscardUnknown added in v0.18.40 

func (m *UserInfoResponse) XXX_DiscardUnknown()

func (*UserInfoResponse) XXX_Marshal added in v0.18.40 

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

func (*UserInfoResponse) XXX_Merge added in v0.18.40 

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

func (*UserInfoResponse) XXX_Size added in v0.18.40 

func (m *UserInfoResponse) XXX_Size() int

func (*UserInfoResponse) XXX_Unmarshal added in v0.18.40 

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

Source Files

View all Source files

Directories

Path Synopsis

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.