service

package
v1.0.15 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

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 

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 

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 

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 

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

func RegisterDataProxyServiceHandler 

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 

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 

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 

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

func RegisterExternalPluginServiceServer 

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

func RegisterIdentityServiceHandler 

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 

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 

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 

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

func RegisterSignalServiceHandler 

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 

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 

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 

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 

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 

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

func (ArtifactType) String 

func (x ArtifactType) String() string

type AuthMetadataServiceClient 

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 

func NewAuthMetadataServiceClient(cc *grpc.ClientConn) AuthMetadataServiceClient

type AuthMetadataServiceServer 

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 

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 

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

func (*CreateDownloadLinkRequest) GetArtifactType 

func (m *CreateDownloadLinkRequest) GetArtifactType() ArtifactType

func (*CreateDownloadLinkRequest) GetExpiresIn 

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

func (*CreateDownloadLinkRequest) GetNodeExecutionId 

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

func (*CreateDownloadLinkRequest) GetSource 

func (m *CreateDownloadLinkRequest) GetSource() isCreateDownloadLinkRequest_Source

func (*CreateDownloadLinkRequest) ProtoMessage 

func (*CreateDownloadLinkRequest) ProtoMessage()

func (*CreateDownloadLinkRequest) Reset 

func (m *CreateDownloadLinkRequest) Reset()

func (*CreateDownloadLinkRequest) String 

func (m *CreateDownloadLinkRequest) String() string

func (*CreateDownloadLinkRequest) XXX_DiscardUnknown 

func (m *CreateDownloadLinkRequest) XXX_DiscardUnknown()

func (*CreateDownloadLinkRequest) XXX_Marshal 

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

func (*CreateDownloadLinkRequest) XXX_Merge 

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

func (*CreateDownloadLinkRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*CreateDownloadLinkRequest) XXX_Size 

func (m *CreateDownloadLinkRequest) XXX_Size() int

func (*CreateDownloadLinkRequest) XXX_Unmarshal 

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

type CreateDownloadLinkRequest_NodeExecutionId 

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

type CreateDownloadLinkResponse 

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 

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

func (*CreateDownloadLinkResponse) GetExpiresAt 

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

func (*CreateDownloadLinkResponse) GetSignedUrl 

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

func (*CreateDownloadLinkResponse) ProtoMessage 

func (*CreateDownloadLinkResponse) ProtoMessage()

func (*CreateDownloadLinkResponse) Reset 

func (m *CreateDownloadLinkResponse) Reset()

func (*CreateDownloadLinkResponse) String 

func (m *CreateDownloadLinkResponse) String() string

func (*CreateDownloadLinkResponse) XXX_DiscardUnknown 

func (m *CreateDownloadLinkResponse) XXX_DiscardUnknown()

func (*CreateDownloadLinkResponse) XXX_Marshal 

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

func (*CreateDownloadLinkResponse) XXX_Merge 

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

func (*CreateDownloadLinkResponse) XXX_Size 

func (m *CreateDownloadLinkResponse) XXX_Size() int

func (*CreateDownloadLinkResponse) XXX_Unmarshal 

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

type CreateDownloadLocationRequest deprecated 

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 

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

func (*CreateDownloadLocationRequest) GetExpiresIn 

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

func (*CreateDownloadLocationRequest) GetNativeUrl 

func (m *CreateDownloadLocationRequest) GetNativeUrl() string

func (*CreateDownloadLocationRequest) ProtoMessage 

func (*CreateDownloadLocationRequest) ProtoMessage()

func (*CreateDownloadLocationRequest) Reset 

func (m *CreateDownloadLocationRequest) Reset()

func (*CreateDownloadLocationRequest) String 

func (m *CreateDownloadLocationRequest) String() string

func (*CreateDownloadLocationRequest) XXX_DiscardUnknown 

func (m *CreateDownloadLocationRequest) XXX_DiscardUnknown()

func (*CreateDownloadLocationRequest) XXX_Marshal 

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

func (*CreateDownloadLocationRequest) XXX_Merge 

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

func (*CreateDownloadLocationRequest) XXX_Size 

func (m *CreateDownloadLocationRequest) XXX_Size() int

func (*CreateDownloadLocationRequest) XXX_Unmarshal 

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

type CreateDownloadLocationResponse deprecated 

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 

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

func (*CreateDownloadLocationResponse) GetExpiresAt 

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

func (*CreateDownloadLocationResponse) GetSignedUrl 

func (m *CreateDownloadLocationResponse) GetSignedUrl() string

func (*CreateDownloadLocationResponse) ProtoMessage 

func (*CreateDownloadLocationResponse) ProtoMessage()

func (*CreateDownloadLocationResponse) Reset 

func (m *CreateDownloadLocationResponse) Reset()

func (*CreateDownloadLocationResponse) String 

func (m *CreateDownloadLocationResponse) String() string

func (*CreateDownloadLocationResponse) XXX_DiscardUnknown 

func (m *CreateDownloadLocationResponse) XXX_DiscardUnknown()

func (*CreateDownloadLocationResponse) XXX_Marshal 

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

func (*CreateDownloadLocationResponse) XXX_Merge 

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

func (*CreateDownloadLocationResponse) XXX_Size 

func (m *CreateDownloadLocationResponse) XXX_Size() int

func (*CreateDownloadLocationResponse) XXX_Unmarshal 

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

type CreateUploadLocationRequest 

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 

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

func (*CreateUploadLocationRequest) GetContentMd5 

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

func (*CreateUploadLocationRequest) GetDomain 

func (m *CreateUploadLocationRequest) GetDomain() string

func (*CreateUploadLocationRequest) GetExpiresIn 

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

func (*CreateUploadLocationRequest) GetFilename 

func (m *CreateUploadLocationRequest) GetFilename() string

func (*CreateUploadLocationRequest) GetProject 

func (m *CreateUploadLocationRequest) GetProject() string

func (*CreateUploadLocationRequest) ProtoMessage 

func (*CreateUploadLocationRequest) ProtoMessage()

func (*CreateUploadLocationRequest) Reset 

func (m *CreateUploadLocationRequest) Reset()

func (*CreateUploadLocationRequest) String 

func (m *CreateUploadLocationRequest) String() string

func (*CreateUploadLocationRequest) XXX_DiscardUnknown 

func (m *CreateUploadLocationRequest) XXX_DiscardUnknown()

func (*CreateUploadLocationRequest) XXX_Marshal 

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

func (*CreateUploadLocationRequest) XXX_Merge 

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

func (*CreateUploadLocationRequest) XXX_Size 

func (m *CreateUploadLocationRequest) XXX_Size() int

func (*CreateUploadLocationRequest) XXX_Unmarshal 

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

type CreateUploadLocationResponse 

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 

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

func (*CreateUploadLocationResponse) GetExpiresAt 

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

func (*CreateUploadLocationResponse) GetNativeUrl 

func (m *CreateUploadLocationResponse) GetNativeUrl() string

func (*CreateUploadLocationResponse) GetSignedUrl 

func (m *CreateUploadLocationResponse) GetSignedUrl() string

func (*CreateUploadLocationResponse) ProtoMessage 

func (*CreateUploadLocationResponse) ProtoMessage()

func (*CreateUploadLocationResponse) Reset 

func (m *CreateUploadLocationResponse) Reset()

func (*CreateUploadLocationResponse) String 

func (m *CreateUploadLocationResponse) String() string

func (*CreateUploadLocationResponse) XXX_DiscardUnknown 

func (m *CreateUploadLocationResponse) XXX_DiscardUnknown()

func (*CreateUploadLocationResponse) XXX_Marshal 

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

func (*CreateUploadLocationResponse) XXX_Merge 

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

func (*CreateUploadLocationResponse) XXX_Size 

func (m *CreateUploadLocationResponse) XXX_Size() int

func (*CreateUploadLocationResponse) XXX_Unmarshal 

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

type DataProxyServiceClient 

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 

func NewDataProxyServiceClient(cc *grpc.ClientConn) DataProxyServiceClient

type DataProxyServiceServer 

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 

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 

func NewExternalPluginServiceClient(cc *grpc.ClientConn) ExternalPluginServiceClient

type ExternalPluginServiceServer 

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 

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 

func NewIdentityServiceClient(cc *grpc.ClientConn) IdentityServiceClient

type IdentityServiceServer 

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 

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

func (*OAuth2MetadataRequest) Descriptor 

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

func (*OAuth2MetadataRequest) ProtoMessage 

func (*OAuth2MetadataRequest) ProtoMessage()

func (*OAuth2MetadataRequest) Reset 

func (m *OAuth2MetadataRequest) Reset()

func (*OAuth2MetadataRequest) String 

func (m *OAuth2MetadataRequest) String() string

func (*OAuth2MetadataRequest) XXX_DiscardUnknown 

func (m *OAuth2MetadataRequest) XXX_DiscardUnknown()

func (*OAuth2MetadataRequest) XXX_Marshal 

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

func (*OAuth2MetadataRequest) XXX_Merge 

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

func (*OAuth2MetadataRequest) XXX_Size 

func (m *OAuth2MetadataRequest) XXX_Size() int

func (*OAuth2MetadataRequest) XXX_Unmarshal 

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

type OAuth2MetadataResponse 

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 

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

func (*OAuth2MetadataResponse) GetAuthorizationEndpoint 

func (m *OAuth2MetadataResponse) GetAuthorizationEndpoint() string

func (*OAuth2MetadataResponse) GetCodeChallengeMethodsSupported 

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

func (*OAuth2MetadataResponse) GetDeviceAuthorizationEndpoint 

func (m *OAuth2MetadataResponse) GetDeviceAuthorizationEndpoint() string

func (*OAuth2MetadataResponse) GetGrantTypesSupported 

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

func (*OAuth2MetadataResponse) GetIssuer 

func (m *OAuth2MetadataResponse) GetIssuer() string

func (*OAuth2MetadataResponse) GetJwksUri 

func (m *OAuth2MetadataResponse) GetJwksUri() string

func (*OAuth2MetadataResponse) GetResponseTypesSupported 

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

func (*OAuth2MetadataResponse) GetScopesSupported 

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

func (*OAuth2MetadataResponse) GetTokenEndpoint 

func (m *OAuth2MetadataResponse) GetTokenEndpoint() string

func (*OAuth2MetadataResponse) GetTokenEndpointAuthMethodsSupported 

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

func (*OAuth2MetadataResponse) ProtoMessage 

func (*OAuth2MetadataResponse) ProtoMessage()

func (*OAuth2MetadataResponse) Reset 

func (m *OAuth2MetadataResponse) Reset()

func (*OAuth2MetadataResponse) String 

func (m *OAuth2MetadataResponse) String() string

func (*OAuth2MetadataResponse) XXX_DiscardUnknown 

func (m *OAuth2MetadataResponse) XXX_DiscardUnknown()

func (*OAuth2MetadataResponse) XXX_Marshal 

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

func (*OAuth2MetadataResponse) XXX_Merge 

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

func (*OAuth2MetadataResponse) XXX_Size 

func (m *OAuth2MetadataResponse) XXX_Size() int

func (*OAuth2MetadataResponse) XXX_Unmarshal 

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

type PublicClientAuthConfigRequest 

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

func (*PublicClientAuthConfigRequest) Descriptor 

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

func (*PublicClientAuthConfigRequest) ProtoMessage 

func (*PublicClientAuthConfigRequest) ProtoMessage()

func (*PublicClientAuthConfigRequest) Reset 

func (m *PublicClientAuthConfigRequest) Reset()

func (*PublicClientAuthConfigRequest) String 

func (m *PublicClientAuthConfigRequest) String() string

func (*PublicClientAuthConfigRequest) XXX_DiscardUnknown 

func (m *PublicClientAuthConfigRequest) XXX_DiscardUnknown()

func (*PublicClientAuthConfigRequest) XXX_Marshal 

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

func (*PublicClientAuthConfigRequest) XXX_Merge 

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

func (*PublicClientAuthConfigRequest) XXX_Size 

func (m *PublicClientAuthConfigRequest) XXX_Size() int

func (*PublicClientAuthConfigRequest) XXX_Unmarshal 

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

type PublicClientAuthConfigResponse 

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 

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

func (*PublicClientAuthConfigResponse) GetAudience 

func (m *PublicClientAuthConfigResponse) GetAudience() string

func (*PublicClientAuthConfigResponse) GetAuthorizationMetadataKey 

func (m *PublicClientAuthConfigResponse) GetAuthorizationMetadataKey() string

func (*PublicClientAuthConfigResponse) GetClientId 

func (m *PublicClientAuthConfigResponse) GetClientId() string

func (*PublicClientAuthConfigResponse) GetRedirectUri 

func (m *PublicClientAuthConfigResponse) GetRedirectUri() string

func (*PublicClientAuthConfigResponse) GetScopes 

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

func (*PublicClientAuthConfigResponse) GetServiceHttpEndpoint 

func (m *PublicClientAuthConfigResponse) GetServiceHttpEndpoint() string

func (*PublicClientAuthConfigResponse) ProtoMessage 

func (*PublicClientAuthConfigResponse) ProtoMessage()

func (*PublicClientAuthConfigResponse) Reset 

func (m *PublicClientAuthConfigResponse) Reset()

func (*PublicClientAuthConfigResponse) String 

func (m *PublicClientAuthConfigResponse) String() string

func (*PublicClientAuthConfigResponse) XXX_DiscardUnknown 

func (m *PublicClientAuthConfigResponse) XXX_DiscardUnknown()

func (*PublicClientAuthConfigResponse) XXX_Marshal 

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

func (*PublicClientAuthConfigResponse) XXX_Merge 

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

func (*PublicClientAuthConfigResponse) XXX_Size 

func (m *PublicClientAuthConfigResponse) XXX_Size() int

func (*PublicClientAuthConfigResponse) XXX_Unmarshal 

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

type SignalServiceClient 

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 

func NewSignalServiceClient(cc *grpc.ClientConn) SignalServiceClient

type SignalServiceServer 

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 

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 

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

func (State) String 

func (x State) String() string

type TaskCreateRequest 

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 

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

func (*TaskCreateRequest) GetInputs 

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

func (*TaskCreateRequest) GetOutputPrefix 

func (m *TaskCreateRequest) GetOutputPrefix() string

func (*TaskCreateRequest) GetTemplate 

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

func (*TaskCreateRequest) ProtoMessage 

func (*TaskCreateRequest) ProtoMessage()

func (*TaskCreateRequest) Reset 

func (m *TaskCreateRequest) Reset()

func (*TaskCreateRequest) String 

func (m *TaskCreateRequest) String() string

func (*TaskCreateRequest) XXX_DiscardUnknown 

func (m *TaskCreateRequest) XXX_DiscardUnknown()

func (*TaskCreateRequest) XXX_Marshal 

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

func (*TaskCreateRequest) XXX_Merge 

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

func (*TaskCreateRequest) XXX_Size 

func (m *TaskCreateRequest) XXX_Size() int

func (*TaskCreateRequest) XXX_Unmarshal 

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

type TaskCreateResponse 

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 

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

func (*TaskCreateResponse) GetJobId 

func (m *TaskCreateResponse) GetJobId() string

func (*TaskCreateResponse) ProtoMessage 

func (*TaskCreateResponse) ProtoMessage()

func (*TaskCreateResponse) Reset 

func (m *TaskCreateResponse) Reset()

func (*TaskCreateResponse) String 

func (m *TaskCreateResponse) String() string

func (*TaskCreateResponse) XXX_DiscardUnknown 

func (m *TaskCreateResponse) XXX_DiscardUnknown()

func (*TaskCreateResponse) XXX_Marshal 

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

func (*TaskCreateResponse) XXX_Merge 

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

func (*TaskCreateResponse) XXX_Size 

func (m *TaskCreateResponse) XXX_Size() int

func (*TaskCreateResponse) XXX_Unmarshal 

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

type TaskDeleteRequest 

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 

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

func (*TaskDeleteRequest) GetJobId 

func (m *TaskDeleteRequest) GetJobId() string

func (*TaskDeleteRequest) GetTaskType 

func (m *TaskDeleteRequest) GetTaskType() string

func (*TaskDeleteRequest) ProtoMessage 

func (*TaskDeleteRequest) ProtoMessage()

func (*TaskDeleteRequest) Reset 

func (m *TaskDeleteRequest) Reset()

func (*TaskDeleteRequest) String 

func (m *TaskDeleteRequest) String() string

func (*TaskDeleteRequest) XXX_DiscardUnknown 

func (m *TaskDeleteRequest) XXX_DiscardUnknown()

func (*TaskDeleteRequest) XXX_Marshal 

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

func (*TaskDeleteRequest) XXX_Merge 

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

func (*TaskDeleteRequest) XXX_Size 

func (m *TaskDeleteRequest) XXX_Size() int

func (*TaskDeleteRequest) XXX_Unmarshal 

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

type TaskDeleteResponse 

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

Response to delete a task.

func (*TaskDeleteResponse) Descriptor 

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

func (*TaskDeleteResponse) ProtoMessage 

func (*TaskDeleteResponse) ProtoMessage()

func (*TaskDeleteResponse) Reset 

func (m *TaskDeleteResponse) Reset()

func (*TaskDeleteResponse) String 

func (m *TaskDeleteResponse) String() string

func (*TaskDeleteResponse) XXX_DiscardUnknown 

func (m *TaskDeleteResponse) XXX_DiscardUnknown()

func (*TaskDeleteResponse) XXX_Marshal 

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

func (*TaskDeleteResponse) XXX_Merge 

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

func (*TaskDeleteResponse) XXX_Size 

func (m *TaskDeleteResponse) XXX_Size() int

func (*TaskDeleteResponse) XXX_Unmarshal 

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

type TaskGetRequest 

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 

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

func (*TaskGetRequest) GetJobId 

func (m *TaskGetRequest) GetJobId() string

func (*TaskGetRequest) GetTaskType 

func (m *TaskGetRequest) GetTaskType() string

func (*TaskGetRequest) ProtoMessage 

func (*TaskGetRequest) ProtoMessage()

func (*TaskGetRequest) Reset 

func (m *TaskGetRequest) Reset()

func (*TaskGetRequest) String 

func (m *TaskGetRequest) String() string

func (*TaskGetRequest) XXX_DiscardUnknown 

func (m *TaskGetRequest) XXX_DiscardUnknown()

func (*TaskGetRequest) XXX_Marshal 

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

func (*TaskGetRequest) XXX_Merge 

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

func (*TaskGetRequest) XXX_Size 

func (m *TaskGetRequest) XXX_Size() int

func (*TaskGetRequest) XXX_Unmarshal 

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

type TaskGetResponse 

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 

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

func (*TaskGetResponse) GetOutputs 

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

func (*TaskGetResponse) GetState 

func (m *TaskGetResponse) GetState() State

func (*TaskGetResponse) ProtoMessage 

func (*TaskGetResponse) ProtoMessage()

func (*TaskGetResponse) Reset 

func (m *TaskGetResponse) Reset()

func (*TaskGetResponse) String 

func (m *TaskGetResponse) String() string

func (*TaskGetResponse) XXX_DiscardUnknown 

func (m *TaskGetResponse) XXX_DiscardUnknown()

func (*TaskGetResponse) XXX_Marshal 

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

func (*TaskGetResponse) XXX_Merge 

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

func (*TaskGetResponse) XXX_Size 

func (m *TaskGetResponse) XXX_Size() int

func (*TaskGetResponse) XXX_Unmarshal 

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

type UnimplementedAdminServiceServer 

type UnimplementedAdminServiceServer struct {
}

UnimplementedAdminServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdminServiceServer) CreateExecution 

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

func (*UnimplementedAdminServiceServer) CreateLaunchPlan 

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

func (*UnimplementedAdminServiceServer) CreateNodeEvent 

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

func (*UnimplementedAdminServiceServer) CreateTask 

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

func (*UnimplementedAdminServiceServer) CreateTaskEvent 

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

func (*UnimplementedAdminServiceServer) CreateWorkflow 

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

func (*UnimplementedAdminServiceServer) CreateWorkflowEvent 

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

func (*UnimplementedAdminServiceServer) DeleteProjectAttributes 

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

func (*UnimplementedAdminServiceServer) DeleteProjectDomainAttributes 

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

func (*UnimplementedAdminServiceServer) DeleteWorkflowAttributes 

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

func (*UnimplementedAdminServiceServer) GetActiveLaunchPlan 

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

func (*UnimplementedAdminServiceServer) GetDescriptionEntity 

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

func (*UnimplementedAdminServiceServer) GetExecution 

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

func (*UnimplementedAdminServiceServer) GetExecutionData 

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

func (*UnimplementedAdminServiceServer) GetExecutionMetrics 

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

func (*UnimplementedAdminServiceServer) GetLaunchPlan 

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

func (*UnimplementedAdminServiceServer) GetNamedEntity 

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

func (*UnimplementedAdminServiceServer) GetNodeExecution 

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

func (*UnimplementedAdminServiceServer) GetNodeExecutionData 

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

func (*UnimplementedAdminServiceServer) GetProjectAttributes 

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

func (*UnimplementedAdminServiceServer) GetProjectDomainAttributes 

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

func (*UnimplementedAdminServiceServer) GetTask 

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

func (*UnimplementedAdminServiceServer) GetTaskExecution 

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

func (*UnimplementedAdminServiceServer) GetTaskExecutionData 

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

func (*UnimplementedAdminServiceServer) GetVersion 

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

func (*UnimplementedAdminServiceServer) GetWorkflow 

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

func (*UnimplementedAdminServiceServer) GetWorkflowAttributes 

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

func (*UnimplementedAdminServiceServer) ListActiveLaunchPlans 

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

func (*UnimplementedAdminServiceServer) ListDescriptionEntities 

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

func (*UnimplementedAdminServiceServer) ListExecutions 

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

func (*UnimplementedAdminServiceServer) ListLaunchPlanIds 

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

func (*UnimplementedAdminServiceServer) ListLaunchPlans 

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

func (*UnimplementedAdminServiceServer) ListMatchableAttributes 

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

func (*UnimplementedAdminServiceServer) ListNamedEntities 

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

func (*UnimplementedAdminServiceServer) ListNodeExecutions 

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

func (*UnimplementedAdminServiceServer) ListNodeExecutionsForTask 

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

func (*UnimplementedAdminServiceServer) ListProjects 

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

func (*UnimplementedAdminServiceServer) ListTaskExecutions 

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

func (*UnimplementedAdminServiceServer) ListTaskIds 

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

func (*UnimplementedAdminServiceServer) ListTasks 

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

func (*UnimplementedAdminServiceServer) ListWorkflowIds 

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

func (*UnimplementedAdminServiceServer) ListWorkflows 

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

func (*UnimplementedAdminServiceServer) RecoverExecution 

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

func (*UnimplementedAdminServiceServer) RegisterProject 

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

func (*UnimplementedAdminServiceServer) RelaunchExecution 

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

func (*UnimplementedAdminServiceServer) TerminateExecution 

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

func (*UnimplementedAdminServiceServer) UpdateExecution 

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

func (*UnimplementedAdminServiceServer) UpdateLaunchPlan 

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

func (*UnimplementedAdminServiceServer) UpdateNamedEntity 

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

func (*UnimplementedAdminServiceServer) UpdateProject 

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

func (*UnimplementedAdminServiceServer) UpdateProjectAttributes 

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

func (*UnimplementedAdminServiceServer) UpdateProjectDomainAttributes 

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

func (*UnimplementedAdminServiceServer) UpdateWorkflowAttributes 

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

type UnimplementedAuthMetadataServiceServer 

type UnimplementedAuthMetadataServiceServer struct {
}

UnimplementedAuthMetadataServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAuthMetadataServiceServer) GetOAuth2Metadata 

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

func (*UnimplementedAuthMetadataServiceServer) GetPublicClientConfig 

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

type UnimplementedDataProxyServiceServer 

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 

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

func (*UnimplementedDataProxyServiceServer) CreateUploadLocation 

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

type UnimplementedExternalPluginServiceServer 

type UnimplementedExternalPluginServiceServer struct {
}

UnimplementedExternalPluginServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedExternalPluginServiceServer) CreateTask 

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

func (*UnimplementedExternalPluginServiceServer) DeleteTask 

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

func (*UnimplementedExternalPluginServiceServer) GetTask 

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

type UnimplementedIdentityServiceServer 

type UnimplementedIdentityServiceServer struct {
}

UnimplementedIdentityServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIdentityServiceServer) UserInfo 

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

type UnimplementedSignalServiceServer 

type UnimplementedSignalServiceServer struct {
}

UnimplementedSignalServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSignalServiceServer) GetOrCreateSignal 

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

func (*UnimplementedSignalServiceServer) ListSignals 

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

func (*UnimplementedSignalServiceServer) SetSignal 

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

type UserInfoRequest 

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

func (*UserInfoRequest) Descriptor 

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

func (*UserInfoRequest) ProtoMessage 

func (*UserInfoRequest) ProtoMessage()

func (*UserInfoRequest) Reset 

func (m *UserInfoRequest) Reset()

func (*UserInfoRequest) String 

func (m *UserInfoRequest) String() string

func (*UserInfoRequest) XXX_DiscardUnknown 

func (m *UserInfoRequest) XXX_DiscardUnknown()

func (*UserInfoRequest) XXX_Marshal 

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

func (*UserInfoRequest) XXX_Merge 

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

func (*UserInfoRequest) XXX_Size 

func (m *UserInfoRequest) XXX_Size() int

func (*UserInfoRequest) XXX_Unmarshal 

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

type UserInfoResponse 

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 

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

func (*UserInfoResponse) GetAdditionalClaims 

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

func (*UserInfoResponse) GetEmail 

func (m *UserInfoResponse) GetEmail() string

func (*UserInfoResponse) GetFamilyName 

func (m *UserInfoResponse) GetFamilyName() string

func (*UserInfoResponse) GetGivenName 

func (m *UserInfoResponse) GetGivenName() string

func (*UserInfoResponse) GetName 

func (m *UserInfoResponse) GetName() string

func (*UserInfoResponse) GetPicture 

func (m *UserInfoResponse) GetPicture() string

func (*UserInfoResponse) GetPreferredUsername 

func (m *UserInfoResponse) GetPreferredUsername() string

func (*UserInfoResponse) GetSubject 

func (m *UserInfoResponse) GetSubject() string

func (*UserInfoResponse) ProtoMessage 

func (*UserInfoResponse) ProtoMessage()

func (*UserInfoResponse) Reset 

func (m *UserInfoResponse) Reset()

func (*UserInfoResponse) String 

func (m *UserInfoResponse) String() string

func (*UserInfoResponse) XXX_DiscardUnknown 

func (m *UserInfoResponse) XXX_DiscardUnknown()

func (*UserInfoResponse) XXX_Marshal 

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

func (*UserInfoResponse) XXX_Merge 

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

func (*UserInfoResponse) XXX_Size 

func (m *UserInfoResponse) XXX_Size() int

func (*UserInfoResponse) XXX_Unmarshal 

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.