corev1beta1grpc

package
v1.2.0-20230223111517-... Latest Latest
Warning

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

Go to latest
Published: unknown License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var RuntimeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "odpf.optimus.core.v1beta1.RuntimeService",
	HandlerType: (*RuntimeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _RuntimeService_Version_Handler,
		},
		{
			MethodName: "CreateJobSpecification",
			Handler:    _RuntimeService_CreateJobSpecification_Handler,
		},
		{
			MethodName: "GetJobSpecification",
			Handler:    _RuntimeService_GetJobSpecification_Handler,
		},
		{
			MethodName: "DeleteJobSpecification",
			Handler:    _RuntimeService_DeleteJobSpecification_Handler,
		},
		{
			MethodName: "ListJobSpecification",
			Handler:    _RuntimeService_ListJobSpecification_Handler,
		},
		{
			MethodName: "GetJobTask",
			Handler:    _RuntimeService_GetJobTask_Handler,
		},
		{
			MethodName: "CheckJobSpecification",
			Handler:    _RuntimeService_CheckJobSpecification_Handler,
		},
		{
			MethodName: "RegisterProject",
			Handler:    _RuntimeService_RegisterProject_Handler,
		},
		{
			MethodName: "RegisterProjectNamespace",
			Handler:    _RuntimeService_RegisterProjectNamespace_Handler,
		},
		{
			MethodName: "RegisterSecret",
			Handler:    _RuntimeService_RegisterSecret_Handler,
		},
		{
			MethodName: "UpdateSecret",
			Handler:    _RuntimeService_UpdateSecret_Handler,
		},
		{
			MethodName: "ListSecrets",
			Handler:    _RuntimeService_ListSecrets_Handler,
		},
		{
			MethodName: "DeleteSecret",
			Handler:    _RuntimeService_DeleteSecret_Handler,
		},
		{
			MethodName: "ListProjects",
			Handler:    _RuntimeService_ListProjects_Handler,
		},
		{
			MethodName: "ListProjectNamespaces",
			Handler:    _RuntimeService_ListProjectNamespaces_Handler,
		},
		{
			MethodName: "RegisterInstance",
			Handler:    _RuntimeService_RegisterInstance_Handler,
		},
		{
			MethodName: "JobStatus",
			Handler:    _RuntimeService_JobStatus_Handler,
		},
		{
			MethodName: "RegisterJobEvent",
			Handler:    _RuntimeService_RegisterJobEvent_Handler,
		},
		{
			MethodName: "GetWindow",
			Handler:    _RuntimeService_GetWindow_Handler,
		},
		{
			MethodName: "ListResourceSpecification",
			Handler:    _RuntimeService_ListResourceSpecification_Handler,
		},
		{
			MethodName: "CreateResource",
			Handler:    _RuntimeService_CreateResource_Handler,
		},
		{
			MethodName: "ReadResource",
			Handler:    _RuntimeService_ReadResource_Handler,
		},
		{
			MethodName: "UpdateResource",
			Handler:    _RuntimeService_UpdateResource_Handler,
		},
		{
			MethodName: "ReplayDryRun",
			Handler:    _RuntimeService_ReplayDryRun_Handler,
		},
		{
			MethodName: "Replay",
			Handler:    _RuntimeService_Replay_Handler,
		},
		{
			MethodName: "GetReplayStatus",
			Handler:    _RuntimeService_GetReplayStatus_Handler,
		},
		{
			MethodName: "ListReplays",
			Handler:    _RuntimeService_ListReplays_Handler,
		},
		{
			MethodName: "BackupDryRun",
			Handler:    _RuntimeService_BackupDryRun_Handler,
		},
		{
			MethodName: "CreateBackup",
			Handler:    _RuntimeService_CreateBackup_Handler,
		},
		{
			MethodName: "ListBackups",
			Handler:    _RuntimeService_ListBackups_Handler,
		},
		{
			MethodName: "GetBackup",
			Handler:    _RuntimeService_GetBackup_Handler,
		},
		{
			MethodName: "RunJob",
			Handler:    _RuntimeService_RunJob_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DeployJobSpecification",
			Handler:       _RuntimeService_DeployJobSpecification_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CheckJobSpecifications",
			Handler:       _RuntimeService_CheckJobSpecifications_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeployResourceSpecification",
			Handler:       _RuntimeService_DeployResourceSpecification_Handler,
			ServerStreams: true,
		},
	},
	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)

Functions

func RegisterRuntimeServiceServer

func RegisterRuntimeServiceServer(s grpc.ServiceRegistrar, srv RuntimeServiceServer)

Types

type RuntimeServiceClient

type RuntimeServiceClient interface {
	Version(ctx context.Context, in *v1beta1.VersionRequest, opts ...grpc.CallOption) (*v1beta1.VersionResponse, error)
	DeployJobSpecification(ctx context.Context, in *v1beta1.DeployJobSpecificationRequest, opts ...grpc.CallOption) (RuntimeService_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)
	GetJobTask(ctx context.Context, in *v1beta1.GetJobTaskRequest, opts ...grpc.CallOption) (*v1beta1.GetJobTaskResponse, error)
	CheckJobSpecification(ctx context.Context, in *v1beta1.CheckJobSpecificationRequest, opts ...grpc.CallOption) (*v1beta1.CheckJobSpecificationResponse, error)
	CheckJobSpecifications(ctx context.Context, in *v1beta1.CheckJobSpecificationsRequest, opts ...grpc.CallOption) (RuntimeService_CheckJobSpecificationsClient, error)
	RegisterProject(ctx context.Context, in *v1beta1.RegisterProjectRequest, opts ...grpc.CallOption) (*v1beta1.RegisterProjectResponse, error)
	RegisterProjectNamespace(ctx context.Context, in *v1beta1.RegisterProjectNamespaceRequest, opts ...grpc.CallOption) (*v1beta1.RegisterProjectNamespaceResponse, error)
	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)
	ListProjects(ctx context.Context, in *v1beta1.ListProjectsRequest, opts ...grpc.CallOption) (*v1beta1.ListProjectsResponse, error)
	ListProjectNamespaces(ctx context.Context, in *v1beta1.ListProjectNamespacesRequest, opts ...grpc.CallOption) (*v1beta1.ListProjectNamespacesResponse, 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)
	RegisterJobEvent(ctx context.Context, in *v1beta1.RegisterJobEventRequest, opts ...grpc.CallOption) (*v1beta1.RegisterJobEventResponse, error)
	GetWindow(ctx context.Context, in *v1beta1.GetWindowRequest, opts ...grpc.CallOption) (*v1beta1.GetWindowResponse, error)
	DeployResourceSpecification(ctx context.Context, in *v1beta1.DeployResourceSpecificationRequest, opts ...grpc.CallOption) (RuntimeService_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)
	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)
	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)
	RunJob(ctx context.Context, in *v1beta1.RunJobRequest, opts ...grpc.CallOption) (*v1beta1.RunJobResponse, 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)
	DeployJobSpecification(*v1beta1.DeployJobSpecificationRequest, RuntimeService_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)
	GetJobTask(context.Context, *v1beta1.GetJobTaskRequest) (*v1beta1.GetJobTaskResponse, error)
	CheckJobSpecification(context.Context, *v1beta1.CheckJobSpecificationRequest) (*v1beta1.CheckJobSpecificationResponse, error)
	CheckJobSpecifications(*v1beta1.CheckJobSpecificationsRequest, RuntimeService_CheckJobSpecificationsServer) error
	RegisterProject(context.Context, *v1beta1.RegisterProjectRequest) (*v1beta1.RegisterProjectResponse, error)
	RegisterProjectNamespace(context.Context, *v1beta1.RegisterProjectNamespaceRequest) (*v1beta1.RegisterProjectNamespaceResponse, error)
	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)
	ListProjects(context.Context, *v1beta1.ListProjectsRequest) (*v1beta1.ListProjectsResponse, error)
	ListProjectNamespaces(context.Context, *v1beta1.ListProjectNamespacesRequest) (*v1beta1.ListProjectNamespacesResponse, error)
	RegisterInstance(context.Context, *v1beta1.RegisterInstanceRequest) (*v1beta1.RegisterInstanceResponse, error)
	JobStatus(context.Context, *v1beta1.JobStatusRequest) (*v1beta1.JobStatusResponse, error)
	RegisterJobEvent(context.Context, *v1beta1.RegisterJobEventRequest) (*v1beta1.RegisterJobEventResponse, error)
	GetWindow(context.Context, *v1beta1.GetWindowRequest) (*v1beta1.GetWindowResponse, error)
	DeployResourceSpecification(*v1beta1.DeployResourceSpecificationRequest, RuntimeService_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)
	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)
	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)
	RunJob(context.Context, *v1beta1.RunJobRequest) (*v1beta1.RunJobResponse, error)
}

RuntimeServiceServer is the server API for RuntimeService service. All implementations should embed UnimplementedRuntimeServiceServer for forward compatibility

type RuntimeService_CheckJobSpecificationsClient

type RuntimeService_CheckJobSpecificationsClient interface {
	Recv() (*v1beta1.CheckJobSpecificationsResponse, error)
	grpc.ClientStream
}

type RuntimeService_CheckJobSpecificationsServer

type RuntimeService_CheckJobSpecificationsServer interface {
	Send(*v1beta1.CheckJobSpecificationsResponse) error
	grpc.ServerStream
}

type RuntimeService_DeployJobSpecificationClient

type RuntimeService_DeployJobSpecificationClient interface {
	Recv() (*v1beta1.DeployJobSpecificationResponse, error)
	grpc.ClientStream
}

type RuntimeService_DeployJobSpecificationServer

type RuntimeService_DeployJobSpecificationServer interface {
	Send(*v1beta1.DeployJobSpecificationResponse) error
	grpc.ServerStream
}

type RuntimeService_DeployResourceSpecificationClient

type RuntimeService_DeployResourceSpecificationClient interface {
	Recv() (*v1beta1.DeployResourceSpecificationResponse, error)
	grpc.ClientStream
}

type RuntimeService_DeployResourceSpecificationServer

type RuntimeService_DeployResourceSpecificationServer interface {
	Send(*v1beta1.DeployResourceSpecificationResponse) error
	grpc.ServerStream
}

type UnimplementedRuntimeServiceServer

type UnimplementedRuntimeServiceServer struct {
}

UnimplementedRuntimeServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServiceServer) BackupDryRun

func (UnimplementedRuntimeServiceServer) CheckJobSpecification

func (UnimplementedRuntimeServiceServer) CheckJobSpecifications

func (UnimplementedRuntimeServiceServer) CreateBackup

func (UnimplementedRuntimeServiceServer) CreateJobSpecification

func (UnimplementedRuntimeServiceServer) CreateResource

func (UnimplementedRuntimeServiceServer) DeleteJobSpecification

func (UnimplementedRuntimeServiceServer) DeleteSecret

func (UnimplementedRuntimeServiceServer) DeployJobSpecification

func (UnimplementedRuntimeServiceServer) DeployResourceSpecification

func (UnimplementedRuntimeServiceServer) GetBackup

func (UnimplementedRuntimeServiceServer) GetJobSpecification

func (UnimplementedRuntimeServiceServer) GetJobTask

func (UnimplementedRuntimeServiceServer) GetReplayStatus

func (UnimplementedRuntimeServiceServer) GetWindow

func (UnimplementedRuntimeServiceServer) JobStatus

func (UnimplementedRuntimeServiceServer) ListBackups

func (UnimplementedRuntimeServiceServer) ListJobSpecification

func (UnimplementedRuntimeServiceServer) ListProjectNamespaces

func (UnimplementedRuntimeServiceServer) ListProjects

func (UnimplementedRuntimeServiceServer) ListReplays

func (UnimplementedRuntimeServiceServer) ListResourceSpecification

func (UnimplementedRuntimeServiceServer) ListSecrets

func (UnimplementedRuntimeServiceServer) ReadResource

func (UnimplementedRuntimeServiceServer) RegisterInstance

func (UnimplementedRuntimeServiceServer) RegisterJobEvent

func (UnimplementedRuntimeServiceServer) RegisterProject

func (UnimplementedRuntimeServiceServer) RegisterProjectNamespace

func (UnimplementedRuntimeServiceServer) RegisterSecret

func (UnimplementedRuntimeServiceServer) Replay

func (UnimplementedRuntimeServiceServer) ReplayDryRun

func (UnimplementedRuntimeServiceServer) RunJob

func (UnimplementedRuntimeServiceServer) UpdateResource

func (UnimplementedRuntimeServiceServer) UpdateSecret

func (UnimplementedRuntimeServiceServer) Version

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL