service

Jul 3, 2024

Changes in this version

+ const AdminService_GetDomains_FullMethodName

type AdminServiceClient

+ GetDomains func(ctx context.Context, in *admin.GetDomainRequest, opts ...grpc.CallOption) (*admin.GetDomainsResponse, error)

type AdminServiceServer

+ GetDomains func(context.Context, *admin.GetDomainRequest) (*admin.GetDomainsResponse, error)

type UnimplementedAdminServiceServer

+ func (UnimplementedAdminServiceServer) GetDomains(context.Context, *admin.GetDomainRequest) (*admin.GetDomainsResponse, error)

May 6, 2024

Changes in this version

+ const AdminService_GetProject_FullMethodName

type AdminServiceClient

+ GetProject func(ctx context.Context, in *admin.ProjectGetRequest, opts ...grpc.CallOption) (*admin.Project, error)

type AdminServiceServer

+ GetProject func(context.Context, *admin.ProjectGetRequest) (*admin.Project, error)

type CreateUploadLocationRequest

+ Org string

+ func (x *CreateUploadLocationRequest) GetOrg() string

type UnimplementedAdminServiceServer

+ func (UnimplementedAdminServiceServer) GetProject(context.Context, *admin.ProjectGetRequest) (*admin.Project, error)

Mar 12, 2024

Changes in this version

+ const SyncAgentService_ExecuteTaskSync_FullMethodName

+ var SyncAgentService_ServiceDesc = grpc.ServiceDesc

+ func RegisterSyncAgentServiceServer(s grpc.ServiceRegistrar, srv SyncAgentServiceServer)

+ type AsyncAgentService_GetTaskLogsClient interface

+ Recv func() (*admin.GetTaskLogsResponse, error)

+ type AsyncAgentService_GetTaskLogsServer interface

+ Send func(*admin.GetTaskLogsResponse) error

type CreateUploadLocationRequest

+ AddContentMd5Metadata bool

+ func (x *CreateUploadLocationRequest) GetAddContentMd5Metadata() bool

type CreateUploadLocationResponse

+ Headers map[string]string

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

+ type SyncAgentServiceClient interface

+ ExecuteTaskSync func(ctx context.Context, opts ...grpc.CallOption) (SyncAgentService_ExecuteTaskSyncClient, error)

+ func NewSyncAgentServiceClient(cc grpc.ClientConnInterface) SyncAgentServiceClient

+ type SyncAgentServiceServer interface

+ ExecuteTaskSync func(SyncAgentService_ExecuteTaskSyncServer) error

+ type SyncAgentService_ExecuteTaskSyncClient interface

+ Recv func() (*admin.ExecuteTaskSyncResponse, error)

+ Send func(*admin.ExecuteTaskSyncRequest) error

+ type SyncAgentService_ExecuteTaskSyncServer interface

+ Recv func() (*admin.ExecuteTaskSyncRequest, error)

+ Send func(*admin.ExecuteTaskSyncResponse) error

+ type UnimplementedSyncAgentServiceServer struct

+ func (UnimplementedSyncAgentServiceServer) ExecuteTaskSync(SyncAgentService_ExecuteTaskSyncServer) error

+ type UnsafeSyncAgentServiceServer interface

Feb 14, 2024

Changes in this version

+ const AdminService_CreateExecution_FullMethodName

+ const AdminService_CreateLaunchPlan_FullMethodName

+ const AdminService_CreateNodeEvent_FullMethodName

+ const AdminService_CreateTaskEvent_FullMethodName

+ const AdminService_CreateTask_FullMethodName

+ const AdminService_CreateWorkflowEvent_FullMethodName

+ const AdminService_CreateWorkflow_FullMethodName

+ const AdminService_DeleteProjectAttributes_FullMethodName

+ const AdminService_DeleteProjectDomainAttributes_FullMethodName

+ const AdminService_DeleteWorkflowAttributes_FullMethodName

+ const AdminService_GetActiveLaunchPlan_FullMethodName

+ const AdminService_GetDescriptionEntity_FullMethodName

+ const AdminService_GetDynamicNodeWorkflow_FullMethodName

+ const AdminService_GetExecutionData_FullMethodName

+ const AdminService_GetExecutionMetrics_FullMethodName

+ const AdminService_GetExecution_FullMethodName

+ const AdminService_GetLaunchPlan_FullMethodName

+ const AdminService_GetNamedEntity_FullMethodName

+ const AdminService_GetNodeExecutionData_FullMethodName

+ const AdminService_GetNodeExecution_FullMethodName

+ const AdminService_GetProjectAttributes_FullMethodName

+ const AdminService_GetProjectDomainAttributes_FullMethodName

+ const AdminService_GetTaskExecutionData_FullMethodName

+ const AdminService_GetTaskExecution_FullMethodName

+ const AdminService_GetTask_FullMethodName

+ const AdminService_GetVersion_FullMethodName

+ const AdminService_GetWorkflowAttributes_FullMethodName

+ const AdminService_GetWorkflow_FullMethodName

+ const AdminService_ListActiveLaunchPlans_FullMethodName

+ const AdminService_ListDescriptionEntities_FullMethodName

+ const AdminService_ListExecutions_FullMethodName

+ const AdminService_ListLaunchPlanIds_FullMethodName

+ const AdminService_ListLaunchPlans_FullMethodName

+ const AdminService_ListMatchableAttributes_FullMethodName

+ const AdminService_ListNamedEntities_FullMethodName

+ const AdminService_ListNodeExecutionsForTask_FullMethodName

+ const AdminService_ListNodeExecutions_FullMethodName

+ const AdminService_ListProjects_FullMethodName

+ const AdminService_ListTaskExecutions_FullMethodName

+ const AdminService_ListTaskIds_FullMethodName

+ const AdminService_ListTasks_FullMethodName

+ const AdminService_ListWorkflowIds_FullMethodName

+ const AdminService_ListWorkflows_FullMethodName

+ const AdminService_RecoverExecution_FullMethodName

+ const AdminService_RegisterProject_FullMethodName

+ const AdminService_RelaunchExecution_FullMethodName

+ const AdminService_TerminateExecution_FullMethodName

+ const AdminService_UpdateExecution_FullMethodName

+ const AdminService_UpdateLaunchPlan_FullMethodName

+ const AdminService_UpdateNamedEntity_FullMethodName

+ const AdminService_UpdateProjectAttributes_FullMethodName

+ const AdminService_UpdateProjectDomainAttributes_FullMethodName

+ const AdminService_UpdateProject_FullMethodName

+ const AdminService_UpdateWorkflowAttributes_FullMethodName

+ const AgentMetadataService_GetAgent_FullMethodName

+ const AgentMetadataService_ListAgents_FullMethodName

+ const AsyncAgentService_CreateTask_FullMethodName

+ const AsyncAgentService_DeleteTask_FullMethodName

+ const AsyncAgentService_GetTaskLogs_FullMethodName

+ const AsyncAgentService_GetTaskMetrics_FullMethodName

+ const AsyncAgentService_GetTask_FullMethodName

+ const AuthMetadataService_GetOAuth2Metadata_FullMethodName

+ const AuthMetadataService_GetPublicClientConfig_FullMethodName

+ const DataProxyService_CreateDownloadLink_FullMethodName

+ const DataProxyService_CreateDownloadLocation_FullMethodName

+ const DataProxyService_CreateUploadLocation_FullMethodName

+ const DataProxyService_GetData_FullMethodName

+ const ExternalPluginService_CreateTask_FullMethodName

+ const ExternalPluginService_DeleteTask_FullMethodName

+ const ExternalPluginService_GetTask_FullMethodName

+ const IdentityService_UserInfo_FullMethodName

+ const SignalService_GetOrCreateSignal_FullMethodName

+ const SignalService_ListSignals_FullMethodName

+ const SignalService_SetSignal_FullMethodName

+ var AdminService_ServiceDesc = grpc.ServiceDesc

+ var AgentMetadataService_ServiceDesc = grpc.ServiceDesc

+ var AsyncAgentService_ServiceDesc = grpc.ServiceDesc

+ var AuthMetadataService_ServiceDesc = grpc.ServiceDesc

+ var DataProxyService_ServiceDesc = grpc.ServiceDesc

+ var ExternalPluginService_ServiceDesc = grpc.ServiceDesc

+ var File_flyteidl_service_admin_proto protoreflect.FileDescriptor

+ var File_flyteidl_service_agent_proto protoreflect.FileDescriptor

+ var File_flyteidl_service_auth_proto protoreflect.FileDescriptor

+ var File_flyteidl_service_dataproxy_proto protoreflect.FileDescriptor

+ var File_flyteidl_service_external_plugin_service_proto protoreflect.FileDescriptor

+ var File_flyteidl_service_identity_proto protoreflect.FileDescriptor

+ var File_flyteidl_service_signal_proto protoreflect.FileDescriptor

+ var IdentityService_ServiceDesc = grpc.ServiceDesc

+ var SignalService_ServiceDesc = grpc.ServiceDesc

+ func RegisterAgentMetadataServiceServer(s grpc.ServiceRegistrar, srv AgentMetadataServiceServer)

type AdminServiceClient

+ GetDynamicNodeWorkflow func(ctx context.Context, in *admin.GetDynamicNodeWorkflowRequest, ...) (*admin.DynamicNodeWorkflowResponse, error)

type AdminServiceServer

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

+ type AgentMetadataServiceClient interface

+ GetAgent func(ctx context.Context, in *admin.GetAgentRequest, opts ...grpc.CallOption) (*admin.GetAgentResponse, error)

+ ListAgents func(ctx context.Context, in *admin.ListAgentsRequest, opts ...grpc.CallOption) (*admin.ListAgentsResponse, error)

+ func NewAgentMetadataServiceClient(cc grpc.ClientConnInterface) AgentMetadataServiceClient

+ type AgentMetadataServiceServer interface

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

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

type ArtifactType

+ func (ArtifactType) Descriptor() protoreflect.EnumDescriptor

+ func (ArtifactType) Type() protoreflect.EnumType

+ func (x ArtifactType) Enum() *ArtifactType

+ func (x ArtifactType) Number() protoreflect.EnumNumber

type AsyncAgentServiceClient

+ GetTaskLogs func(ctx context.Context, in *admin.GetTaskLogsRequest, opts ...grpc.CallOption) (*admin.GetTaskLogsResponse, error)

+ GetTaskMetrics func(ctx context.Context, in *admin.GetTaskMetricsRequest, opts ...grpc.CallOption) (*admin.GetTaskMetricsResponse, error)

type AsyncAgentServiceServer

+ GetTaskLogs func(context.Context, *admin.GetTaskLogsRequest) (*admin.GetTaskLogsResponse, error)

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

type CreateDownloadLinkRequest

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

type CreateDownloadLinkResponse

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

type CreateDownloadLocationRequest

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

type CreateDownloadLocationResponse

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

type CreateUploadLocationRequest

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

type CreateUploadLocationResponse

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

type GetDataRequest

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

type GetDataResponse

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

type OAuth2MetadataRequest

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

type OAuth2MetadataResponse

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

type PreSignedURLs

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

type PublicClientAuthConfigRequest

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

type PublicClientAuthConfigResponse

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

type State

+ func (State) Descriptor() protoreflect.EnumDescriptor

+ func (State) Type() protoreflect.EnumType

+ func (x State) Enum() *State

+ func (x State) Number() protoreflect.EnumNumber

type TaskCreateRequest

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

type TaskCreateResponse

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

type TaskDeleteRequest

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

type TaskDeleteResponse

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

type TaskGetRequest

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

type TaskGetResponse

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

type UnimplementedAdminServiceServer

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

+ type UnimplementedAgentMetadataServiceServer struct

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

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

type UnimplementedAsyncAgentServiceServer

+ func (UnimplementedAsyncAgentServiceServer) GetTaskLogs(context.Context, *admin.GetTaskLogsRequest) (*admin.GetTaskLogsResponse, error)

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

+ type UnsafeAdminServiceServer interface

+ type UnsafeAgentMetadataServiceServer interface

+ type UnsafeAsyncAgentServiceServer interface

+ type UnsafeAuthMetadataServiceServer interface

+ type UnsafeDataProxyServiceServer interface

+ type UnsafeExternalPluginServiceServer interface

+ type UnsafeIdentityServiceServer interface

+ type UnsafeSignalServiceServer interface

type UserInfoRequest

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

type UserInfoResponse

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

Oct 4, 2023

Changes in this version

+ var ArtifactType_name = map[int32]string

+ var ArtifactType_value = map[string]int32

+ var State_name = map[int32]string

+ var State_value = map[string]int32

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

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

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

+ func AssetNames() []string

+ func MustAsset(name string) []byte

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

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

+ func RegisterAdminServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterAsyncAgentServiceServer(s *grpc.Server, srv AsyncAgentServiceServer)

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

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

+ func RegisterAuthMetadataServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

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

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

+ func RegisterDataProxyServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

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

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

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

+ func RegisterIdentityServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

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

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

+ func RegisterSignalServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RestoreAsset(dir, name string) error

+ func RestoreAssets(dir, name string) error

+ type AdminServiceClient interface

+ CreateExecution func(ctx context.Context, in *admin.ExecutionCreateRequest, opts ...grpc.CallOption) (*admin.ExecutionCreateResponse, error)

+ CreateLaunchPlan func(ctx context.Context, in *admin.LaunchPlanCreateRequest, ...) (*admin.LaunchPlanCreateResponse, error)

+ CreateNodeEvent func(ctx context.Context, in *admin.NodeExecutionEventRequest, ...) (*admin.NodeExecutionEventResponse, error)

+ CreateTask func(ctx context.Context, in *admin.TaskCreateRequest, opts ...grpc.CallOption) (*admin.TaskCreateResponse, error)

+ CreateTaskEvent func(ctx context.Context, in *admin.TaskExecutionEventRequest, ...) (*admin.TaskExecutionEventResponse, error)

+ CreateWorkflow func(ctx context.Context, in *admin.WorkflowCreateRequest, opts ...grpc.CallOption) (*admin.WorkflowCreateResponse, error)

+ CreateWorkflowEvent func(ctx context.Context, in *admin.WorkflowExecutionEventRequest, ...) (*admin.WorkflowExecutionEventResponse, error)

+ DeleteProjectAttributes func(ctx context.Context, in *admin.ProjectAttributesDeleteRequest, ...) (*admin.ProjectAttributesDeleteResponse, error)

+ DeleteProjectDomainAttributes func(ctx context.Context, in *admin.ProjectDomainAttributesDeleteRequest, ...) (*admin.ProjectDomainAttributesDeleteResponse, error)

+ DeleteWorkflowAttributes func(ctx context.Context, in *admin.WorkflowAttributesDeleteRequest, ...) (*admin.WorkflowAttributesDeleteResponse, error)

+ GetActiveLaunchPlan func(ctx context.Context, in *admin.ActiveLaunchPlanRequest, ...) (*admin.LaunchPlan, error)

+ GetDescriptionEntity func(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.DescriptionEntity, error)

+ GetExecution func(ctx context.Context, in *admin.WorkflowExecutionGetRequest, ...) (*admin.Execution, error)

+ GetExecutionData func(ctx context.Context, in *admin.WorkflowExecutionGetDataRequest, ...) (*admin.WorkflowExecutionGetDataResponse, error)

+ GetExecutionMetrics func(ctx context.Context, in *admin.WorkflowExecutionGetMetricsRequest, ...) (*admin.WorkflowExecutionGetMetricsResponse, error)

+ GetLaunchPlan func(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.LaunchPlan, error)

+ GetNamedEntity func(ctx context.Context, in *admin.NamedEntityGetRequest, opts ...grpc.CallOption) (*admin.NamedEntity, error)

+ GetNodeExecution func(ctx context.Context, in *admin.NodeExecutionGetRequest, ...) (*admin.NodeExecution, error)

+ GetNodeExecutionData func(ctx context.Context, in *admin.NodeExecutionGetDataRequest, ...) (*admin.NodeExecutionGetDataResponse, error)

+ GetProjectAttributes func(ctx context.Context, in *admin.ProjectAttributesGetRequest, ...) (*admin.ProjectAttributesGetResponse, error)

+ GetProjectDomainAttributes func(ctx context.Context, in *admin.ProjectDomainAttributesGetRequest, ...) (*admin.ProjectDomainAttributesGetResponse, error)

+ GetTask func(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.Task, error)

+ GetTaskExecution func(ctx context.Context, in *admin.TaskExecutionGetRequest, ...) (*admin.TaskExecution, error)

+ GetTaskExecutionData func(ctx context.Context, in *admin.TaskExecutionGetDataRequest, ...) (*admin.TaskExecutionGetDataResponse, error)

+ GetVersion func(ctx context.Context, in *admin.GetVersionRequest, opts ...grpc.CallOption) (*admin.GetVersionResponse, error)

+ GetWorkflow func(ctx context.Context, in *admin.ObjectGetRequest, opts ...grpc.CallOption) (*admin.Workflow, error)

+ GetWorkflowAttributes func(ctx context.Context, in *admin.WorkflowAttributesGetRequest, ...) (*admin.WorkflowAttributesGetResponse, error)

+ ListActiveLaunchPlans func(ctx context.Context, in *admin.ActiveLaunchPlanListRequest, ...) (*admin.LaunchPlanList, error)

+ ListDescriptionEntities func(ctx context.Context, in *admin.DescriptionEntityListRequest, ...) (*admin.DescriptionEntityList, error)

+ ListExecutions func(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.ExecutionList, error)

+ ListLaunchPlanIds func(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, ...) (*admin.NamedEntityIdentifierList, error)

+ ListLaunchPlans func(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.LaunchPlanList, error)

+ ListMatchableAttributes func(ctx context.Context, in *admin.ListMatchableAttributesRequest, ...) (*admin.ListMatchableAttributesResponse, error)

+ ListNamedEntities func(ctx context.Context, in *admin.NamedEntityListRequest, opts ...grpc.CallOption) (*admin.NamedEntityList, error)

+ ListNodeExecutions func(ctx context.Context, in *admin.NodeExecutionListRequest, ...) (*admin.NodeExecutionList, error)

+ ListNodeExecutionsForTask func(ctx context.Context, in *admin.NodeExecutionForTaskListRequest, ...) (*admin.NodeExecutionList, error)

+ ListProjects func(ctx context.Context, in *admin.ProjectListRequest, opts ...grpc.CallOption) (*admin.Projects, error)

+ ListTaskExecutions func(ctx context.Context, in *admin.TaskExecutionListRequest, ...) (*admin.TaskExecutionList, error)

+ ListTaskIds func(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, ...) (*admin.NamedEntityIdentifierList, error)

+ ListTasks func(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.TaskList, error)

+ ListWorkflowIds func(ctx context.Context, in *admin.NamedEntityIdentifierListRequest, ...) (*admin.NamedEntityIdentifierList, error)

+ ListWorkflows func(ctx context.Context, in *admin.ResourceListRequest, opts ...grpc.CallOption) (*admin.WorkflowList, error)

+ RecoverExecution func(ctx context.Context, in *admin.ExecutionRecoverRequest, ...) (*admin.ExecutionCreateResponse, error)

+ RegisterProject func(ctx context.Context, in *admin.ProjectRegisterRequest, opts ...grpc.CallOption) (*admin.ProjectRegisterResponse, error)

+ RelaunchExecution func(ctx context.Context, in *admin.ExecutionRelaunchRequest, ...) (*admin.ExecutionCreateResponse, error)

+ TerminateExecution func(ctx context.Context, in *admin.ExecutionTerminateRequest, ...) (*admin.ExecutionTerminateResponse, error)

+ UpdateExecution func(ctx context.Context, in *admin.ExecutionUpdateRequest, opts ...grpc.CallOption) (*admin.ExecutionUpdateResponse, error)

+ UpdateLaunchPlan func(ctx context.Context, in *admin.LaunchPlanUpdateRequest, ...) (*admin.LaunchPlanUpdateResponse, error)

+ UpdateNamedEntity func(ctx context.Context, in *admin.NamedEntityUpdateRequest, ...) (*admin.NamedEntityUpdateResponse, error)

+ UpdateProject func(ctx context.Context, in *admin.Project, opts ...grpc.CallOption) (*admin.ProjectUpdateResponse, error)

+ UpdateProjectAttributes func(ctx context.Context, in *admin.ProjectAttributesUpdateRequest, ...) (*admin.ProjectAttributesUpdateResponse, error)

+ UpdateProjectDomainAttributes func(ctx context.Context, in *admin.ProjectDomainAttributesUpdateRequest, ...) (*admin.ProjectDomainAttributesUpdateResponse, error)

+ UpdateWorkflowAttributes func(ctx context.Context, in *admin.WorkflowAttributesUpdateRequest, ...) (*admin.WorkflowAttributesUpdateResponse, error)

+ func NewAdminServiceClient(cc *grpc.ClientConn) AdminServiceClient

+ type AdminServiceServer interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ArtifactType int32

+ const ArtifactType_ARTIFACT_TYPE_DECK

+ const ArtifactType_ARTIFACT_TYPE_UNDEFINED

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

+ func (x ArtifactType) String() string

+ type AsyncAgentServiceClient interface

+ CreateTask func(ctx context.Context, in *admin.CreateTaskRequest, opts ...grpc.CallOption) (*admin.CreateTaskResponse, error)

+ DeleteTask func(ctx context.Context, in *admin.DeleteTaskRequest, opts ...grpc.CallOption) (*admin.DeleteTaskResponse, error)

+ GetTask func(ctx context.Context, in *admin.GetTaskRequest, opts ...grpc.CallOption) (*admin.GetTaskResponse, error)

+ func NewAsyncAgentServiceClient(cc *grpc.ClientConn) AsyncAgentServiceClient

+ type AsyncAgentServiceServer interface

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

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

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

+ type AuthMetadataServiceClient interface

+ GetOAuth2Metadata func(ctx context.Context, in *OAuth2MetadataRequest, opts ...grpc.CallOption) (*OAuth2MetadataResponse, error)

+ GetPublicClientConfig func(ctx context.Context, in *PublicClientAuthConfigRequest, ...) (*PublicClientAuthConfigResponse, error)

+ func NewAuthMetadataServiceClient(cc *grpc.ClientConn) AuthMetadataServiceClient

+ type AuthMetadataServiceServer interface

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

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

+ type CreateDownloadLinkRequest struct

+ ArtifactType ArtifactType

+ ExpiresIn *duration.Duration

+ Source isCreateDownloadLinkRequest_Source

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateDownloadLinkRequest) ProtoMessage()

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

+ func (m *CreateDownloadLinkRequest) GetArtifactType() ArtifactType

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

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

+ func (m *CreateDownloadLinkRequest) GetSource() isCreateDownloadLinkRequest_Source

+ func (m *CreateDownloadLinkRequest) Reset()

+ func (m *CreateDownloadLinkRequest) String() string

+ func (m *CreateDownloadLinkRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreateDownloadLinkRequest) XXX_Size() int

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

+ type CreateDownloadLinkRequest_NodeExecutionId struct

+ NodeExecutionId *core.NodeExecutionIdentifier

+ type CreateDownloadLinkResponse struct

+ ExpiresAt *timestamp.Timestamp

+ PreSignedUrls *PreSignedURLs

+ SignedUrl []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateDownloadLinkResponse) ProtoMessage()

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

+ func (m *CreateDownloadLinkResponse) GetPreSignedUrls() *PreSignedURLs

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

+ func (m *CreateDownloadLinkResponse) Reset()

+ func (m *CreateDownloadLinkResponse) String() string

+ func (m *CreateDownloadLinkResponse) XXX_DiscardUnknown()

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

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

+ func (m *CreateDownloadLinkResponse) XXX_Size() int

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

+ type CreateDownloadLocationRequest struct

+ ExpiresIn *duration.Duration

+ NativeUrl string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateDownloadLocationRequest) ProtoMessage()

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

+ func (m *CreateDownloadLocationRequest) GetNativeUrl() string

+ func (m *CreateDownloadLocationRequest) Reset()

+ func (m *CreateDownloadLocationRequest) String() string

+ func (m *CreateDownloadLocationRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreateDownloadLocationRequest) XXX_Size() int

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

+ type CreateDownloadLocationResponse struct

+ ExpiresAt *timestamp.Timestamp

+ SignedUrl string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateDownloadLocationResponse) ProtoMessage()

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

+ func (m *CreateDownloadLocationResponse) GetSignedUrl() string

+ func (m *CreateDownloadLocationResponse) Reset()

+ func (m *CreateDownloadLocationResponse) String() string

+ func (m *CreateDownloadLocationResponse) XXX_DiscardUnknown()

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

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

+ func (m *CreateDownloadLocationResponse) XXX_Size() int

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

+ type CreateUploadLocationRequest struct

+ ContentMd5 []byte

+ Domain string

+ ExpiresIn *duration.Duration

+ Filename string

+ FilenameRoot string

+ Project string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateUploadLocationRequest) ProtoMessage()

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

+ func (m *CreateUploadLocationRequest) GetDomain() string

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

+ func (m *CreateUploadLocationRequest) GetFilename() string

+ func (m *CreateUploadLocationRequest) GetFilenameRoot() string

+ func (m *CreateUploadLocationRequest) GetProject() string

+ func (m *CreateUploadLocationRequest) Reset()

+ func (m *CreateUploadLocationRequest) String() string

+ func (m *CreateUploadLocationRequest) XXX_DiscardUnknown()

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

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

+ func (m *CreateUploadLocationRequest) XXX_Size() int

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

+ type CreateUploadLocationResponse struct

+ ExpiresAt *timestamp.Timestamp

+ NativeUrl string

+ SignedUrl string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateUploadLocationResponse) ProtoMessage()

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

+ func (m *CreateUploadLocationResponse) GetNativeUrl() string

+ func (m *CreateUploadLocationResponse) GetSignedUrl() string

+ func (m *CreateUploadLocationResponse) Reset()

+ func (m *CreateUploadLocationResponse) String() string

+ func (m *CreateUploadLocationResponse) XXX_DiscardUnknown()

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

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

+ func (m *CreateUploadLocationResponse) XXX_Size() int

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

+ type DataProxyServiceClient interface

+ CreateDownloadLink func(ctx context.Context, in *CreateDownloadLinkRequest, opts ...grpc.CallOption) (*CreateDownloadLinkResponse, error)

+ CreateDownloadLocation func(ctx context.Context, in *CreateDownloadLocationRequest, ...) (*CreateDownloadLocationResponse, error)

+ CreateUploadLocation func(ctx context.Context, in *CreateUploadLocationRequest, opts ...grpc.CallOption) (*CreateUploadLocationResponse, error)

+ GetData func(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (*GetDataResponse, error)

+ func NewDataProxyServiceClient(cc *grpc.ClientConn) DataProxyServiceClient

+ type DataProxyServiceServer interface

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

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

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

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

+ type ExternalPluginServiceClient interface

+ CreateTask func(ctx context.Context, in *TaskCreateRequest, opts ...grpc.CallOption) (*TaskCreateResponse, error)

+ DeleteTask func(ctx context.Context, in *TaskDeleteRequest, opts ...grpc.CallOption) (*TaskDeleteResponse, error)

+ GetTask func(ctx context.Context, in *TaskGetRequest, opts ...grpc.CallOption) (*TaskGetResponse, error)

+ func NewExternalPluginServiceClient(cc *grpc.ClientConn) ExternalPluginServiceClient

+ type ExternalPluginServiceServer interface

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

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

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

+ type GetDataRequest struct

+ FlyteUrl string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetDataRequest) ProtoMessage()

+ func (m *GetDataRequest) GetFlyteUrl() string

+ func (m *GetDataRequest) Reset()

+ func (m *GetDataRequest) String() string

+ func (m *GetDataRequest) XXX_DiscardUnknown()

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

+ func (m *GetDataRequest) XXX_Merge(src proto.Message)

+ func (m *GetDataRequest) XXX_Size() int

+ func (m *GetDataRequest) XXX_Unmarshal(b []byte) error

+ type GetDataResponse struct

+ Data isGetDataResponse_Data

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetDataResponse) ProtoMessage()

+ func (*GetDataResponse) XXX_OneofWrappers() []interface{}

+ func (m *GetDataResponse) GetData() isGetDataResponse_Data

+ func (m *GetDataResponse) GetLiteral() *core.Literal

+ func (m *GetDataResponse) GetLiteralMap() *core.LiteralMap

+ func (m *GetDataResponse) GetPreSignedUrls() *PreSignedURLs

+ func (m *GetDataResponse) Reset()

+ func (m *GetDataResponse) String() string

+ func (m *GetDataResponse) XXX_DiscardUnknown()

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

+ func (m *GetDataResponse) XXX_Merge(src proto.Message)

+ func (m *GetDataResponse) XXX_Size() int

+ func (m *GetDataResponse) XXX_Unmarshal(b []byte) error

+ type GetDataResponse_Literal struct

+ Literal *core.Literal

+ type GetDataResponse_LiteralMap struct

+ LiteralMap *core.LiteralMap

+ type GetDataResponse_PreSignedUrls struct

+ PreSignedUrls *PreSignedURLs

+ type IdentityServiceClient interface

+ UserInfo func(ctx context.Context, in *UserInfoRequest, opts ...grpc.CallOption) (*UserInfoResponse, error)

+ func NewIdentityServiceClient(cc *grpc.ClientConn) IdentityServiceClient

+ type IdentityServiceServer interface

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

+ type OAuth2MetadataRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*OAuth2MetadataRequest) ProtoMessage()

+ func (m *OAuth2MetadataRequest) Reset()

+ func (m *OAuth2MetadataRequest) String() string

+ func (m *OAuth2MetadataRequest) XXX_DiscardUnknown()

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

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

+ func (m *OAuth2MetadataRequest) XXX_Size() int

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

+ type OAuth2MetadataResponse struct

+ AuthorizationEndpoint string

+ CodeChallengeMethodsSupported []string

+ DeviceAuthorizationEndpoint string

+ GrantTypesSupported []string

+ Issuer string

+ JwksUri string

+ ResponseTypesSupported []string

+ ScopesSupported []string

+ TokenEndpoint string

+ TokenEndpointAuthMethodsSupported []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*OAuth2MetadataResponse) ProtoMessage()

+ func (m *OAuth2MetadataResponse) GetAuthorizationEndpoint() string

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

+ func (m *OAuth2MetadataResponse) GetDeviceAuthorizationEndpoint() string

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

+ func (m *OAuth2MetadataResponse) GetIssuer() string

+ func (m *OAuth2MetadataResponse) GetJwksUri() string

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

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

+ func (m *OAuth2MetadataResponse) GetTokenEndpoint() string

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

+ func (m *OAuth2MetadataResponse) Reset()

+ func (m *OAuth2MetadataResponse) String() string

+ func (m *OAuth2MetadataResponse) XXX_DiscardUnknown()

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

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

+ func (m *OAuth2MetadataResponse) XXX_Size() int

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

+ type PreSignedURLs struct

+ ExpiresAt *timestamp.Timestamp

+ SignedUrl []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PreSignedURLs) ProtoMessage()

+ func (m *PreSignedURLs) GetExpiresAt() *timestamp.Timestamp

+ func (m *PreSignedURLs) GetSignedUrl() []string

+ func (m *PreSignedURLs) Reset()

+ func (m *PreSignedURLs) String() string

+ func (m *PreSignedURLs) XXX_DiscardUnknown()

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

+ func (m *PreSignedURLs) XXX_Merge(src proto.Message)

+ func (m *PreSignedURLs) XXX_Size() int

+ func (m *PreSignedURLs) XXX_Unmarshal(b []byte) error

+ type PublicClientAuthConfigRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PublicClientAuthConfigRequest) ProtoMessage()

+ func (m *PublicClientAuthConfigRequest) Reset()

+ func (m *PublicClientAuthConfigRequest) String() string

+ func (m *PublicClientAuthConfigRequest) XXX_DiscardUnknown()

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

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

+ func (m *PublicClientAuthConfigRequest) XXX_Size() int

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

+ type PublicClientAuthConfigResponse struct

+ Audience string

+ AuthorizationMetadataKey string

+ ClientId string

+ RedirectUri string

+ Scopes []string

+ ServiceHttpEndpoint string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PublicClientAuthConfigResponse) ProtoMessage()

+ func (m *PublicClientAuthConfigResponse) GetAudience() string

+ func (m *PublicClientAuthConfigResponse) GetAuthorizationMetadataKey() string

+ func (m *PublicClientAuthConfigResponse) GetClientId() string

+ func (m *PublicClientAuthConfigResponse) GetRedirectUri() string

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

+ func (m *PublicClientAuthConfigResponse) GetServiceHttpEndpoint() string

+ func (m *PublicClientAuthConfigResponse) Reset()

+ func (m *PublicClientAuthConfigResponse) String() string

+ func (m *PublicClientAuthConfigResponse) XXX_DiscardUnknown()

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

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

+ func (m *PublicClientAuthConfigResponse) XXX_Size() int

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

+ type SignalServiceClient interface

+ GetOrCreateSignal func(ctx context.Context, in *admin.SignalGetOrCreateRequest, ...) (*admin.Signal, error)

+ ListSignals func(ctx context.Context, in *admin.SignalListRequest, opts ...grpc.CallOption) (*admin.SignalList, error)

+ SetSignal func(ctx context.Context, in *admin.SignalSetRequest, opts ...grpc.CallOption) (*admin.SignalSetResponse, error)

+ func NewSignalServiceClient(cc *grpc.ClientConn) SignalServiceClient

+ type SignalServiceServer interface

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

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

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

+ type State int32

+ const State_PENDING

+ const State_PERMANENT_FAILURE

+ const State_RETRYABLE_FAILURE

+ const State_RUNNING

+ const State_SUCCEEDED

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

+ func (x State) String() string

+ type TaskCreateRequest struct

+ Inputs *core.LiteralMap

+ OutputPrefix string

+ Template *core.TaskTemplate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskCreateRequest) ProtoMessage()

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

+ func (m *TaskCreateRequest) GetOutputPrefix() string

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

+ func (m *TaskCreateRequest) Reset()

+ func (m *TaskCreateRequest) String() string

+ func (m *TaskCreateRequest) XXX_DiscardUnknown()

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

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

+ func (m *TaskCreateRequest) XXX_Size() int

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

+ type TaskCreateResponse struct

+ JobId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskCreateResponse) ProtoMessage()

+ func (m *TaskCreateResponse) GetJobId() string

+ func (m *TaskCreateResponse) Reset()

+ func (m *TaskCreateResponse) String() string

+ func (m *TaskCreateResponse) XXX_DiscardUnknown()

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

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

+ func (m *TaskCreateResponse) XXX_Size() int

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

+ type TaskDeleteRequest struct

+ JobId string

+ TaskType string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskDeleteRequest) ProtoMessage()

+ func (m *TaskDeleteRequest) GetJobId() string

+ func (m *TaskDeleteRequest) GetTaskType() string

+ func (m *TaskDeleteRequest) Reset()

+ func (m *TaskDeleteRequest) String() string

+ func (m *TaskDeleteRequest) XXX_DiscardUnknown()

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

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

+ func (m *TaskDeleteRequest) XXX_Size() int

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

+ type TaskDeleteResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskDeleteResponse) ProtoMessage()

+ func (m *TaskDeleteResponse) Reset()

+ func (m *TaskDeleteResponse) String() string

+ func (m *TaskDeleteResponse) XXX_DiscardUnknown()

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

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

+ func (m *TaskDeleteResponse) XXX_Size() int

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

+ type TaskGetRequest struct

+ JobId string

+ TaskType string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskGetRequest) ProtoMessage()

+ func (m *TaskGetRequest) GetJobId() string

+ func (m *TaskGetRequest) GetTaskType() string

+ func (m *TaskGetRequest) Reset()

+ func (m *TaskGetRequest) String() string

+ func (m *TaskGetRequest) XXX_DiscardUnknown()

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

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

+ func (m *TaskGetRequest) XXX_Size() int

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

+ type TaskGetResponse struct

+ Outputs *core.LiteralMap

+ State State

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskGetResponse) ProtoMessage()

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

+ func (m *TaskGetResponse) GetState() State

+ func (m *TaskGetResponse) Reset()

+ func (m *TaskGetResponse) String() string

+ func (m *TaskGetResponse) XXX_DiscardUnknown()

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

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

+ func (m *TaskGetResponse) XXX_Size() int

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

+ type UnimplementedAdminServiceServer struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type UnimplementedAsyncAgentServiceServer struct

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

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

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

+ type UnimplementedAuthMetadataServiceServer struct

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

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

+ type UnimplementedDataProxyServiceServer struct

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

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

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

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

+ type UnimplementedExternalPluginServiceServer struct

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

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

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

+ type UnimplementedIdentityServiceServer struct

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

+ type UnimplementedSignalServiceServer struct

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

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

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

+ type UserInfoRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UserInfoRequest) ProtoMessage()

+ func (m *UserInfoRequest) Reset()

+ func (m *UserInfoRequest) String() string

+ func (m *UserInfoRequest) XXX_DiscardUnknown()

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

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

+ func (m *UserInfoRequest) XXX_Size() int

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

+ type UserInfoResponse struct

+ AdditionalClaims *_struct.Struct

+ Email string

+ FamilyName string

+ GivenName string

+ Name string

+ Picture string

+ PreferredUsername string

+ Subject string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UserInfoResponse) ProtoMessage()

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

+ func (m *UserInfoResponse) GetEmail() string

+ func (m *UserInfoResponse) GetFamilyName() string

+ func (m *UserInfoResponse) GetGivenName() string

+ func (m *UserInfoResponse) GetName() string

+ func (m *UserInfoResponse) GetPicture() string

+ func (m *UserInfoResponse) GetPreferredUsername() string

+ func (m *UserInfoResponse) GetSubject() string

+ func (m *UserInfoResponse) Reset()

+ func (m *UserInfoResponse) String() string

+ func (m *UserInfoResponse) XXX_DiscardUnknown()

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

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

+ func (m *UserInfoResponse) XXX_Size() int

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