service

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2024 License: Apache-2.0 Imports: 15 Imported by: 29

Documentation

Index

Constants

View Source 
const (
	AdminService_CreateTask_FullMethodName                    = "/flyteidl.service.AdminService/CreateTask"
	AdminService_GetTask_FullMethodName                       = "/flyteidl.service.AdminService/GetTask"
	AdminService_ListTaskIds_FullMethodName                   = "/flyteidl.service.AdminService/ListTaskIds"
	AdminService_ListTasks_FullMethodName                     = "/flyteidl.service.AdminService/ListTasks"
	AdminService_CreateWorkflow_FullMethodName                = "/flyteidl.service.AdminService/CreateWorkflow"
	AdminService_GetWorkflow_FullMethodName                   = "/flyteidl.service.AdminService/GetWorkflow"
	AdminService_ListWorkflowIds_FullMethodName               = "/flyteidl.service.AdminService/ListWorkflowIds"
	AdminService_ListWorkflows_FullMethodName                 = "/flyteidl.service.AdminService/ListWorkflows"
	AdminService_CreateLaunchPlan_FullMethodName              = "/flyteidl.service.AdminService/CreateLaunchPlan"
	AdminService_GetLaunchPlan_FullMethodName                 = "/flyteidl.service.AdminService/GetLaunchPlan"
	AdminService_GetActiveLaunchPlan_FullMethodName           = "/flyteidl.service.AdminService/GetActiveLaunchPlan"
	AdminService_ListActiveLaunchPlans_FullMethodName         = "/flyteidl.service.AdminService/ListActiveLaunchPlans"
	AdminService_ListLaunchPlanIds_FullMethodName             = "/flyteidl.service.AdminService/ListLaunchPlanIds"
	AdminService_ListLaunchPlans_FullMethodName               = "/flyteidl.service.AdminService/ListLaunchPlans"
	AdminService_UpdateLaunchPlan_FullMethodName              = "/flyteidl.service.AdminService/UpdateLaunchPlan"
	AdminService_CreateExecution_FullMethodName               = "/flyteidl.service.AdminService/CreateExecution"
	AdminService_RelaunchExecution_FullMethodName             = "/flyteidl.service.AdminService/RelaunchExecution"
	AdminService_RecoverExecution_FullMethodName              = "/flyteidl.service.AdminService/RecoverExecution"
	AdminService_GetExecution_FullMethodName                  = "/flyteidl.service.AdminService/GetExecution"
	AdminService_UpdateExecution_FullMethodName               = "/flyteidl.service.AdminService/UpdateExecution"
	AdminService_GetExecutionData_FullMethodName              = "/flyteidl.service.AdminService/GetExecutionData"
	AdminService_ListExecutions_FullMethodName                = "/flyteidl.service.AdminService/ListExecutions"
	AdminService_TerminateExecution_FullMethodName            = "/flyteidl.service.AdminService/TerminateExecution"
	AdminService_GetNodeExecution_FullMethodName              = "/flyteidl.service.AdminService/GetNodeExecution"
	AdminService_GetDynamicNodeWorkflow_FullMethodName        = "/flyteidl.service.AdminService/GetDynamicNodeWorkflow"
	AdminService_ListNodeExecutions_FullMethodName            = "/flyteidl.service.AdminService/ListNodeExecutions"
	AdminService_ListNodeExecutionsForTask_FullMethodName     = "/flyteidl.service.AdminService/ListNodeExecutionsForTask"
	AdminService_GetNodeExecutionData_FullMethodName          = "/flyteidl.service.AdminService/GetNodeExecutionData"
	AdminService_RegisterProject_FullMethodName               = "/flyteidl.service.AdminService/RegisterProject"
	AdminService_UpdateProject_FullMethodName                 = "/flyteidl.service.AdminService/UpdateProject"
	AdminService_ListProjects_FullMethodName                  = "/flyteidl.service.AdminService/ListProjects"
	AdminService_CreateWorkflowEvent_FullMethodName           = "/flyteidl.service.AdminService/CreateWorkflowEvent"
	AdminService_CreateNodeEvent_FullMethodName               = "/flyteidl.service.AdminService/CreateNodeEvent"
	AdminService_CreateTaskEvent_FullMethodName               = "/flyteidl.service.AdminService/CreateTaskEvent"
	AdminService_GetTaskExecution_FullMethodName              = "/flyteidl.service.AdminService/GetTaskExecution"
	AdminService_ListTaskExecutions_FullMethodName            = "/flyteidl.service.AdminService/ListTaskExecutions"
	AdminService_GetTaskExecutionData_FullMethodName          = "/flyteidl.service.AdminService/GetTaskExecutionData"
	AdminService_UpdateProjectDomainAttributes_FullMethodName = "/flyteidl.service.AdminService/UpdateProjectDomainAttributes"
	AdminService_GetProjectDomainAttributes_FullMethodName    = "/flyteidl.service.AdminService/GetProjectDomainAttributes"
	AdminService_DeleteProjectDomainAttributes_FullMethodName = "/flyteidl.service.AdminService/DeleteProjectDomainAttributes"
	AdminService_UpdateProjectAttributes_FullMethodName       = "/flyteidl.service.AdminService/UpdateProjectAttributes"
	AdminService_GetProjectAttributes_FullMethodName          = "/flyteidl.service.AdminService/GetProjectAttributes"
	AdminService_DeleteProjectAttributes_FullMethodName       = "/flyteidl.service.AdminService/DeleteProjectAttributes"
	AdminService_UpdateWorkflowAttributes_FullMethodName      = "/flyteidl.service.AdminService/UpdateWorkflowAttributes"
	AdminService_GetWorkflowAttributes_FullMethodName         = "/flyteidl.service.AdminService/GetWorkflowAttributes"
	AdminService_DeleteWorkflowAttributes_FullMethodName      = "/flyteidl.service.AdminService/DeleteWorkflowAttributes"
	AdminService_ListMatchableAttributes_FullMethodName       = "/flyteidl.service.AdminService/ListMatchableAttributes"
	AdminService_ListNamedEntities_FullMethodName             = "/flyteidl.service.AdminService/ListNamedEntities"
	AdminService_GetNamedEntity_FullMethodName                = "/flyteidl.service.AdminService/GetNamedEntity"
	AdminService_UpdateNamedEntity_FullMethodName             = "/flyteidl.service.AdminService/UpdateNamedEntity"
	AdminService_GetVersion_FullMethodName                    = "/flyteidl.service.AdminService/GetVersion"
	AdminService_GetDescriptionEntity_FullMethodName          = "/flyteidl.service.AdminService/GetDescriptionEntity"
	AdminService_ListDescriptionEntities_FullMethodName       = "/flyteidl.service.AdminService/ListDescriptionEntities"
	AdminService_GetExecutionMetrics_FullMethodName           = "/flyteidl.service.AdminService/GetExecutionMetrics"
)
View Source 
const (
	AsyncAgentService_CreateTask_FullMethodName     = "/flyteidl.service.AsyncAgentService/CreateTask"
	AsyncAgentService_GetTask_FullMethodName        = "/flyteidl.service.AsyncAgentService/GetTask"
	AsyncAgentService_DeleteTask_FullMethodName     = "/flyteidl.service.AsyncAgentService/DeleteTask"
	AsyncAgentService_GetTaskMetrics_FullMethodName = "/flyteidl.service.AsyncAgentService/GetTaskMetrics"
	AsyncAgentService_GetTaskLogs_FullMethodName    = "/flyteidl.service.AsyncAgentService/GetTaskLogs"
)
View Source 
const (
	AgentMetadataService_GetAgent_FullMethodName   = "/flyteidl.service.AgentMetadataService/GetAgent"
	AgentMetadataService_ListAgents_FullMethodName = "/flyteidl.service.AgentMetadataService/ListAgents"
)
View Source 
const (
	AuthMetadataService_GetOAuth2Metadata_FullMethodName     = "/flyteidl.service.AuthMetadataService/GetOAuth2Metadata"
	AuthMetadataService_GetPublicClientConfig_FullMethodName = "/flyteidl.service.AuthMetadataService/GetPublicClientConfig"
)
View Source 
const (
	DataProxyService_CreateUploadLocation_FullMethodName   = "/flyteidl.service.DataProxyService/CreateUploadLocation"
	DataProxyService_CreateDownloadLocation_FullMethodName = "/flyteidl.service.DataProxyService/CreateDownloadLocation"
	DataProxyService_CreateDownloadLink_FullMethodName     = "/flyteidl.service.DataProxyService/CreateDownloadLink"
	DataProxyService_GetData_FullMethodName                = "/flyteidl.service.DataProxyService/GetData"
)
View Source 
const (
	ExternalPluginService_CreateTask_FullMethodName = "/flyteidl.service.ExternalPluginService/CreateTask"
	ExternalPluginService_GetTask_FullMethodName    = "/flyteidl.service.ExternalPluginService/GetTask"
	ExternalPluginService_DeleteTask_FullMethodName = "/flyteidl.service.ExternalPluginService/DeleteTask"
)
View Source 
const (
	SignalService_GetOrCreateSignal_FullMethodName = "/flyteidl.service.SignalService/GetOrCreateSignal"
	SignalService_ListSignals_FullMethodName       = "/flyteidl.service.SignalService/ListSignals"
	SignalService_SetSignal_FullMethodName         = "/flyteidl.service.SignalService/SetSignal"
)
View Source 
const (
	IdentityService_UserInfo_FullMethodName = "/flyteidl.service.IdentityService/UserInfo"
)
View Source 
const (
	SyncAgentService_ExecuteTaskSync_FullMethodName = "/flyteidl.service.SyncAgentService/ExecuteTaskSync"
)

Variables

View Source 
var (
	ArtifactType_name = map[int32]string{
		0: "ARTIFACT_TYPE_UNDEFINED",
		1: "ARTIFACT_TYPE_DECK",
	}
	ArtifactType_value = map[string]int32{
		"ARTIFACT_TYPE_UNDEFINED": 0,
		"ARTIFACT_TYPE_DECK":      1,
	}
)

Enum value maps for ArtifactType.

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

Enum value maps for State.

View Source 
var AdminService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.service.AdminService",
	HandlerType: (*AdminServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateTask",
			Handler:    _AdminService_CreateTask_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _AdminService_GetTask_Handler,
		},
		{
			MethodName: "ListTaskIds",
			Handler:    _AdminService_ListTaskIds_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _AdminService_ListTasks_Handler,
		},
		{
			MethodName: "CreateWorkflow",
			Handler:    _AdminService_CreateWorkflow_Handler,
		},
		{
			MethodName: "GetWorkflow",
			Handler:    _AdminService_GetWorkflow_Handler,
		},
		{
			MethodName: "ListWorkflowIds",
			Handler:    _AdminService_ListWorkflowIds_Handler,
		},
		{
			MethodName: "ListWorkflows",
			Handler:    _AdminService_ListWorkflows_Handler,
		},
		{
			MethodName: "CreateLaunchPlan",
			Handler:    _AdminService_CreateLaunchPlan_Handler,
		},
		{
			MethodName: "GetLaunchPlan",
			Handler:    _AdminService_GetLaunchPlan_Handler,
		},
		{
			MethodName: "GetActiveLaunchPlan",
			Handler:    _AdminService_GetActiveLaunchPlan_Handler,
		},
		{
			MethodName: "ListActiveLaunchPlans",
			Handler:    _AdminService_ListActiveLaunchPlans_Handler,
		},
		{
			MethodName: "ListLaunchPlanIds",
			Handler:    _AdminService_ListLaunchPlanIds_Handler,
		},
		{
			MethodName: "ListLaunchPlans",
			Handler:    _AdminService_ListLaunchPlans_Handler,
		},
		{
			MethodName: "UpdateLaunchPlan",
			Handler:    _AdminService_UpdateLaunchPlan_Handler,
		},
		{
			MethodName: "CreateExecution",
			Handler:    _AdminService_CreateExecution_Handler,
		},
		{
			MethodName: "RelaunchExecution",
			Handler:    _AdminService_RelaunchExecution_Handler,
		},
		{
			MethodName: "RecoverExecution",
			Handler:    _AdminService_RecoverExecution_Handler,
		},
		{
			MethodName: "GetExecution",
			Handler:    _AdminService_GetExecution_Handler,
		},
		{
			MethodName: "UpdateExecution",
			Handler:    _AdminService_UpdateExecution_Handler,
		},
		{
			MethodName: "GetExecutionData",
			Handler:    _AdminService_GetExecutionData_Handler,
		},
		{
			MethodName: "ListExecutions",
			Handler:    _AdminService_ListExecutions_Handler,
		},
		{
			MethodName: "TerminateExecution",
			Handler:    _AdminService_TerminateExecution_Handler,
		},
		{
			MethodName: "GetNodeExecution",
			Handler:    _AdminService_GetNodeExecution_Handler,
		},
		{
			MethodName: "GetDynamicNodeWorkflow",
			Handler:    _AdminService_GetDynamicNodeWorkflow_Handler,
		},
		{
			MethodName: "ListNodeExecutions",
			Handler:    _AdminService_ListNodeExecutions_Handler,
		},
		{
			MethodName: "ListNodeExecutionsForTask",
			Handler:    _AdminService_ListNodeExecutionsForTask_Handler,
		},
		{
			MethodName: "GetNodeExecutionData",
			Handler:    _AdminService_GetNodeExecutionData_Handler,
		},
		{
			MethodName: "RegisterProject",
			Handler:    _AdminService_RegisterProject_Handler,
		},
		{
			MethodName: "UpdateProject",
			Handler:    _AdminService_UpdateProject_Handler,
		},
		{
			MethodName: "ListProjects",
			Handler:    _AdminService_ListProjects_Handler,
		},
		{
			MethodName: "CreateWorkflowEvent",
			Handler:    _AdminService_CreateWorkflowEvent_Handler,
		},
		{
			MethodName: "CreateNodeEvent",
			Handler:    _AdminService_CreateNodeEvent_Handler,
		},
		{
			MethodName: "CreateTaskEvent",
			Handler:    _AdminService_CreateTaskEvent_Handler,
		},
		{
			MethodName: "GetTaskExecution",
			Handler:    _AdminService_GetTaskExecution_Handler,
		},
		{
			MethodName: "ListTaskExecutions",
			Handler:    _AdminService_ListTaskExecutions_Handler,
		},
		{
			MethodName: "GetTaskExecutionData",
			Handler:    _AdminService_GetTaskExecutionData_Handler,
		},
		{
			MethodName: "UpdateProjectDomainAttributes",
			Handler:    _AdminService_UpdateProjectDomainAttributes_Handler,
		},
		{
			MethodName: "GetProjectDomainAttributes",
			Handler:    _AdminService_GetProjectDomainAttributes_Handler,
		},
		{
			MethodName: "DeleteProjectDomainAttributes",
			Handler:    _AdminService_DeleteProjectDomainAttributes_Handler,
		},
		{
			MethodName: "UpdateProjectAttributes",
			Handler:    _AdminService_UpdateProjectAttributes_Handler,
		},
		{
			MethodName: "GetProjectAttributes",
			Handler:    _AdminService_GetProjectAttributes_Handler,
		},
		{
			MethodName: "DeleteProjectAttributes",
			Handler:    _AdminService_DeleteProjectAttributes_Handler,
		},
		{
			MethodName: "UpdateWorkflowAttributes",
			Handler:    _AdminService_UpdateWorkflowAttributes_Handler,
		},
		{
			MethodName: "GetWorkflowAttributes",
			Handler:    _AdminService_GetWorkflowAttributes_Handler,
		},
		{
			MethodName: "DeleteWorkflowAttributes",
			Handler:    _AdminService_DeleteWorkflowAttributes_Handler,
		},
		{
			MethodName: "ListMatchableAttributes",
			Handler:    _AdminService_ListMatchableAttributes_Handler,
		},
		{
			MethodName: "ListNamedEntities",
			Handler:    _AdminService_ListNamedEntities_Handler,
		},
		{
			MethodName: "GetNamedEntity",
			Handler:    _AdminService_GetNamedEntity_Handler,
		},
		{
			MethodName: "UpdateNamedEntity",
			Handler:    _AdminService_UpdateNamedEntity_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _AdminService_GetVersion_Handler,
		},
		{
			MethodName: "GetDescriptionEntity",
			Handler:    _AdminService_GetDescriptionEntity_Handler,
		},
		{
			MethodName: "ListDescriptionEntities",
			Handler:    _AdminService_ListDescriptionEntities_Handler,
		},
		{
			MethodName: "GetExecutionMetrics",
			Handler:    _AdminService_GetExecutionMetrics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "flyteidl/service/admin.proto",
}

AdminService_ServiceDesc is the grpc.ServiceDesc for AdminService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var AgentMetadataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.service.AgentMetadataService",
	HandlerType: (*AgentMetadataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAgent",
			Handler:    _AgentMetadataService_GetAgent_Handler,
		},
		{
			MethodName: "ListAgents",
			Handler:    _AgentMetadataService_ListAgents_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "flyteidl/service/agent.proto",
}

AgentMetadataService_ServiceDesc is the grpc.ServiceDesc for AgentMetadataService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var AsyncAgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.service.AsyncAgentService",
	HandlerType: (*AsyncAgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateTask",
			Handler:    _AsyncAgentService_CreateTask_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _AsyncAgentService_GetTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _AsyncAgentService_DeleteTask_Handler,
		},
		{
			MethodName: "GetTaskMetrics",
			Handler:    _AsyncAgentService_GetTaskMetrics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetTaskLogs",
			Handler:       _AsyncAgentService_GetTaskLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "flyteidl/service/agent.proto",
}

AsyncAgentService_ServiceDesc is the grpc.ServiceDesc for AsyncAgentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var AuthMetadataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.service.AuthMetadataService",
	HandlerType: (*AuthMetadataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOAuth2Metadata",
			Handler:    _AuthMetadataService_GetOAuth2Metadata_Handler,
		},
		{
			MethodName: "GetPublicClientConfig",
			Handler:    _AuthMetadataService_GetPublicClientConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "flyteidl/service/auth.proto",
}

AuthMetadataService_ServiceDesc is the grpc.ServiceDesc for AuthMetadataService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DataProxyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.service.DataProxyService",
	HandlerType: (*DataProxyServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateUploadLocation",
			Handler:    _DataProxyService_CreateUploadLocation_Handler,
		},
		{
			MethodName: "CreateDownloadLocation",
			Handler:    _DataProxyService_CreateDownloadLocation_Handler,
		},
		{
			MethodName: "CreateDownloadLink",
			Handler:    _DataProxyService_CreateDownloadLink_Handler,
		},
		{
			MethodName: "GetData",
			Handler:    _DataProxyService_GetData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "flyteidl/service/dataproxy.proto",
}

DataProxyService_ServiceDesc is the grpc.ServiceDesc for DataProxyService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ExternalPluginService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.service.ExternalPluginService",
	HandlerType: (*ExternalPluginServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateTask",
			Handler:    _ExternalPluginService_CreateTask_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _ExternalPluginService_GetTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _ExternalPluginService_DeleteTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "flyteidl/service/external_plugin_service.proto",
}

ExternalPluginService_ServiceDesc is the grpc.ServiceDesc for ExternalPluginService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_flyteidl_service_admin_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_service_agent_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_service_auth_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_service_dataproxy_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_service_external_plugin_service_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_service_identity_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_service_signal_proto protoreflect.FileDescriptor
View Source 
var IdentityService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.service.IdentityService",
	HandlerType: (*IdentityServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UserInfo",
			Handler:    _IdentityService_UserInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "flyteidl/service/identity.proto",
}

IdentityService_ServiceDesc is the grpc.ServiceDesc for IdentityService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var SignalService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.service.SignalService",
	HandlerType: (*SignalServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOrCreateSignal",
			Handler:    _SignalService_GetOrCreateSignal_Handler,
		},
		{
			MethodName: "ListSignals",
			Handler:    _SignalService_ListSignals_Handler,
		},
		{
			MethodName: "SetSignal",
			Handler:    _SignalService_SetSignal_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "flyteidl/service/signal.proto",
}

SignalService_ServiceDesc is the grpc.ServiceDesc for SignalService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var SyncAgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl.service.SyncAgentService",
	HandlerType: (*SyncAgentServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteTaskSync",
			Handler:       _SyncAgentService_ExecuteTaskSync_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "flyteidl/service/agent.proto",
}

SyncAgentService_ServiceDesc is the grpc.ServiceDesc for SyncAgentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAdminServiceServer 

func RegisterAdminServiceServer(s grpc.ServiceRegistrar, srv AdminServiceServer)

func RegisterAgentMetadataServiceServer added in v1.10.7 

func RegisterAgentMetadataServiceServer(s grpc.ServiceRegistrar, srv AgentMetadataServiceServer)

func RegisterAsyncAgentServiceServer 

func RegisterAsyncAgentServiceServer(s grpc.ServiceRegistrar, srv AsyncAgentServiceServer)

func RegisterAuthMetadataServiceServer 

func RegisterAuthMetadataServiceServer(s grpc.ServiceRegistrar, srv AuthMetadataServiceServer)

func RegisterDataProxyServiceServer 

func RegisterDataProxyServiceServer(s grpc.ServiceRegistrar, srv DataProxyServiceServer)

func RegisterExternalPluginServiceServer 

func RegisterExternalPluginServiceServer(s grpc.ServiceRegistrar, srv ExternalPluginServiceServer)

func RegisterIdentityServiceServer 

func RegisterIdentityServiceServer(s grpc.ServiceRegistrar, srv IdentityServiceServer)

func RegisterSignalServiceServer 

func RegisterSignalServiceServer(s grpc.ServiceRegistrar, srv SignalServiceServer)

func RegisterSyncAgentServiceServer added in v1.11.0 

func RegisterSyncAgentServiceServer(s grpc.ServiceRegistrar, srv SyncAgentServiceServer)

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)
	// Fetches a :ref:`ref_flyteidl.admin.DynamicNodeWorkflowResponse`.
	GetDynamicNodeWorkflow(ctx context.Context, in *admin.GetDynamicNodeWorkflowRequest, opts ...grpc.CallOption) (*admin.DynamicNodeWorkflowResponse, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAdminServiceClient 

func NewAdminServiceClient(cc grpc.ClientConnInterface) 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)
	// Fetches a :ref:`ref_flyteidl.admin.DynamicNodeWorkflowResponse`.
	GetDynamicNodeWorkflow(context.Context, *admin.GetDynamicNodeWorkflowRequest) (*admin.DynamicNodeWorkflowResponse, 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. All implementations should embed UnimplementedAdminServiceServer for forward compatibility

type AgentMetadataServiceClient added in v1.10.7 

type AgentMetadataServiceClient interface {
	// Fetch a :ref:`ref_flyteidl.admin.Agent` definition.
	GetAgent(ctx context.Context, in *admin.GetAgentRequest, opts ...grpc.CallOption) (*admin.GetAgentResponse, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.Agent` definitions.
	ListAgents(ctx context.Context, in *admin.ListAgentsRequest, opts ...grpc.CallOption) (*admin.ListAgentsResponse, error)
}

AgentMetadataServiceClient is the client API for AgentMetadataService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAgentMetadataServiceClient added in v1.10.7 

func NewAgentMetadataServiceClient(cc grpc.ClientConnInterface) AgentMetadataServiceClient

type AgentMetadataServiceServer added in v1.10.7 

type AgentMetadataServiceServer interface {
	// Fetch a :ref:`ref_flyteidl.admin.Agent` definition.
	GetAgent(context.Context, *admin.GetAgentRequest) (*admin.GetAgentResponse, error)
	// Fetch a list of :ref:`ref_flyteidl.admin.Agent` definitions.
	ListAgents(context.Context, *admin.ListAgentsRequest) (*admin.ListAgentsResponse, error)
}

AgentMetadataServiceServer is the server API for AgentMetadataService service. All implementations should embed UnimplementedAgentMetadataServiceServer for forward compatibility

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) Descriptor added in v1.10.7 

func (ArtifactType) Descriptor() protoreflect.EnumDescriptor

func (ArtifactType) Enum added in v1.10.7 

func (x ArtifactType) Enum() *ArtifactType

func (ArtifactType) EnumDescriptor deprecated 

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

Deprecated: Use ArtifactType.Descriptor instead.

func (ArtifactType) Number added in v1.10.7 

func (x ArtifactType) Number() protoreflect.EnumNumber

func (ArtifactType) String 

func (x ArtifactType) String() string

func (ArtifactType) Type added in v1.10.7 

func (ArtifactType) Type() protoreflect.EnumType

type AsyncAgentServiceClient 

type AsyncAgentServiceClient interface {
	// CreateTask sends a task create request to the agent service.
	CreateTask(ctx context.Context, in *admin.CreateTaskRequest, opts ...grpc.CallOption) (*admin.CreateTaskResponse, error)
	// Get job status.
	GetTask(ctx context.Context, in *admin.GetTaskRequest, opts ...grpc.CallOption) (*admin.GetTaskResponse, error)
	// Delete the task resource.
	DeleteTask(ctx context.Context, in *admin.DeleteTaskRequest, opts ...grpc.CallOption) (*admin.DeleteTaskResponse, error)
	// GetTaskMetrics returns one or more task execution metrics, if available.
	//
	// Errors include
	//   - OutOfRange if metrics are not available for the specified task time range
	//   - various other errors
	GetTaskMetrics(ctx context.Context, in *admin.GetTaskMetricsRequest, opts ...grpc.CallOption) (*admin.GetTaskMetricsResponse, error)
	// GetTaskLogs returns task execution logs, if available.
	GetTaskLogs(ctx context.Context, in *admin.GetTaskLogsRequest, opts ...grpc.CallOption) (AsyncAgentService_GetTaskLogsClient, error)
}

AsyncAgentServiceClient is the client API for AsyncAgentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAsyncAgentServiceClient 

func NewAsyncAgentServiceClient(cc grpc.ClientConnInterface) AsyncAgentServiceClient

type AsyncAgentServiceServer 

type AsyncAgentServiceServer interface {
	// CreateTask sends a task create request to the agent service.
	CreateTask(context.Context, *admin.CreateTaskRequest) (*admin.CreateTaskResponse, error)
	// Get job status.
	GetTask(context.Context, *admin.GetTaskRequest) (*admin.GetTaskResponse, error)
	// Delete the task resource.
	DeleteTask(context.Context, *admin.DeleteTaskRequest) (*admin.DeleteTaskResponse, error)
	// GetTaskMetrics returns one or more task execution metrics, if available.
	//
	// Errors include
	//   - OutOfRange if metrics are not available for the specified task time range
	//   - various other errors
	GetTaskMetrics(context.Context, *admin.GetTaskMetricsRequest) (*admin.GetTaskMetricsResponse, error)
	// GetTaskLogs returns task execution logs, if available.
	GetTaskLogs(*admin.GetTaskLogsRequest, AsyncAgentService_GetTaskLogsServer) error
}

AsyncAgentServiceServer is the server API for AsyncAgentService service. All implementations should embed UnimplementedAsyncAgentServiceServer for forward compatibility

type AsyncAgentService_GetTaskLogsClient added in v1.11.0 

type AsyncAgentService_GetTaskLogsClient interface {
	Recv() (*admin.GetTaskLogsResponse, error)
	grpc.ClientStream
}

type AsyncAgentService_GetTaskLogsServer added in v1.11.0 

type AsyncAgentService_GetTaskLogsServer interface {
	Send(*admin.GetTaskLogsResponse) error
	grpc.ServerStream
}

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAuthMetadataServiceClient 

func NewAuthMetadataServiceClient(cc grpc.ClientConnInterface) 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. All implementations should embed UnimplementedAuthMetadataServiceServer for forward compatibility

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 *durationpb.Duration `protobuf:"bytes,2,opt,name=expires_in,json=expiresIn,proto3" json:"expires_in,omitempty"`
	// Types that are assignable to Source:
	//
	//	*CreateDownloadLinkRequest_NodeExecutionId
	Source isCreateDownloadLinkRequest_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

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

func (*CreateDownloadLinkRequest) Descriptor deprecated 

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

Deprecated: Use CreateDownloadLinkRequest.ProtoReflect.Descriptor instead.

func (*CreateDownloadLinkRequest) GetArtifactType 

func (x *CreateDownloadLinkRequest) GetArtifactType() ArtifactType

func (*CreateDownloadLinkRequest) GetExpiresIn 

func (x *CreateDownloadLinkRequest) GetExpiresIn() *durationpb.Duration

func (*CreateDownloadLinkRequest) GetNodeExecutionId 

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

func (*CreateDownloadLinkRequest) GetSource 

func (m *CreateDownloadLinkRequest) GetSource() isCreateDownloadLinkRequest_Source

func (*CreateDownloadLinkRequest) ProtoMessage 

func (*CreateDownloadLinkRequest) ProtoMessage()

func (*CreateDownloadLinkRequest) ProtoReflect added in v1.10.7 

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

func (*CreateDownloadLinkRequest) Reset 

func (x *CreateDownloadLinkRequest) Reset()

func (*CreateDownloadLinkRequest) String 

func (x *CreateDownloadLinkRequest) String() string

type CreateDownloadLinkRequest_NodeExecutionId 

type CreateDownloadLinkRequest_NodeExecutionId struct {
	// NodeId is the unique identifier for the node execution. For a task node, this will retrieve the output of the
	// most recent attempt of the task.
	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-...)
	//
	// Deprecated: Marked as deprecated in flyteidl/service/dataproxy.proto.
	SignedUrl []string `protobuf:"bytes,1,rep,name=signed_url,json=signedUrl,proto3" json:"signed_url,omitempty"`
	// ExpiresAt defines when will the signed URL expire.
	//
	// Deprecated: Marked as deprecated in flyteidl/service/dataproxy.proto.
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// New wrapper object containing the signed urls and expiration time
	PreSignedUrls *PreSignedURLs `protobuf:"bytes,3,opt,name=pre_signed_urls,json=preSignedUrls,proto3" json:"pre_signed_urls,omitempty"`
	// contains filtered or unexported fields
}

CreateDownloadLinkResponse defines the response for the generated links

func (*CreateDownloadLinkResponse) Descriptor deprecated 

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

Deprecated: Use CreateDownloadLinkResponse.ProtoReflect.Descriptor instead.

func (*CreateDownloadLinkResponse) GetExpiresAt deprecated 

func (x *CreateDownloadLinkResponse) GetExpiresAt() *timestamppb.Timestamp

Deprecated: Marked as deprecated in flyteidl/service/dataproxy.proto.

func (*CreateDownloadLinkResponse) GetPreSignedUrls 

func (x *CreateDownloadLinkResponse) GetPreSignedUrls() *PreSignedURLs

func (*CreateDownloadLinkResponse) GetSignedUrl deprecated 

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

Deprecated: Marked as deprecated in flyteidl/service/dataproxy.proto.

func (*CreateDownloadLinkResponse) ProtoMessage 

func (*CreateDownloadLinkResponse) ProtoMessage()

func (*CreateDownloadLinkResponse) ProtoReflect added in v1.10.7 

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

func (*CreateDownloadLinkResponse) Reset 

func (x *CreateDownloadLinkResponse) Reset()

func (*CreateDownloadLinkResponse) String 

func (x *CreateDownloadLinkResponse) String() string

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 *durationpb.Duration `protobuf:"bytes,2,opt,name=expires_in,json=expiresIn,proto3" json:"expires_in,omitempty"`
	// contains filtered or unexported fields
}

CreateDownloadLocationRequest specified request for the CreateDownloadLocation API.

Deprecated: Marked as deprecated in flyteidl/service/dataproxy.proto.

func (*CreateDownloadLocationRequest) Descriptor deprecated 

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

Deprecated: Use CreateDownloadLocationRequest.ProtoReflect.Descriptor instead.

func (*CreateDownloadLocationRequest) GetExpiresIn 

func (x *CreateDownloadLocationRequest) GetExpiresIn() *durationpb.Duration

func (*CreateDownloadLocationRequest) GetNativeUrl 

func (x *CreateDownloadLocationRequest) GetNativeUrl() string

func (*CreateDownloadLocationRequest) ProtoMessage 

func (*CreateDownloadLocationRequest) ProtoMessage()

func (*CreateDownloadLocationRequest) ProtoReflect added in v1.10.7 

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

func (*CreateDownloadLocationRequest) Reset 

func (x *CreateDownloadLocationRequest) Reset()

func (*CreateDownloadLocationRequest) String 

func (x *CreateDownloadLocationRequest) String() string

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 *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Marked as deprecated in flyteidl/service/dataproxy.proto.

func (*CreateDownloadLocationResponse) Descriptor deprecated 

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

Deprecated: Use CreateDownloadLocationResponse.ProtoReflect.Descriptor instead.

func (*CreateDownloadLocationResponse) GetExpiresAt 

func (x *CreateDownloadLocationResponse) GetExpiresAt() *timestamppb.Timestamp

func (*CreateDownloadLocationResponse) GetSignedUrl 

func (x *CreateDownloadLocationResponse) GetSignedUrl() string

func (*CreateDownloadLocationResponse) ProtoMessage 

func (*CreateDownloadLocationResponse) ProtoMessage()

func (*CreateDownloadLocationResponse) ProtoReflect added in v1.10.7 

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

func (*CreateDownloadLocationResponse) Reset 

func (x *CreateDownloadLocationResponse) Reset()

func (*CreateDownloadLocationResponse) String 

func (x *CreateDownloadLocationResponse) String() string

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 *durationpb.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"`
	// If present, data proxy will use this string in lieu of the md5 hash in the path. When the filename is also included
	// this makes the upload location deterministic. The native url will still be prefixed by the upload location prefix
	// in data proxy config. This option is useful when uploading multiple files.
	// +optional
	FilenameRoot string `protobuf:"bytes,6,opt,name=filename_root,json=filenameRoot,proto3" json:"filename_root,omitempty"`
	// If true, the data proxy will add content_md5 to the metadata to the signed URL and
	// it will force clients to add this metadata to the object.
	// This make sure dataproxy is backward compatible with the old flytekit.
	AddContentMd5Metadata bool `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

CreateUploadLocationRequest specified request for the CreateUploadLocation API. The implementation in data proxy service will create the s3 location with some server side configured prefixes, and then:

  • project/domain/(a deterministic str representation of the content_md5)/filename (if present); OR
  • project/domain/filename_root (if present)/filename (if present).

func (*CreateUploadLocationRequest) Descriptor deprecated 

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

Deprecated: Use CreateUploadLocationRequest.ProtoReflect.Descriptor instead.

func (*CreateUploadLocationRequest) GetAddContentMd5Metadata added in v1.11.0 

func (x *CreateUploadLocationRequest) GetAddContentMd5Metadata() bool

func (*CreateUploadLocationRequest) GetContentMd5 

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

func (*CreateUploadLocationRequest) GetDomain 

func (x *CreateUploadLocationRequest) GetDomain() string

func (*CreateUploadLocationRequest) GetExpiresIn 

func (x *CreateUploadLocationRequest) GetExpiresIn() *durationpb.Duration

func (*CreateUploadLocationRequest) GetFilename 

func (x *CreateUploadLocationRequest) GetFilename() string

func (*CreateUploadLocationRequest) GetFilenameRoot 

func (x *CreateUploadLocationRequest) GetFilenameRoot() string

func (*CreateUploadLocationRequest) GetProject 

func (x *CreateUploadLocationRequest) GetProject() string

func (*CreateUploadLocationRequest) ProtoMessage 

func (*CreateUploadLocationRequest) ProtoMessage()

func (*CreateUploadLocationRequest) ProtoReflect added in v1.10.7 

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

func (*CreateUploadLocationRequest) Reset 

func (x *CreateUploadLocationRequest) Reset()

func (*CreateUploadLocationRequest) String 

func (x *CreateUploadLocationRequest) String() string

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 *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// Data proxy generates these headers for client, and they have to add these headers to the request when uploading the file.
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateUploadLocationResponse) Descriptor deprecated 

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

Deprecated: Use CreateUploadLocationResponse.ProtoReflect.Descriptor instead.

func (*CreateUploadLocationResponse) GetExpiresAt 

func (x *CreateUploadLocationResponse) GetExpiresAt() *timestamppb.Timestamp

func (*CreateUploadLocationResponse) GetHeaders added in v1.11.0 

func (x *CreateUploadLocationResponse) GetHeaders() map[string]string

func (*CreateUploadLocationResponse) GetNativeUrl 

func (x *CreateUploadLocationResponse) GetNativeUrl() string

func (*CreateUploadLocationResponse) GetSignedUrl 

func (x *CreateUploadLocationResponse) GetSignedUrl() string

func (*CreateUploadLocationResponse) ProtoMessage 

func (*CreateUploadLocationResponse) ProtoMessage()

func (*CreateUploadLocationResponse) ProtoReflect added in v1.10.7 

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

func (*CreateUploadLocationResponse) Reset 

func (x *CreateUploadLocationResponse) Reset()

func (*CreateUploadLocationResponse) String 

func (x *CreateUploadLocationResponse) String() string

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)
	// Deprecated: Do not use.
	// 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)
	GetData(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (*GetDataResponse, error)
}

DataProxyServiceClient is the client API for DataProxyService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDataProxyServiceClient 

func NewDataProxyServiceClient(cc grpc.ClientConnInterface) 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)
	// Deprecated: Do not use.
	// 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)
	GetData(context.Context, *GetDataRequest) (*GetDataResponse, error)
}

DataProxyServiceServer is the server API for DataProxyService service. All implementations should embed UnimplementedDataProxyServiceServer for forward compatibility

type ExternalPluginServiceClient 

type ExternalPluginServiceClient interface {
	// Deprecated: Do not use.
	// Send a task create request to the backend plugin server.
	CreateTask(ctx context.Context, in *TaskCreateRequest, opts ...grpc.CallOption) (*TaskCreateResponse, error)
	// Deprecated: Do not use.
	// Get job status.
	GetTask(ctx context.Context, in *TaskGetRequest, opts ...grpc.CallOption) (*TaskGetResponse, error)
	// Deprecated: Do not use.
	// 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExternalPluginServiceClient 

func NewExternalPluginServiceClient(cc grpc.ClientConnInterface) ExternalPluginServiceClient

type ExternalPluginServiceServer 

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

ExternalPluginServiceServer is the server API for ExternalPluginService service. All implementations should embed UnimplementedExternalPluginServiceServer for forward compatibility

type GetDataRequest 

type GetDataRequest struct {

	// A unique identifier in the form of flyte://<something> that uniquely, for a given Flyte
	// backend, identifies a Flyte artifact ([i]nput, [o]output, flyte [d]eck, etc.).
	// e.g. flyte://v1/proj/development/execid/n2/0/i (for 0th task execution attempt input)
	//
	//	flyte://v1/proj/development/execid/n2/i (for node execution input)
	//	flyte://v1/proj/development/execid/n2/o/o3 (the o3 output of the second node)
	FlyteUrl string `protobuf:"bytes,1,opt,name=flyte_url,json=flyteUrl,proto3" json:"flyte_url,omitempty"`
	// contains filtered or unexported fields
}

General request artifact to retrieve data from a Flyte artifact url.

func (*GetDataRequest) Descriptor deprecated 

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

Deprecated: Use GetDataRequest.ProtoReflect.Descriptor instead.

func (*GetDataRequest) GetFlyteUrl 

func (x *GetDataRequest) GetFlyteUrl() string

func (*GetDataRequest) ProtoMessage 

func (*GetDataRequest) ProtoMessage()

func (*GetDataRequest) ProtoReflect added in v1.10.7 

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

func (*GetDataRequest) Reset 

func (x *GetDataRequest) Reset()

func (*GetDataRequest) String 

func (x *GetDataRequest) String() string

type GetDataResponse 

type GetDataResponse struct {

	// Types that are assignable to Data:
	//
	//	*GetDataResponse_LiteralMap
	//	*GetDataResponse_PreSignedUrls
	//	*GetDataResponse_Literal
	Data isGetDataResponse_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*GetDataResponse) Descriptor deprecated 

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

Deprecated: Use GetDataResponse.ProtoReflect.Descriptor instead.

func (*GetDataResponse) GetData 

func (m *GetDataResponse) GetData() isGetDataResponse_Data

func (*GetDataResponse) GetLiteral 

func (x *GetDataResponse) GetLiteral() *core.Literal

func (*GetDataResponse) GetLiteralMap 

func (x *GetDataResponse) GetLiteralMap() *core.LiteralMap

func (*GetDataResponse) GetPreSignedUrls 

func (x *GetDataResponse) GetPreSignedUrls() *PreSignedURLs

func (*GetDataResponse) ProtoMessage 

func (*GetDataResponse) ProtoMessage()

func (*GetDataResponse) ProtoReflect added in v1.10.7 

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

func (*GetDataResponse) Reset 

func (x *GetDataResponse) Reset()

func (*GetDataResponse) String 

func (x *GetDataResponse) String() string

type GetDataResponse_Literal 

type GetDataResponse_Literal struct {
	// Single literal will be returned. This is returned when the user/url requests a specific output or input
	// by name. See the o3 example above.
	Literal *core.Literal `protobuf:"bytes,3,opt,name=literal,proto3,oneof"`
}

type GetDataResponse_LiteralMap 

type GetDataResponse_LiteralMap struct {
	// literal map data will be returned
	LiteralMap *core.LiteralMap `protobuf:"bytes,1,opt,name=literal_map,json=literalMap,proto3,oneof"`
}

type GetDataResponse_PreSignedUrls 

type GetDataResponse_PreSignedUrls struct {
	// Flyte deck html will be returned as a signed url users can download
	PreSignedUrls *PreSignedURLs `protobuf:"bytes,2,opt,name=pre_signed_urls,json=preSignedUrls,proto3,oneof"`
}

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewIdentityServiceClient 

func NewIdentityServiceClient(cc grpc.ClientConnInterface) 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. All implementations should embed UnimplementedIdentityServiceServer for forward compatibility

type OAuth2MetadataRequest 

type OAuth2MetadataRequest struct {
	// contains filtered or unexported fields
}

func (*OAuth2MetadataRequest) Descriptor deprecated 

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

Deprecated: Use OAuth2MetadataRequest.ProtoReflect.Descriptor instead.

func (*OAuth2MetadataRequest) ProtoMessage 

func (*OAuth2MetadataRequest) ProtoMessage()

func (*OAuth2MetadataRequest) ProtoReflect added in v1.10.7 

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

func (*OAuth2MetadataRequest) Reset 

func (x *OAuth2MetadataRequest) Reset()

func (*OAuth2MetadataRequest) String 

func (x *OAuth2MetadataRequest) String() string

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 */
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use OAuth2MetadataResponse.ProtoReflect.Descriptor instead.

func (*OAuth2MetadataResponse) GetAuthorizationEndpoint 

func (x *OAuth2MetadataResponse) GetAuthorizationEndpoint() string

func (*OAuth2MetadataResponse) GetCodeChallengeMethodsSupported 

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

func (*OAuth2MetadataResponse) GetDeviceAuthorizationEndpoint 

func (x *OAuth2MetadataResponse) GetDeviceAuthorizationEndpoint() string

func (*OAuth2MetadataResponse) GetGrantTypesSupported 

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

func (*OAuth2MetadataResponse) GetIssuer 

func (x *OAuth2MetadataResponse) GetIssuer() string

func (*OAuth2MetadataResponse) GetJwksUri 

func (x *OAuth2MetadataResponse) GetJwksUri() string

func (*OAuth2MetadataResponse) GetResponseTypesSupported 

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

func (*OAuth2MetadataResponse) GetScopesSupported 

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

func (*OAuth2MetadataResponse) GetTokenEndpoint 

func (x *OAuth2MetadataResponse) GetTokenEndpoint() string

func (*OAuth2MetadataResponse) GetTokenEndpointAuthMethodsSupported 

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

func (*OAuth2MetadataResponse) ProtoMessage 

func (*OAuth2MetadataResponse) ProtoMessage()

func (*OAuth2MetadataResponse) ProtoReflect added in v1.10.7 

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

func (*OAuth2MetadataResponse) Reset 

func (x *OAuth2MetadataResponse) Reset()

func (*OAuth2MetadataResponse) String 

func (x *OAuth2MetadataResponse) String() string

type PreSignedURLs 

type PreSignedURLs 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 *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

Wrapper object since the message is shared across this and the GetDataResponse

func (*PreSignedURLs) Descriptor deprecated 

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

Deprecated: Use PreSignedURLs.ProtoReflect.Descriptor instead.

func (*PreSignedURLs) GetExpiresAt 

func (x *PreSignedURLs) GetExpiresAt() *timestamppb.Timestamp

func (*PreSignedURLs) GetSignedUrl 

func (x *PreSignedURLs) GetSignedUrl() []string

func (*PreSignedURLs) ProtoMessage 

func (*PreSignedURLs) ProtoMessage()

func (*PreSignedURLs) ProtoReflect added in v1.10.7 

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

func (*PreSignedURLs) Reset 

func (x *PreSignedURLs) Reset()

func (*PreSignedURLs) String 

func (x *PreSignedURLs) String() string

type PublicClientAuthConfigRequest 

type PublicClientAuthConfigRequest struct {
	// contains filtered or unexported fields
}

func (*PublicClientAuthConfigRequest) Descriptor deprecated 

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

Deprecated: Use PublicClientAuthConfigRequest.ProtoReflect.Descriptor instead.

func (*PublicClientAuthConfigRequest) ProtoMessage 

func (*PublicClientAuthConfigRequest) ProtoMessage()

func (*PublicClientAuthConfigRequest) ProtoReflect added in v1.10.7 

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

func (*PublicClientAuthConfigRequest) Reset 

func (x *PublicClientAuthConfigRequest) Reset()

func (*PublicClientAuthConfigRequest) String 

func (x *PublicClientAuthConfigRequest) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*PublicClientAuthConfigResponse) Descriptor deprecated 

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

Deprecated: Use PublicClientAuthConfigResponse.ProtoReflect.Descriptor instead.

func (*PublicClientAuthConfigResponse) GetAudience 

func (x *PublicClientAuthConfigResponse) GetAudience() string

func (*PublicClientAuthConfigResponse) GetAuthorizationMetadataKey 

func (x *PublicClientAuthConfigResponse) GetAuthorizationMetadataKey() string

func (*PublicClientAuthConfigResponse) GetClientId 

func (x *PublicClientAuthConfigResponse) GetClientId() string

func (*PublicClientAuthConfigResponse) GetRedirectUri 

func (x *PublicClientAuthConfigResponse) GetRedirectUri() string

func (*PublicClientAuthConfigResponse) GetScopes 

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

func (*PublicClientAuthConfigResponse) GetServiceHttpEndpoint 

func (x *PublicClientAuthConfigResponse) GetServiceHttpEndpoint() string

func (*PublicClientAuthConfigResponse) ProtoMessage 

func (*PublicClientAuthConfigResponse) ProtoMessage()

func (*PublicClientAuthConfigResponse) ProtoReflect added in v1.10.7 

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

func (*PublicClientAuthConfigResponse) Reset 

func (x *PublicClientAuthConfigResponse) Reset()

func (*PublicClientAuthConfigResponse) String 

func (x *PublicClientAuthConfigResponse) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSignalServiceClient 

func NewSignalServiceClient(cc grpc.ClientConnInterface) 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. All implementations should embed UnimplementedSignalServiceServer for forward compatibility

type State deprecated 

type State int32

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

Deprecated: Marked as deprecated in flyteidl/service/external_plugin_service.proto. 

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) Descriptor added in v1.10.7 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum added in v1.10.7 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

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

Deprecated: Use State.Descriptor instead.

func (State) Number added in v1.10.7 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type added in v1.10.7 

func (State) Type() protoreflect.EnumType

type SyncAgentServiceClient added in v1.11.0 

type SyncAgentServiceClient interface {
	// ExecuteTaskSync streams the create request and inputs to the agent service and streams the outputs back.
	ExecuteTaskSync(ctx context.Context, opts ...grpc.CallOption) (SyncAgentService_ExecuteTaskSyncClient, error)
}

SyncAgentServiceClient is the client API for SyncAgentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSyncAgentServiceClient added in v1.11.0 

func NewSyncAgentServiceClient(cc grpc.ClientConnInterface) SyncAgentServiceClient

type SyncAgentServiceServer added in v1.11.0 

type SyncAgentServiceServer interface {
	// ExecuteTaskSync streams the create request and inputs to the agent service and streams the outputs back.
	ExecuteTaskSync(SyncAgentService_ExecuteTaskSyncServer) error
}

SyncAgentServiceServer is the server API for SyncAgentService service. All implementations should embed UnimplementedSyncAgentServiceServer for forward compatibility

type SyncAgentService_ExecuteTaskSyncClient added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncClient interface {
	Send(*admin.ExecuteTaskSyncRequest) error
	Recv() (*admin.ExecuteTaskSyncResponse, error)
	grpc.ClientStream
}

type SyncAgentService_ExecuteTaskSyncServer added in v1.11.0 

type SyncAgentService_ExecuteTaskSyncServer interface {
	Send(*admin.ExecuteTaskSyncResponse) error
	Recv() (*admin.ExecuteTaskSyncRequest, error)
	grpc.ServerStream
}

type TaskCreateRequest deprecated 

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"`
	// contains filtered or unexported fields
}

Represents a request structure to create task.

Deprecated: Marked as deprecated in flyteidl/service/external_plugin_service.proto.

func (*TaskCreateRequest) Descriptor deprecated 

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

Deprecated: Use TaskCreateRequest.ProtoReflect.Descriptor instead.

func (*TaskCreateRequest) GetInputs 

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

func (*TaskCreateRequest) GetOutputPrefix 

func (x *TaskCreateRequest) GetOutputPrefix() string

func (*TaskCreateRequest) GetTemplate 

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

func (*TaskCreateRequest) ProtoMessage 

func (*TaskCreateRequest) ProtoMessage()

func (*TaskCreateRequest) ProtoReflect added in v1.10.7 

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

func (*TaskCreateRequest) Reset 

func (x *TaskCreateRequest) Reset()

func (*TaskCreateRequest) String 

func (x *TaskCreateRequest) String() string

type TaskCreateResponse deprecated 

type TaskCreateResponse struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

Represents a create response structure.

Deprecated: Marked as deprecated in flyteidl/service/external_plugin_service.proto.

func (*TaskCreateResponse) Descriptor deprecated 

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

Deprecated: Use TaskCreateResponse.ProtoReflect.Descriptor instead.

func (*TaskCreateResponse) GetJobId 

func (x *TaskCreateResponse) GetJobId() string

func (*TaskCreateResponse) ProtoMessage 

func (*TaskCreateResponse) ProtoMessage()

func (*TaskCreateResponse) ProtoReflect added in v1.10.7 

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

func (*TaskCreateResponse) Reset 

func (x *TaskCreateResponse) Reset()

func (*TaskCreateResponse) String 

func (x *TaskCreateResponse) String() string

type TaskDeleteRequest deprecated 

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"`
	// contains filtered or unexported fields
}

A message used to delete a task.

Deprecated: Marked as deprecated in flyteidl/service/external_plugin_service.proto.

func (*TaskDeleteRequest) Descriptor deprecated 

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

Deprecated: Use TaskDeleteRequest.ProtoReflect.Descriptor instead.

func (*TaskDeleteRequest) GetJobId 

func (x *TaskDeleteRequest) GetJobId() string

func (*TaskDeleteRequest) GetTaskType 

func (x *TaskDeleteRequest) GetTaskType() string

func (*TaskDeleteRequest) ProtoMessage 

func (*TaskDeleteRequest) ProtoMessage()

func (*TaskDeleteRequest) ProtoReflect added in v1.10.7 

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

func (*TaskDeleteRequest) Reset 

func (x *TaskDeleteRequest) Reset()

func (*TaskDeleteRequest) String 

func (x *TaskDeleteRequest) String() string

type TaskDeleteResponse deprecated 

type TaskDeleteResponse struct {
	// contains filtered or unexported fields
}

Response to delete a task.

Deprecated: Marked as deprecated in flyteidl/service/external_plugin_service.proto.

func (*TaskDeleteResponse) Descriptor deprecated 

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

Deprecated: Use TaskDeleteResponse.ProtoReflect.Descriptor instead.

func (*TaskDeleteResponse) ProtoMessage 

func (*TaskDeleteResponse) ProtoMessage()

func (*TaskDeleteResponse) ProtoReflect added in v1.10.7 

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

func (*TaskDeleteResponse) Reset 

func (x *TaskDeleteResponse) Reset()

func (*TaskDeleteResponse) String 

func (x *TaskDeleteResponse) String() string

type TaskGetRequest deprecated 

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"`
	// contains filtered or unexported fields
}

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

Deprecated: Marked as deprecated in flyteidl/service/external_plugin_service.proto.

func (*TaskGetRequest) Descriptor deprecated 

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

Deprecated: Use TaskGetRequest.ProtoReflect.Descriptor instead.

func (*TaskGetRequest) GetJobId 

func (x *TaskGetRequest) GetJobId() string

func (*TaskGetRequest) GetTaskType 

func (x *TaskGetRequest) GetTaskType() string

func (*TaskGetRequest) ProtoMessage 

func (*TaskGetRequest) ProtoMessage()

func (*TaskGetRequest) ProtoReflect added in v1.10.7 

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

func (*TaskGetRequest) Reset 

func (x *TaskGetRequest) Reset()

func (*TaskGetRequest) String 

func (x *TaskGetRequest) String() string

type TaskGetResponse deprecated 

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"`
	// contains filtered or unexported fields
}

Response to get an individual task state.

Deprecated: Marked as deprecated in flyteidl/service/external_plugin_service.proto.

func (*TaskGetResponse) Descriptor deprecated 

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

Deprecated: Use TaskGetResponse.ProtoReflect.Descriptor instead.

func (*TaskGetResponse) GetOutputs 

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

func (*TaskGetResponse) GetState 

func (x *TaskGetResponse) GetState() State

func (*TaskGetResponse) ProtoMessage 

func (*TaskGetResponse) ProtoMessage()

func (*TaskGetResponse) ProtoReflect added in v1.10.7 

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

func (*TaskGetResponse) Reset 

func (x *TaskGetResponse) Reset()

func (*TaskGetResponse) String 

func (x *TaskGetResponse) String() string

type UnimplementedAdminServiceServer 

type UnimplementedAdminServiceServer struct {
}

UnimplementedAdminServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAdminServiceServer) CreateExecution 

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

func (UnimplementedAdminServiceServer) CreateLaunchPlan 

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

func (UnimplementedAdminServiceServer) CreateNodeEvent 

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

func (UnimplementedAdminServiceServer) CreateTask 

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

func (UnimplementedAdminServiceServer) CreateTaskEvent 

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

func (UnimplementedAdminServiceServer) CreateWorkflow 

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

func (UnimplementedAdminServiceServer) CreateWorkflowEvent 

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

func (UnimplementedAdminServiceServer) DeleteProjectAttributes 

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

func (UnimplementedAdminServiceServer) DeleteProjectDomainAttributes 

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

func (UnimplementedAdminServiceServer) DeleteWorkflowAttributes 

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

func (UnimplementedAdminServiceServer) GetActiveLaunchPlan 

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

func (UnimplementedAdminServiceServer) GetDescriptionEntity 

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

func (UnimplementedAdminServiceServer) GetDynamicNodeWorkflow added in v1.10.7 

func (UnimplementedAdminServiceServer) GetDynamicNodeWorkflow(context.Context, *admin.GetDynamicNodeWorkflowRequest) (*admin.DynamicNodeWorkflowResponse, error)

func (UnimplementedAdminServiceServer) GetExecution 

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

func (UnimplementedAdminServiceServer) GetExecutionData 

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

func (UnimplementedAdminServiceServer) GetExecutionMetrics 

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

func (UnimplementedAdminServiceServer) GetLaunchPlan 

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

func (UnimplementedAdminServiceServer) GetNamedEntity 

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

func (UnimplementedAdminServiceServer) GetNodeExecution 

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

func (UnimplementedAdminServiceServer) GetNodeExecutionData 

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

func (UnimplementedAdminServiceServer) GetProjectAttributes 

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

func (UnimplementedAdminServiceServer) GetProjectDomainAttributes 

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

func (UnimplementedAdminServiceServer) GetTask 

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

func (UnimplementedAdminServiceServer) GetTaskExecution 

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

func (UnimplementedAdminServiceServer) GetTaskExecutionData 

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

func (UnimplementedAdminServiceServer) GetVersion 

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

func (UnimplementedAdminServiceServer) GetWorkflow 

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

func (UnimplementedAdminServiceServer) GetWorkflowAttributes 

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

func (UnimplementedAdminServiceServer) ListActiveLaunchPlans 

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

func (UnimplementedAdminServiceServer) ListDescriptionEntities 

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

func (UnimplementedAdminServiceServer) ListExecutions 

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

func (UnimplementedAdminServiceServer) ListLaunchPlanIds 

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

func (UnimplementedAdminServiceServer) ListLaunchPlans 

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

func (UnimplementedAdminServiceServer) ListMatchableAttributes 

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

func (UnimplementedAdminServiceServer) ListNamedEntities 

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

func (UnimplementedAdminServiceServer) ListNodeExecutions 

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

func (UnimplementedAdminServiceServer) ListNodeExecutionsForTask 

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

func (UnimplementedAdminServiceServer) ListProjects 

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

func (UnimplementedAdminServiceServer) ListTaskExecutions 

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

func (UnimplementedAdminServiceServer) ListTaskIds 

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

func (UnimplementedAdminServiceServer) ListTasks 

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

func (UnimplementedAdminServiceServer) ListWorkflowIds 

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

func (UnimplementedAdminServiceServer) ListWorkflows 

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

func (UnimplementedAdminServiceServer) RecoverExecution 

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

func (UnimplementedAdminServiceServer) RegisterProject 

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

func (UnimplementedAdminServiceServer) RelaunchExecution 

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

func (UnimplementedAdminServiceServer) TerminateExecution 

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

func (UnimplementedAdminServiceServer) UpdateExecution 

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

func (UnimplementedAdminServiceServer) UpdateLaunchPlan 

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

func (UnimplementedAdminServiceServer) UpdateNamedEntity 

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

func (UnimplementedAdminServiceServer) UpdateProject 

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

func (UnimplementedAdminServiceServer) UpdateProjectAttributes 

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

func (UnimplementedAdminServiceServer) UpdateProjectDomainAttributes 

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

func (UnimplementedAdminServiceServer) UpdateWorkflowAttributes 

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

type UnimplementedAgentMetadataServiceServer added in v1.10.7 

type UnimplementedAgentMetadataServiceServer struct {
}

UnimplementedAgentMetadataServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAgentMetadataServiceServer) GetAgent added in v1.10.7 

func (UnimplementedAgentMetadataServiceServer) GetAgent(context.Context, *admin.GetAgentRequest) (*admin.GetAgentResponse, error)

func (UnimplementedAgentMetadataServiceServer) ListAgents added in v1.10.7 

func (UnimplementedAgentMetadataServiceServer) ListAgents(context.Context, *admin.ListAgentsRequest) (*admin.ListAgentsResponse, error)

type UnimplementedAsyncAgentServiceServer 

type UnimplementedAsyncAgentServiceServer struct {
}

UnimplementedAsyncAgentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAsyncAgentServiceServer) CreateTask 

func (UnimplementedAsyncAgentServiceServer) CreateTask(context.Context, *admin.CreateTaskRequest) (*admin.CreateTaskResponse, error)

func (UnimplementedAsyncAgentServiceServer) DeleteTask 

func (UnimplementedAsyncAgentServiceServer) DeleteTask(context.Context, *admin.DeleteTaskRequest) (*admin.DeleteTaskResponse, error)

func (UnimplementedAsyncAgentServiceServer) GetTask 

func (UnimplementedAsyncAgentServiceServer) GetTask(context.Context, *admin.GetTaskRequest) (*admin.GetTaskResponse, error)

func (UnimplementedAsyncAgentServiceServer) GetTaskLogs added in v1.10.7 

func (UnimplementedAsyncAgentServiceServer) GetTaskLogs(*admin.GetTaskLogsRequest, AsyncAgentService_GetTaskLogsServer) error

func (UnimplementedAsyncAgentServiceServer) GetTaskMetrics added in v1.10.7 

func (UnimplementedAsyncAgentServiceServer) GetTaskMetrics(context.Context, *admin.GetTaskMetricsRequest) (*admin.GetTaskMetricsResponse, error)

type UnimplementedAuthMetadataServiceServer 

type UnimplementedAuthMetadataServiceServer struct {
}

UnimplementedAuthMetadataServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAuthMetadataServiceServer) GetOAuth2Metadata 

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

func (UnimplementedAuthMetadataServiceServer) GetPublicClientConfig 

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

type UnimplementedDataProxyServiceServer 

type UnimplementedDataProxyServiceServer struct {
}

UnimplementedDataProxyServiceServer should be embedded to have forward compatible implementations. 

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

func (UnimplementedDataProxyServiceServer) CreateDownloadLocation 

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

func (UnimplementedDataProxyServiceServer) CreateUploadLocation 

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

func (UnimplementedDataProxyServiceServer) GetData 

func (UnimplementedDataProxyServiceServer) GetData(context.Context, *GetDataRequest) (*GetDataResponse, error)

type UnimplementedExternalPluginServiceServer 

type UnimplementedExternalPluginServiceServer struct {
}

UnimplementedExternalPluginServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedExternalPluginServiceServer) CreateTask 

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

func (UnimplementedExternalPluginServiceServer) DeleteTask 

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

func (UnimplementedExternalPluginServiceServer) GetTask 

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

type UnimplementedIdentityServiceServer 

type UnimplementedIdentityServiceServer struct {
}

UnimplementedIdentityServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedIdentityServiceServer) UserInfo 

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

type UnimplementedSignalServiceServer 

type UnimplementedSignalServiceServer struct {
}

UnimplementedSignalServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedSignalServiceServer) GetOrCreateSignal 

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

func (UnimplementedSignalServiceServer) ListSignals 

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

func (UnimplementedSignalServiceServer) SetSignal 

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

type UnimplementedSyncAgentServiceServer added in v1.11.0 

type UnimplementedSyncAgentServiceServer struct {
}

UnimplementedSyncAgentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedSyncAgentServiceServer) ExecuteTaskSync added in v1.11.0 

func (UnimplementedSyncAgentServiceServer) ExecuteTaskSync(SyncAgentService_ExecuteTaskSyncServer) error

type UnsafeAdminServiceServer added in v1.10.7 

type UnsafeAdminServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAdminServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AdminServiceServer will result in compilation errors.

type UnsafeAgentMetadataServiceServer added in v1.10.7 

type UnsafeAgentMetadataServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAgentMetadataServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentMetadataServiceServer will result in compilation errors.

type UnsafeAsyncAgentServiceServer added in v1.10.7 

type UnsafeAsyncAgentServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAsyncAgentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AsyncAgentServiceServer will result in compilation errors.

type UnsafeAuthMetadataServiceServer added in v1.10.7 

type UnsafeAuthMetadataServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAuthMetadataServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthMetadataServiceServer will result in compilation errors.

type UnsafeDataProxyServiceServer added in v1.10.7 

type UnsafeDataProxyServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDataProxyServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataProxyServiceServer will result in compilation errors.

type UnsafeExternalPluginServiceServer added in v1.10.7 

type UnsafeExternalPluginServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeExternalPluginServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExternalPluginServiceServer will result in compilation errors.

type UnsafeIdentityServiceServer added in v1.10.7 

type UnsafeIdentityServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeIdentityServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IdentityServiceServer will result in compilation errors.

type UnsafeSignalServiceServer added in v1.10.7 

type UnsafeSignalServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeSignalServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SignalServiceServer will result in compilation errors.

type UnsafeSyncAgentServiceServer added in v1.11.0 

type UnsafeSyncAgentServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeSyncAgentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SyncAgentServiceServer will result in compilation errors.

type UserInfoRequest 

type UserInfoRequest struct {
	// contains filtered or unexported fields
}

func (*UserInfoRequest) Descriptor deprecated 

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

Deprecated: Use UserInfoRequest.ProtoReflect.Descriptor instead.

func (*UserInfoRequest) ProtoMessage 

func (*UserInfoRequest) ProtoMessage()

func (*UserInfoRequest) ProtoReflect added in v1.10.7 

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

func (*UserInfoRequest) Reset 

func (x *UserInfoRequest) Reset()

func (*UserInfoRequest) String 

func (x *UserInfoRequest) String() string

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 *structpb.Struct `protobuf:"bytes,8,opt,name=additional_claims,json=additionalClaims,proto3" json:"additional_claims,omitempty"`
	// contains filtered or unexported fields
}

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

func (*UserInfoResponse) Descriptor deprecated 

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

Deprecated: Use UserInfoResponse.ProtoReflect.Descriptor instead.

func (*UserInfoResponse) GetAdditionalClaims 

func (x *UserInfoResponse) GetAdditionalClaims() *structpb.Struct

func (*UserInfoResponse) GetEmail 

func (x *UserInfoResponse) GetEmail() string

func (*UserInfoResponse) GetFamilyName 

func (x *UserInfoResponse) GetFamilyName() string

func (*UserInfoResponse) GetGivenName 

func (x *UserInfoResponse) GetGivenName() string

func (*UserInfoResponse) GetName 

func (x *UserInfoResponse) GetName() string

func (*UserInfoResponse) GetPicture 

func (x *UserInfoResponse) GetPicture() string

func (*UserInfoResponse) GetPreferredUsername 

func (x *UserInfoResponse) GetPreferredUsername() string

func (*UserInfoResponse) GetSubject 

func (x *UserInfoResponse) GetSubject() string

func (*UserInfoResponse) ProtoMessage 

func (*UserInfoResponse) ProtoMessage()

func (*UserInfoResponse) ProtoReflect added in v1.10.7 

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

func (*UserInfoResponse) Reset 

func (x *UserInfoResponse) Reset()

func (*UserInfoResponse) String 

func (x *UserInfoResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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