Documentation
¶
Index ¶
- Variables
- func RegisterBackupServiceServer(s grpc.ServiceRegistrar, srv BackupServiceServer)
- func RegisterJobRunServiceServer(s grpc.ServiceRegistrar, srv JobRunServiceServer)
- func RegisterJobSpecificationServiceServer(s grpc.ServiceRegistrar, srv JobSpecificationServiceServer)
- func RegisterNamespaceServiceServer(s grpc.ServiceRegistrar, srv NamespaceServiceServer)
- func RegisterProjectServiceServer(s grpc.ServiceRegistrar, srv ProjectServiceServer)
- func RegisterReplayServiceServer(s grpc.ServiceRegistrar, srv ReplayServiceServer)
- func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)
- func RegisterRuntimeServiceServer(s grpc.ServiceRegistrar, srv RuntimeServiceServer)
- func RegisterSecretServiceServer(s grpc.ServiceRegistrar, srv SecretServiceServer)
- type BackupServiceClient
- type BackupServiceServer
- type JobRunServiceClient
- type JobRunServiceServer
- type JobSpecificationServiceClient
- type JobSpecificationServiceServer
- type JobSpecificationService_CheckJobSpecificationsClient
- type JobSpecificationService_CheckJobSpecificationsServer
- type JobSpecificationService_DeployJobSpecificationClient
- type JobSpecificationService_DeployJobSpecificationServer
- type JobSpecificationService_RefreshJobsClient
- type JobSpecificationService_RefreshJobsServer
- type NamespaceServiceClient
- type NamespaceServiceServer
- type ProjectServiceClient
- type ProjectServiceServer
- type ReplayServiceClient
- type ReplayServiceServer
- type ResourceServiceClient
- type ResourceServiceServer
- type ResourceService_DeployResourceSpecificationClient
- type ResourceService_DeployResourceSpecificationServer
- type RuntimeServiceClient
- type RuntimeServiceServer
- type SecretServiceClient
- type SecretServiceServer
- type UnimplementedBackupServiceServer
- func (UnimplementedBackupServiceServer) BackupDryRun(context.Context, *v1beta1.BackupDryRunRequest) (*v1beta1.BackupDryRunResponse, error)
- func (UnimplementedBackupServiceServer) CreateBackup(context.Context, *v1beta1.CreateBackupRequest) (*v1beta1.CreateBackupResponse, error)
- func (UnimplementedBackupServiceServer) GetBackup(context.Context, *v1beta1.GetBackupRequest) (*v1beta1.GetBackupResponse, error)
- func (UnimplementedBackupServiceServer) ListBackups(context.Context, *v1beta1.ListBackupsRequest) (*v1beta1.ListBackupsResponse, error)
- type UnimplementedJobRunServiceServer
- func (UnimplementedJobRunServiceServer) GetJobTask(context.Context, *v1beta1.GetJobTaskRequest) (*v1beta1.GetJobTaskResponse, error)
- func (UnimplementedJobRunServiceServer) GetWindow(context.Context, *v1beta1.GetWindowRequest) (*v1beta1.GetWindowResponse, error)
- func (UnimplementedJobRunServiceServer) JobRun(context.Context, *v1beta1.JobRunRequest) (*v1beta1.JobRunResponse, error)
- func (UnimplementedJobRunServiceServer) JobStatus(context.Context, *v1beta1.JobStatusRequest) (*v1beta1.JobStatusResponse, error)
- func (UnimplementedJobRunServiceServer) RegisterInstance(context.Context, *v1beta1.RegisterInstanceRequest) (*v1beta1.RegisterInstanceResponse, error)
- func (UnimplementedJobRunServiceServer) RunJob(context.Context, *v1beta1.RunJobRequest) (*v1beta1.RunJobResponse, error)
- type UnimplementedJobSpecificationServiceServer
- func (UnimplementedJobSpecificationServiceServer) CheckJobSpecification(context.Context, *v1beta1.CheckJobSpecificationRequest) (*v1beta1.CheckJobSpecificationResponse, error)
- func (UnimplementedJobSpecificationServiceServer) CheckJobSpecifications(*v1beta1.CheckJobSpecificationsRequest, ...) error
- func (UnimplementedJobSpecificationServiceServer) CreateJobSpecification(context.Context, *v1beta1.CreateJobSpecificationRequest) (*v1beta1.CreateJobSpecificationResponse, error)
- func (UnimplementedJobSpecificationServiceServer) DeleteJobSpecification(context.Context, *v1beta1.DeleteJobSpecificationRequest) (*v1beta1.DeleteJobSpecificationResponse, error)
- func (UnimplementedJobSpecificationServiceServer) DeployJobSpecification(JobSpecificationService_DeployJobSpecificationServer) error
- func (UnimplementedJobSpecificationServiceServer) GetJobSpecification(context.Context, *v1beta1.GetJobSpecificationRequest) (*v1beta1.GetJobSpecificationResponse, error)
- func (UnimplementedJobSpecificationServiceServer) ListJobSpecification(context.Context, *v1beta1.ListJobSpecificationRequest) (*v1beta1.ListJobSpecificationResponse, error)
- func (UnimplementedJobSpecificationServiceServer) RefreshJobs(*v1beta1.RefreshJobsRequest, JobSpecificationService_RefreshJobsServer) error
- type UnimplementedNamespaceServiceServer
- func (UnimplementedNamespaceServiceServer) ListProjectNamespaces(context.Context, *v1beta1.ListProjectNamespacesRequest) (*v1beta1.ListProjectNamespacesResponse, error)
- func (UnimplementedNamespaceServiceServer) RegisterProjectNamespace(context.Context, *v1beta1.RegisterProjectNamespaceRequest) (*v1beta1.RegisterProjectNamespaceResponse, error)
- type UnimplementedProjectServiceServer
- type UnimplementedReplayServiceServer
- func (UnimplementedReplayServiceServer) GetReplayStatus(context.Context, *v1beta1.GetReplayStatusRequest) (*v1beta1.GetReplayStatusResponse, error)
- func (UnimplementedReplayServiceServer) ListReplays(context.Context, *v1beta1.ListReplaysRequest) (*v1beta1.ListReplaysResponse, error)
- func (UnimplementedReplayServiceServer) Replay(context.Context, *v1beta1.ReplayRequest) (*v1beta1.ReplayResponse, error)
- func (UnimplementedReplayServiceServer) ReplayDryRun(context.Context, *v1beta1.ReplayDryRunRequest) (*v1beta1.ReplayDryRunResponse, error)
- type UnimplementedResourceServiceServer
- func (UnimplementedResourceServiceServer) CreateResource(context.Context, *v1beta1.CreateResourceRequest) (*v1beta1.CreateResourceResponse, error)
- func (UnimplementedResourceServiceServer) DeployResourceSpecification(ResourceService_DeployResourceSpecificationServer) error
- func (UnimplementedResourceServiceServer) ListResourceSpecification(context.Context, *v1beta1.ListResourceSpecificationRequest) (*v1beta1.ListResourceSpecificationResponse, error)
- func (UnimplementedResourceServiceServer) ReadResource(context.Context, *v1beta1.ReadResourceRequest) (*v1beta1.ReadResourceResponse, error)
- func (UnimplementedResourceServiceServer) UpdateResource(context.Context, *v1beta1.UpdateResourceRequest) (*v1beta1.UpdateResourceResponse, error)
- type UnimplementedRuntimeServiceServer
- type UnimplementedSecretServiceServer
- func (UnimplementedSecretServiceServer) DeleteSecret(context.Context, *v1beta1.DeleteSecretRequest) (*v1beta1.DeleteSecretResponse, error)
- func (UnimplementedSecretServiceServer) ListSecrets(context.Context, *v1beta1.ListSecretsRequest) (*v1beta1.ListSecretsResponse, error)
- func (UnimplementedSecretServiceServer) RegisterSecret(context.Context, *v1beta1.RegisterSecretRequest) (*v1beta1.RegisterSecretResponse, error)
- func (UnimplementedSecretServiceServer) UpdateSecret(context.Context, *v1beta1.UpdateSecretRequest) (*v1beta1.UpdateSecretResponse, error)
- type UnsafeBackupServiceServer
- type UnsafeJobRunServiceServer
- type UnsafeJobSpecificationServiceServer
- type UnsafeNamespaceServiceServer
- type UnsafeProjectServiceServer
- type UnsafeReplayServiceServer
- type UnsafeResourceServiceServer
- type UnsafeRuntimeServiceServer
- type UnsafeSecretServiceServer
Constants ¶
This section is empty.
Variables ¶
var BackupService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "odpf.optimus.core.v1beta1.BackupService", HandlerType: (*BackupServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "BackupDryRun", Handler: _BackupService_BackupDryRun_Handler, }, { MethodName: "CreateBackup", Handler: _BackupService_CreateBackup_Handler, }, { MethodName: "ListBackups", Handler: _BackupService_ListBackups_Handler, }, { MethodName: "GetBackup", Handler: _BackupService_GetBackup_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "odpf/optimus/core/v1beta1/backup.proto", }
BackupService_ServiceDesc is the grpc.ServiceDesc for BackupService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var JobRunService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "odpf.optimus.core.v1beta1.JobRunService", HandlerType: (*JobRunServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetJobTask", Handler: _JobRunService_GetJobTask_Handler, }, { MethodName: "RegisterInstance", Handler: _JobRunService_RegisterInstance_Handler, }, { MethodName: "JobStatus", Handler: _JobRunService_JobStatus_Handler, }, { MethodName: "JobRun", Handler: _JobRunService_JobRun_Handler, }, { MethodName: "GetWindow", Handler: _JobRunService_GetWindow_Handler, }, { MethodName: "RunJob", Handler: _JobRunService_RunJob_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "odpf/optimus/core/v1beta1/job_run.proto", }
JobRunService_ServiceDesc is the grpc.ServiceDesc for JobRunService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var JobSpecificationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "odpf.optimus.core.v1beta1.JobSpecificationService", HandlerType: (*JobSpecificationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateJobSpecification", Handler: _JobSpecificationService_CreateJobSpecification_Handler, }, { MethodName: "GetJobSpecification", Handler: _JobSpecificationService_GetJobSpecification_Handler, }, { MethodName: "DeleteJobSpecification", Handler: _JobSpecificationService_DeleteJobSpecification_Handler, }, { MethodName: "ListJobSpecification", Handler: _JobSpecificationService_ListJobSpecification_Handler, }, { MethodName: "CheckJobSpecification", Handler: _JobSpecificationService_CheckJobSpecification_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "DeployJobSpecification", Handler: _JobSpecificationService_DeployJobSpecification_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "CheckJobSpecifications", Handler: _JobSpecificationService_CheckJobSpecifications_Handler, ServerStreams: true, }, { StreamName: "RefreshJobs", Handler: _JobSpecificationService_RefreshJobs_Handler, ServerStreams: true, }, }, Metadata: "odpf/optimus/core/v1beta1/job_spec.proto", }
JobSpecificationService_ServiceDesc is the grpc.ServiceDesc for JobSpecificationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var NamespaceService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "odpf.optimus.core.v1beta1.NamespaceService", HandlerType: (*NamespaceServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterProjectNamespace", Handler: _NamespaceService_RegisterProjectNamespace_Handler, }, { MethodName: "ListProjectNamespaces", Handler: _NamespaceService_ListProjectNamespaces_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "odpf/optimus/core/v1beta1/namespace.proto", }
NamespaceService_ServiceDesc is the grpc.ServiceDesc for NamespaceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ProjectService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "odpf.optimus.core.v1beta1.ProjectService", HandlerType: (*ProjectServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterProject", Handler: _ProjectService_RegisterProject_Handler, }, { MethodName: "ListProjects", Handler: _ProjectService_ListProjects_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "odpf/optimus/core/v1beta1/project.proto", }
ProjectService_ServiceDesc is the grpc.ServiceDesc for ProjectService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ReplayService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "odpf.optimus.core.v1beta1.ReplayService", HandlerType: (*ReplayServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ReplayDryRun", Handler: _ReplayService_ReplayDryRun_Handler, }, { MethodName: "Replay", Handler: _ReplayService_Replay_Handler, }, { MethodName: "GetReplayStatus", Handler: _ReplayService_GetReplayStatus_Handler, }, { MethodName: "ListReplays", Handler: _ReplayService_ListReplays_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "odpf/optimus/core/v1beta1/replay.proto", }
ReplayService_ServiceDesc is the grpc.ServiceDesc for ReplayService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ResourceService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "odpf.optimus.core.v1beta1.ResourceService", HandlerType: (*ResourceServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListResourceSpecification", Handler: _ResourceService_ListResourceSpecification_Handler, }, { MethodName: "CreateResource", Handler: _ResourceService_CreateResource_Handler, }, { MethodName: "ReadResource", Handler: _ResourceService_ReadResource_Handler, }, { MethodName: "UpdateResource", Handler: _ResourceService_UpdateResource_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "DeployResourceSpecification", Handler: _ResourceService_DeployResourceSpecification_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "odpf/optimus/core/v1beta1/resource.proto", }
ResourceService_ServiceDesc is the grpc.ServiceDesc for ResourceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var RuntimeService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "odpf.optimus.core.v1beta1.RuntimeService", HandlerType: (*RuntimeServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Version", Handler: _RuntimeService_Version_Handler, }, { MethodName: "RegisterJobEvent", Handler: _RuntimeService_RegisterJobEvent_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "odpf/optimus/core/v1beta1/runtime.proto", }
RuntimeService_ServiceDesc is the grpc.ServiceDesc for RuntimeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SecretService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "odpf.optimus.core.v1beta1.SecretService", HandlerType: (*SecretServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterSecret", Handler: _SecretService_RegisterSecret_Handler, }, { MethodName: "UpdateSecret", Handler: _SecretService_UpdateSecret_Handler, }, { MethodName: "ListSecrets", Handler: _SecretService_ListSecrets_Handler, }, { MethodName: "DeleteSecret", Handler: _SecretService_DeleteSecret_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "odpf/optimus/core/v1beta1/secret.proto", }
SecretService_ServiceDesc is the grpc.ServiceDesc for SecretService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterBackupServiceServer ¶
func RegisterBackupServiceServer(s grpc.ServiceRegistrar, srv BackupServiceServer)
func RegisterJobRunServiceServer ¶
func RegisterJobRunServiceServer(s grpc.ServiceRegistrar, srv JobRunServiceServer)
func RegisterJobSpecificationServiceServer ¶
func RegisterJobSpecificationServiceServer(s grpc.ServiceRegistrar, srv JobSpecificationServiceServer)
func RegisterNamespaceServiceServer ¶
func RegisterNamespaceServiceServer(s grpc.ServiceRegistrar, srv NamespaceServiceServer)
func RegisterProjectServiceServer ¶
func RegisterProjectServiceServer(s grpc.ServiceRegistrar, srv ProjectServiceServer)
func RegisterReplayServiceServer ¶
func RegisterReplayServiceServer(s grpc.ServiceRegistrar, srv ReplayServiceServer)
func RegisterResourceServiceServer ¶
func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)
func RegisterRuntimeServiceServer ¶
func RegisterRuntimeServiceServer(s grpc.ServiceRegistrar, srv RuntimeServiceServer)
func RegisterSecretServiceServer ¶
func RegisterSecretServiceServer(s grpc.ServiceRegistrar, srv SecretServiceServer)
Types ¶
type BackupServiceClient ¶
type BackupServiceClient interface { BackupDryRun(ctx context.Context, in *v1beta1.BackupDryRunRequest, opts ...grpc.CallOption) (*v1beta1.BackupDryRunResponse, error) CreateBackup(ctx context.Context, in *v1beta1.CreateBackupRequest, opts ...grpc.CallOption) (*v1beta1.CreateBackupResponse, error) ListBackups(ctx context.Context, in *v1beta1.ListBackupsRequest, opts ...grpc.CallOption) (*v1beta1.ListBackupsResponse, error) GetBackup(ctx context.Context, in *v1beta1.GetBackupRequest, opts ...grpc.CallOption) (*v1beta1.GetBackupResponse, error) }
BackupServiceClient is the client API for BackupService 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 NewBackupServiceClient ¶
func NewBackupServiceClient(cc grpc.ClientConnInterface) BackupServiceClient
type BackupServiceServer ¶
type BackupServiceServer interface { BackupDryRun(context.Context, *v1beta1.BackupDryRunRequest) (*v1beta1.BackupDryRunResponse, error) CreateBackup(context.Context, *v1beta1.CreateBackupRequest) (*v1beta1.CreateBackupResponse, error) ListBackups(context.Context, *v1beta1.ListBackupsRequest) (*v1beta1.ListBackupsResponse, error) GetBackup(context.Context, *v1beta1.GetBackupRequest) (*v1beta1.GetBackupResponse, error) }
BackupServiceServer is the server API for BackupService service. All implementations should embed UnimplementedBackupServiceServer for forward compatibility
type JobRunServiceClient ¶
type JobRunServiceClient interface { GetJobTask(ctx context.Context, in *v1beta1.GetJobTaskRequest, opts ...grpc.CallOption) (*v1beta1.GetJobTaskResponse, error) RegisterInstance(ctx context.Context, in *v1beta1.RegisterInstanceRequest, opts ...grpc.CallOption) (*v1beta1.RegisterInstanceResponse, error) JobStatus(ctx context.Context, in *v1beta1.JobStatusRequest, opts ...grpc.CallOption) (*v1beta1.JobStatusResponse, error) JobRun(ctx context.Context, in *v1beta1.JobRunRequest, opts ...grpc.CallOption) (*v1beta1.JobRunResponse, error) GetWindow(ctx context.Context, in *v1beta1.GetWindowRequest, opts ...grpc.CallOption) (*v1beta1.GetWindowResponse, error) RunJob(ctx context.Context, in *v1beta1.RunJobRequest, opts ...grpc.CallOption) (*v1beta1.RunJobResponse, error) }
JobRunServiceClient is the client API for JobRunService 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 NewJobRunServiceClient ¶
func NewJobRunServiceClient(cc grpc.ClientConnInterface) JobRunServiceClient
type JobRunServiceServer ¶
type JobRunServiceServer interface { GetJobTask(context.Context, *v1beta1.GetJobTaskRequest) (*v1beta1.GetJobTaskResponse, error) RegisterInstance(context.Context, *v1beta1.RegisterInstanceRequest) (*v1beta1.RegisterInstanceResponse, error) JobStatus(context.Context, *v1beta1.JobStatusRequest) (*v1beta1.JobStatusResponse, error) JobRun(context.Context, *v1beta1.JobRunRequest) (*v1beta1.JobRunResponse, error) GetWindow(context.Context, *v1beta1.GetWindowRequest) (*v1beta1.GetWindowResponse, error) RunJob(context.Context, *v1beta1.RunJobRequest) (*v1beta1.RunJobResponse, error) }
JobRunServiceServer is the server API for JobRunService service. All implementations should embed UnimplementedJobRunServiceServer for forward compatibility
type JobSpecificationServiceClient ¶
type JobSpecificationServiceClient interface { DeployJobSpecification(ctx context.Context, opts ...grpc.CallOption) (JobSpecificationService_DeployJobSpecificationClient, error) CreateJobSpecification(ctx context.Context, in *v1beta1.CreateJobSpecificationRequest, opts ...grpc.CallOption) (*v1beta1.CreateJobSpecificationResponse, error) GetJobSpecification(ctx context.Context, in *v1beta1.GetJobSpecificationRequest, opts ...grpc.CallOption) (*v1beta1.GetJobSpecificationResponse, error) DeleteJobSpecification(ctx context.Context, in *v1beta1.DeleteJobSpecificationRequest, opts ...grpc.CallOption) (*v1beta1.DeleteJobSpecificationResponse, error) ListJobSpecification(ctx context.Context, in *v1beta1.ListJobSpecificationRequest, opts ...grpc.CallOption) (*v1beta1.ListJobSpecificationResponse, error) CheckJobSpecification(ctx context.Context, in *v1beta1.CheckJobSpecificationRequest, opts ...grpc.CallOption) (*v1beta1.CheckJobSpecificationResponse, error) CheckJobSpecifications(ctx context.Context, in *v1beta1.CheckJobSpecificationsRequest, opts ...grpc.CallOption) (JobSpecificationService_CheckJobSpecificationsClient, error) RefreshJobs(ctx context.Context, in *v1beta1.RefreshJobsRequest, opts ...grpc.CallOption) (JobSpecificationService_RefreshJobsClient, error) }
JobSpecificationServiceClient is the client API for JobSpecificationService 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 NewJobSpecificationServiceClient ¶
func NewJobSpecificationServiceClient(cc grpc.ClientConnInterface) JobSpecificationServiceClient
type JobSpecificationServiceServer ¶
type JobSpecificationServiceServer interface { DeployJobSpecification(JobSpecificationService_DeployJobSpecificationServer) error CreateJobSpecification(context.Context, *v1beta1.CreateJobSpecificationRequest) (*v1beta1.CreateJobSpecificationResponse, error) GetJobSpecification(context.Context, *v1beta1.GetJobSpecificationRequest) (*v1beta1.GetJobSpecificationResponse, error) DeleteJobSpecification(context.Context, *v1beta1.DeleteJobSpecificationRequest) (*v1beta1.DeleteJobSpecificationResponse, error) ListJobSpecification(context.Context, *v1beta1.ListJobSpecificationRequest) (*v1beta1.ListJobSpecificationResponse, error) CheckJobSpecification(context.Context, *v1beta1.CheckJobSpecificationRequest) (*v1beta1.CheckJobSpecificationResponse, error) CheckJobSpecifications(*v1beta1.CheckJobSpecificationsRequest, JobSpecificationService_CheckJobSpecificationsServer) error RefreshJobs(*v1beta1.RefreshJobsRequest, JobSpecificationService_RefreshJobsServer) error }
JobSpecificationServiceServer is the server API for JobSpecificationService service. All implementations should embed UnimplementedJobSpecificationServiceServer for forward compatibility
type JobSpecificationService_CheckJobSpecificationsClient ¶
type JobSpecificationService_CheckJobSpecificationsClient interface { Recv() (*v1beta1.CheckJobSpecificationsResponse, error) grpc.ClientStream }
type JobSpecificationService_CheckJobSpecificationsServer ¶
type JobSpecificationService_CheckJobSpecificationsServer interface { Send(*v1beta1.CheckJobSpecificationsResponse) error grpc.ServerStream }
type JobSpecificationService_DeployJobSpecificationClient ¶
type JobSpecificationService_DeployJobSpecificationClient interface { Send(*v1beta1.DeployJobSpecificationRequest) error Recv() (*v1beta1.DeployJobSpecificationResponse, error) grpc.ClientStream }
type JobSpecificationService_DeployJobSpecificationServer ¶
type JobSpecificationService_DeployJobSpecificationServer interface { Send(*v1beta1.DeployJobSpecificationResponse) error Recv() (*v1beta1.DeployJobSpecificationRequest, error) grpc.ServerStream }
type JobSpecificationService_RefreshJobsClient ¶
type JobSpecificationService_RefreshJobsClient interface { Recv() (*v1beta1.RefreshJobsResponse, error) grpc.ClientStream }
type JobSpecificationService_RefreshJobsServer ¶
type JobSpecificationService_RefreshJobsServer interface { Send(*v1beta1.RefreshJobsResponse) error grpc.ServerStream }
type NamespaceServiceClient ¶
type NamespaceServiceClient interface { RegisterProjectNamespace(ctx context.Context, in *v1beta1.RegisterProjectNamespaceRequest, opts ...grpc.CallOption) (*v1beta1.RegisterProjectNamespaceResponse, error) ListProjectNamespaces(ctx context.Context, in *v1beta1.ListProjectNamespacesRequest, opts ...grpc.CallOption) (*v1beta1.ListProjectNamespacesResponse, error) }
NamespaceServiceClient is the client API for NamespaceService 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 NewNamespaceServiceClient ¶
func NewNamespaceServiceClient(cc grpc.ClientConnInterface) NamespaceServiceClient
type NamespaceServiceServer ¶
type NamespaceServiceServer interface { RegisterProjectNamespace(context.Context, *v1beta1.RegisterProjectNamespaceRequest) (*v1beta1.RegisterProjectNamespaceResponse, error) ListProjectNamespaces(context.Context, *v1beta1.ListProjectNamespacesRequest) (*v1beta1.ListProjectNamespacesResponse, error) }
NamespaceServiceServer is the server API for NamespaceService service. All implementations should embed UnimplementedNamespaceServiceServer for forward compatibility
type ProjectServiceClient ¶
type ProjectServiceClient interface { RegisterProject(ctx context.Context, in *v1beta1.RegisterProjectRequest, opts ...grpc.CallOption) (*v1beta1.RegisterProjectResponse, error) ListProjects(ctx context.Context, in *v1beta1.ListProjectsRequest, opts ...grpc.CallOption) (*v1beta1.ListProjectsResponse, error) }
ProjectServiceClient is the client API for ProjectService 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 NewProjectServiceClient ¶
func NewProjectServiceClient(cc grpc.ClientConnInterface) ProjectServiceClient
type ProjectServiceServer ¶
type ProjectServiceServer interface { RegisterProject(context.Context, *v1beta1.RegisterProjectRequest) (*v1beta1.RegisterProjectResponse, error) ListProjects(context.Context, *v1beta1.ListProjectsRequest) (*v1beta1.ListProjectsResponse, error) }
ProjectServiceServer is the server API for ProjectService service. All implementations should embed UnimplementedProjectServiceServer for forward compatibility
type ReplayServiceClient ¶
type ReplayServiceClient interface { ReplayDryRun(ctx context.Context, in *v1beta1.ReplayDryRunRequest, opts ...grpc.CallOption) (*v1beta1.ReplayDryRunResponse, error) Replay(ctx context.Context, in *v1beta1.ReplayRequest, opts ...grpc.CallOption) (*v1beta1.ReplayResponse, error) GetReplayStatus(ctx context.Context, in *v1beta1.GetReplayStatusRequest, opts ...grpc.CallOption) (*v1beta1.GetReplayStatusResponse, error) ListReplays(ctx context.Context, in *v1beta1.ListReplaysRequest, opts ...grpc.CallOption) (*v1beta1.ListReplaysResponse, error) }
ReplayServiceClient is the client API for ReplayService 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 NewReplayServiceClient ¶
func NewReplayServiceClient(cc grpc.ClientConnInterface) ReplayServiceClient
type ReplayServiceServer ¶
type ReplayServiceServer interface { ReplayDryRun(context.Context, *v1beta1.ReplayDryRunRequest) (*v1beta1.ReplayDryRunResponse, error) Replay(context.Context, *v1beta1.ReplayRequest) (*v1beta1.ReplayResponse, error) GetReplayStatus(context.Context, *v1beta1.GetReplayStatusRequest) (*v1beta1.GetReplayStatusResponse, error) ListReplays(context.Context, *v1beta1.ListReplaysRequest) (*v1beta1.ListReplaysResponse, error) }
ReplayServiceServer is the server API for ReplayService service. All implementations should embed UnimplementedReplayServiceServer for forward compatibility
type ResourceServiceClient ¶
type ResourceServiceClient interface { DeployResourceSpecification(ctx context.Context, opts ...grpc.CallOption) (ResourceService_DeployResourceSpecificationClient, error) ListResourceSpecification(ctx context.Context, in *v1beta1.ListResourceSpecificationRequest, opts ...grpc.CallOption) (*v1beta1.ListResourceSpecificationResponse, error) CreateResource(ctx context.Context, in *v1beta1.CreateResourceRequest, opts ...grpc.CallOption) (*v1beta1.CreateResourceResponse, error) ReadResource(ctx context.Context, in *v1beta1.ReadResourceRequest, opts ...grpc.CallOption) (*v1beta1.ReadResourceResponse, error) UpdateResource(ctx context.Context, in *v1beta1.UpdateResourceRequest, opts ...grpc.CallOption) (*v1beta1.UpdateResourceResponse, error) }
ResourceServiceClient is the client API for ResourceService 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 NewResourceServiceClient ¶
func NewResourceServiceClient(cc grpc.ClientConnInterface) ResourceServiceClient
type ResourceServiceServer ¶
type ResourceServiceServer interface { DeployResourceSpecification(ResourceService_DeployResourceSpecificationServer) error ListResourceSpecification(context.Context, *v1beta1.ListResourceSpecificationRequest) (*v1beta1.ListResourceSpecificationResponse, error) CreateResource(context.Context, *v1beta1.CreateResourceRequest) (*v1beta1.CreateResourceResponse, error) ReadResource(context.Context, *v1beta1.ReadResourceRequest) (*v1beta1.ReadResourceResponse, error) UpdateResource(context.Context, *v1beta1.UpdateResourceRequest) (*v1beta1.UpdateResourceResponse, error) }
ResourceServiceServer is the server API for ResourceService service. All implementations should embed UnimplementedResourceServiceServer for forward compatibility
type ResourceService_DeployResourceSpecificationClient ¶
type ResourceService_DeployResourceSpecificationClient interface { Send(*v1beta1.DeployResourceSpecificationRequest) error Recv() (*v1beta1.DeployResourceSpecificationResponse, error) grpc.ClientStream }
type ResourceService_DeployResourceSpecificationServer ¶
type ResourceService_DeployResourceSpecificationServer interface { Send(*v1beta1.DeployResourceSpecificationResponse) error Recv() (*v1beta1.DeployResourceSpecificationRequest, error) grpc.ServerStream }
type RuntimeServiceClient ¶
type RuntimeServiceClient interface { Version(ctx context.Context, in *v1beta1.VersionRequest, opts ...grpc.CallOption) (*v1beta1.VersionResponse, error) RegisterJobEvent(ctx context.Context, in *v1beta1.RegisterJobEventRequest, opts ...grpc.CallOption) (*v1beta1.RegisterJobEventResponse, error) }
RuntimeServiceClient is the client API for RuntimeService 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 NewRuntimeServiceClient ¶
func NewRuntimeServiceClient(cc grpc.ClientConnInterface) RuntimeServiceClient
type RuntimeServiceServer ¶
type RuntimeServiceServer interface { Version(context.Context, *v1beta1.VersionRequest) (*v1beta1.VersionResponse, error) RegisterJobEvent(context.Context, *v1beta1.RegisterJobEventRequest) (*v1beta1.RegisterJobEventResponse, error) }
RuntimeServiceServer is the server API for RuntimeService service. All implementations should embed UnimplementedRuntimeServiceServer for forward compatibility
type SecretServiceClient ¶
type SecretServiceClient interface { RegisterSecret(ctx context.Context, in *v1beta1.RegisterSecretRequest, opts ...grpc.CallOption) (*v1beta1.RegisterSecretResponse, error) UpdateSecret(ctx context.Context, in *v1beta1.UpdateSecretRequest, opts ...grpc.CallOption) (*v1beta1.UpdateSecretResponse, error) ListSecrets(ctx context.Context, in *v1beta1.ListSecretsRequest, opts ...grpc.CallOption) (*v1beta1.ListSecretsResponse, error) DeleteSecret(ctx context.Context, in *v1beta1.DeleteSecretRequest, opts ...grpc.CallOption) (*v1beta1.DeleteSecretResponse, error) }
SecretServiceClient is the client API for SecretService 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 NewSecretServiceClient ¶
func NewSecretServiceClient(cc grpc.ClientConnInterface) SecretServiceClient
type SecretServiceServer ¶
type SecretServiceServer interface { RegisterSecret(context.Context, *v1beta1.RegisterSecretRequest) (*v1beta1.RegisterSecretResponse, error) UpdateSecret(context.Context, *v1beta1.UpdateSecretRequest) (*v1beta1.UpdateSecretResponse, error) ListSecrets(context.Context, *v1beta1.ListSecretsRequest) (*v1beta1.ListSecretsResponse, error) DeleteSecret(context.Context, *v1beta1.DeleteSecretRequest) (*v1beta1.DeleteSecretResponse, error) }
SecretServiceServer is the server API for SecretService service. All implementations should embed UnimplementedSecretServiceServer for forward compatibility
type UnimplementedBackupServiceServer ¶
type UnimplementedBackupServiceServer struct { }
UnimplementedBackupServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedBackupServiceServer) BackupDryRun ¶
func (UnimplementedBackupServiceServer) BackupDryRun(context.Context, *v1beta1.BackupDryRunRequest) (*v1beta1.BackupDryRunResponse, error)
func (UnimplementedBackupServiceServer) CreateBackup ¶
func (UnimplementedBackupServiceServer) CreateBackup(context.Context, *v1beta1.CreateBackupRequest) (*v1beta1.CreateBackupResponse, error)
func (UnimplementedBackupServiceServer) GetBackup ¶
func (UnimplementedBackupServiceServer) GetBackup(context.Context, *v1beta1.GetBackupRequest) (*v1beta1.GetBackupResponse, error)
func (UnimplementedBackupServiceServer) ListBackups ¶
func (UnimplementedBackupServiceServer) ListBackups(context.Context, *v1beta1.ListBackupsRequest) (*v1beta1.ListBackupsResponse, error)
type UnimplementedJobRunServiceServer ¶
type UnimplementedJobRunServiceServer struct { }
UnimplementedJobRunServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedJobRunServiceServer) GetJobTask ¶
func (UnimplementedJobRunServiceServer) GetJobTask(context.Context, *v1beta1.GetJobTaskRequest) (*v1beta1.GetJobTaskResponse, error)
func (UnimplementedJobRunServiceServer) GetWindow ¶
func (UnimplementedJobRunServiceServer) GetWindow(context.Context, *v1beta1.GetWindowRequest) (*v1beta1.GetWindowResponse, error)
func (UnimplementedJobRunServiceServer) JobRun ¶
func (UnimplementedJobRunServiceServer) JobRun(context.Context, *v1beta1.JobRunRequest) (*v1beta1.JobRunResponse, error)
func (UnimplementedJobRunServiceServer) JobStatus ¶
func (UnimplementedJobRunServiceServer) JobStatus(context.Context, *v1beta1.JobStatusRequest) (*v1beta1.JobStatusResponse, error)
func (UnimplementedJobRunServiceServer) RegisterInstance ¶
func (UnimplementedJobRunServiceServer) RegisterInstance(context.Context, *v1beta1.RegisterInstanceRequest) (*v1beta1.RegisterInstanceResponse, error)
func (UnimplementedJobRunServiceServer) RunJob ¶
func (UnimplementedJobRunServiceServer) RunJob(context.Context, *v1beta1.RunJobRequest) (*v1beta1.RunJobResponse, error)
type UnimplementedJobSpecificationServiceServer ¶
type UnimplementedJobSpecificationServiceServer struct { }
UnimplementedJobSpecificationServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedJobSpecificationServiceServer) CheckJobSpecification ¶
func (UnimplementedJobSpecificationServiceServer) CheckJobSpecification(context.Context, *v1beta1.CheckJobSpecificationRequest) (*v1beta1.CheckJobSpecificationResponse, error)
func (UnimplementedJobSpecificationServiceServer) CheckJobSpecifications ¶
func (UnimplementedJobSpecificationServiceServer) CheckJobSpecifications(*v1beta1.CheckJobSpecificationsRequest, JobSpecificationService_CheckJobSpecificationsServer) error
func (UnimplementedJobSpecificationServiceServer) CreateJobSpecification ¶
func (UnimplementedJobSpecificationServiceServer) CreateJobSpecification(context.Context, *v1beta1.CreateJobSpecificationRequest) (*v1beta1.CreateJobSpecificationResponse, error)
func (UnimplementedJobSpecificationServiceServer) DeleteJobSpecification ¶
func (UnimplementedJobSpecificationServiceServer) DeleteJobSpecification(context.Context, *v1beta1.DeleteJobSpecificationRequest) (*v1beta1.DeleteJobSpecificationResponse, error)
func (UnimplementedJobSpecificationServiceServer) DeployJobSpecification ¶
func (UnimplementedJobSpecificationServiceServer) DeployJobSpecification(JobSpecificationService_DeployJobSpecificationServer) error
func (UnimplementedJobSpecificationServiceServer) GetJobSpecification ¶
func (UnimplementedJobSpecificationServiceServer) GetJobSpecification(context.Context, *v1beta1.GetJobSpecificationRequest) (*v1beta1.GetJobSpecificationResponse, error)
func (UnimplementedJobSpecificationServiceServer) ListJobSpecification ¶
func (UnimplementedJobSpecificationServiceServer) ListJobSpecification(context.Context, *v1beta1.ListJobSpecificationRequest) (*v1beta1.ListJobSpecificationResponse, error)
func (UnimplementedJobSpecificationServiceServer) RefreshJobs ¶
type UnimplementedNamespaceServiceServer ¶
type UnimplementedNamespaceServiceServer struct { }
UnimplementedNamespaceServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedNamespaceServiceServer) ListProjectNamespaces ¶
func (UnimplementedNamespaceServiceServer) ListProjectNamespaces(context.Context, *v1beta1.ListProjectNamespacesRequest) (*v1beta1.ListProjectNamespacesResponse, error)
func (UnimplementedNamespaceServiceServer) RegisterProjectNamespace ¶
func (UnimplementedNamespaceServiceServer) RegisterProjectNamespace(context.Context, *v1beta1.RegisterProjectNamespaceRequest) (*v1beta1.RegisterProjectNamespaceResponse, error)
type UnimplementedProjectServiceServer ¶
type UnimplementedProjectServiceServer struct { }
UnimplementedProjectServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedProjectServiceServer) ListProjects ¶
func (UnimplementedProjectServiceServer) ListProjects(context.Context, *v1beta1.ListProjectsRequest) (*v1beta1.ListProjectsResponse, error)
func (UnimplementedProjectServiceServer) RegisterProject ¶
func (UnimplementedProjectServiceServer) RegisterProject(context.Context, *v1beta1.RegisterProjectRequest) (*v1beta1.RegisterProjectResponse, error)
type UnimplementedReplayServiceServer ¶
type UnimplementedReplayServiceServer struct { }
UnimplementedReplayServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedReplayServiceServer) GetReplayStatus ¶
func (UnimplementedReplayServiceServer) GetReplayStatus(context.Context, *v1beta1.GetReplayStatusRequest) (*v1beta1.GetReplayStatusResponse, error)
func (UnimplementedReplayServiceServer) ListReplays ¶
func (UnimplementedReplayServiceServer) ListReplays(context.Context, *v1beta1.ListReplaysRequest) (*v1beta1.ListReplaysResponse, error)
func (UnimplementedReplayServiceServer) Replay ¶
func (UnimplementedReplayServiceServer) Replay(context.Context, *v1beta1.ReplayRequest) (*v1beta1.ReplayResponse, error)
func (UnimplementedReplayServiceServer) ReplayDryRun ¶
func (UnimplementedReplayServiceServer) ReplayDryRun(context.Context, *v1beta1.ReplayDryRunRequest) (*v1beta1.ReplayDryRunResponse, error)
type UnimplementedResourceServiceServer ¶
type UnimplementedResourceServiceServer struct { }
UnimplementedResourceServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedResourceServiceServer) CreateResource ¶
func (UnimplementedResourceServiceServer) CreateResource(context.Context, *v1beta1.CreateResourceRequest) (*v1beta1.CreateResourceResponse, error)
func (UnimplementedResourceServiceServer) DeployResourceSpecification ¶
func (UnimplementedResourceServiceServer) DeployResourceSpecification(ResourceService_DeployResourceSpecificationServer) error
func (UnimplementedResourceServiceServer) ListResourceSpecification ¶
func (UnimplementedResourceServiceServer) ListResourceSpecification(context.Context, *v1beta1.ListResourceSpecificationRequest) (*v1beta1.ListResourceSpecificationResponse, error)
func (UnimplementedResourceServiceServer) ReadResource ¶
func (UnimplementedResourceServiceServer) ReadResource(context.Context, *v1beta1.ReadResourceRequest) (*v1beta1.ReadResourceResponse, error)
func (UnimplementedResourceServiceServer) UpdateResource ¶
func (UnimplementedResourceServiceServer) UpdateResource(context.Context, *v1beta1.UpdateResourceRequest) (*v1beta1.UpdateResourceResponse, error)
type UnimplementedRuntimeServiceServer ¶
type UnimplementedRuntimeServiceServer struct { }
UnimplementedRuntimeServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedRuntimeServiceServer) RegisterJobEvent ¶
func (UnimplementedRuntimeServiceServer) RegisterJobEvent(context.Context, *v1beta1.RegisterJobEventRequest) (*v1beta1.RegisterJobEventResponse, error)
func (UnimplementedRuntimeServiceServer) Version ¶
func (UnimplementedRuntimeServiceServer) Version(context.Context, *v1beta1.VersionRequest) (*v1beta1.VersionResponse, error)
type UnimplementedSecretServiceServer ¶
type UnimplementedSecretServiceServer struct { }
UnimplementedSecretServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedSecretServiceServer) DeleteSecret ¶
func (UnimplementedSecretServiceServer) DeleteSecret(context.Context, *v1beta1.DeleteSecretRequest) (*v1beta1.DeleteSecretResponse, error)
func (UnimplementedSecretServiceServer) ListSecrets ¶
func (UnimplementedSecretServiceServer) ListSecrets(context.Context, *v1beta1.ListSecretsRequest) (*v1beta1.ListSecretsResponse, error)
func (UnimplementedSecretServiceServer) RegisterSecret ¶
func (UnimplementedSecretServiceServer) RegisterSecret(context.Context, *v1beta1.RegisterSecretRequest) (*v1beta1.RegisterSecretResponse, error)
func (UnimplementedSecretServiceServer) UpdateSecret ¶
func (UnimplementedSecretServiceServer) UpdateSecret(context.Context, *v1beta1.UpdateSecretRequest) (*v1beta1.UpdateSecretResponse, error)
type UnsafeBackupServiceServer ¶
type UnsafeBackupServiceServer interface {
// contains filtered or unexported methods
}
UnsafeBackupServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BackupServiceServer will result in compilation errors.
type UnsafeJobRunServiceServer ¶
type UnsafeJobRunServiceServer interface {
// contains filtered or unexported methods
}
UnsafeJobRunServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobRunServiceServer will result in compilation errors.
type UnsafeJobSpecificationServiceServer ¶
type UnsafeJobSpecificationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeJobSpecificationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobSpecificationServiceServer will result in compilation errors.
type UnsafeNamespaceServiceServer ¶
type UnsafeNamespaceServiceServer interface {
// contains filtered or unexported methods
}
UnsafeNamespaceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NamespaceServiceServer will result in compilation errors.
type UnsafeProjectServiceServer ¶
type UnsafeProjectServiceServer interface {
// contains filtered or unexported methods
}
UnsafeProjectServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProjectServiceServer will result in compilation errors.
type UnsafeReplayServiceServer ¶
type UnsafeReplayServiceServer interface {
// contains filtered or unexported methods
}
UnsafeReplayServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReplayServiceServer will result in compilation errors.
type UnsafeResourceServiceServer ¶
type UnsafeResourceServiceServer interface {
// contains filtered or unexported methods
}
UnsafeResourceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ResourceServiceServer will result in compilation errors.
type UnsafeRuntimeServiceServer ¶
type UnsafeRuntimeServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRuntimeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RuntimeServiceServer will result in compilation errors.
type UnsafeSecretServiceServer ¶
type UnsafeSecretServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSecretServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SecretServiceServer will result in compilation errors.