optimusgrpc

package
v1.2.0-20230223111441-... 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.RuntimeService",
	HandlerType: (*RuntimeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _RuntimeService_Version_Handler,
		},
		{
			MethodName: "CreateJobSpecification",
			Handler:    _RuntimeService_CreateJobSpecification_Handler,
		},
		{
			MethodName: "ReadJobSpecification",
			Handler:    _RuntimeService_ReadJobSpecification_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: "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: "Backup",
			Handler:    _RuntimeService_Backup_Handler,
		},
		{
			MethodName: "ListBackups",
			Handler:    _RuntimeService_ListBackups_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/runtime_service.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 *optimus.VersionRequest, opts ...grpc.CallOption) (*optimus.VersionResponse, error)
	DeployJobSpecification(ctx context.Context, in *optimus.DeployJobSpecificationRequest, opts ...grpc.CallOption) (RuntimeService_DeployJobSpecificationClient, error)
	CreateJobSpecification(ctx context.Context, in *optimus.CreateJobSpecificationRequest, opts ...grpc.CallOption) (*optimus.CreateJobSpecificationResponse, error)
	ReadJobSpecification(ctx context.Context, in *optimus.ReadJobSpecificationRequest, opts ...grpc.CallOption) (*optimus.ReadJobSpecificationResponse, error)
	DeleteJobSpecification(ctx context.Context, in *optimus.DeleteJobSpecificationRequest, opts ...grpc.CallOption) (*optimus.DeleteJobSpecificationResponse, error)
	ListJobSpecification(ctx context.Context, in *optimus.ListJobSpecificationRequest, opts ...grpc.CallOption) (*optimus.ListJobSpecificationResponse, error)
	GetJobTask(ctx context.Context, in *optimus.GetJobTaskRequest, opts ...grpc.CallOption) (*optimus.GetJobTaskResponse, error)
	CheckJobSpecification(ctx context.Context, in *optimus.CheckJobSpecificationRequest, opts ...grpc.CallOption) (*optimus.CheckJobSpecificationResponse, error)
	CheckJobSpecifications(ctx context.Context, in *optimus.CheckJobSpecificationsRequest, opts ...grpc.CallOption) (RuntimeService_CheckJobSpecificationsClient, error)
	RegisterProject(ctx context.Context, in *optimus.RegisterProjectRequest, opts ...grpc.CallOption) (*optimus.RegisterProjectResponse, error)
	RegisterProjectNamespace(ctx context.Context, in *optimus.RegisterProjectNamespaceRequest, opts ...grpc.CallOption) (*optimus.RegisterProjectNamespaceResponse, error)
	RegisterSecret(ctx context.Context, in *optimus.RegisterSecretRequest, opts ...grpc.CallOption) (*optimus.RegisterSecretResponse, error)
	ListProjects(ctx context.Context, in *optimus.ListProjectsRequest, opts ...grpc.CallOption) (*optimus.ListProjectsResponse, error)
	ListProjectNamespaces(ctx context.Context, in *optimus.ListProjectNamespacesRequest, opts ...grpc.CallOption) (*optimus.ListProjectNamespacesResponse, error)
	RegisterInstance(ctx context.Context, in *optimus.RegisterInstanceRequest, opts ...grpc.CallOption) (*optimus.RegisterInstanceResponse, error)
	JobStatus(ctx context.Context, in *optimus.JobStatusRequest, opts ...grpc.CallOption) (*optimus.JobStatusResponse, error)
	RegisterJobEvent(ctx context.Context, in *optimus.RegisterJobEventRequest, opts ...grpc.CallOption) (*optimus.RegisterJobEventResponse, error)
	GetWindow(ctx context.Context, in *optimus.GetWindowRequest, opts ...grpc.CallOption) (*optimus.GetWindowResponse, error)
	DeployResourceSpecification(ctx context.Context, in *optimus.DeployResourceSpecificationRequest, opts ...grpc.CallOption) (RuntimeService_DeployResourceSpecificationClient, error)
	ListResourceSpecification(ctx context.Context, in *optimus.ListResourceSpecificationRequest, opts ...grpc.CallOption) (*optimus.ListResourceSpecificationResponse, error)
	CreateResource(ctx context.Context, in *optimus.CreateResourceRequest, opts ...grpc.CallOption) (*optimus.CreateResourceResponse, error)
	ReadResource(ctx context.Context, in *optimus.ReadResourceRequest, opts ...grpc.CallOption) (*optimus.ReadResourceResponse, error)
	UpdateResource(ctx context.Context, in *optimus.UpdateResourceRequest, opts ...grpc.CallOption) (*optimus.UpdateResourceResponse, error)
	ReplayDryRun(ctx context.Context, in *optimus.ReplayDryRunRequest, opts ...grpc.CallOption) (*optimus.ReplayDryRunResponse, error)
	Replay(ctx context.Context, in *optimus.ReplayRequest, opts ...grpc.CallOption) (*optimus.ReplayResponse, error)
	GetReplayStatus(ctx context.Context, in *optimus.GetReplayStatusRequest, opts ...grpc.CallOption) (*optimus.GetReplayStatusResponse, error)
	ListReplays(ctx context.Context, in *optimus.ListReplaysRequest, opts ...grpc.CallOption) (*optimus.ListReplaysResponse, error)
	BackupDryRun(ctx context.Context, in *optimus.BackupDryRunRequest, opts ...grpc.CallOption) (*optimus.BackupDryRunResponse, error)
	Backup(ctx context.Context, in *optimus.BackupRequest, opts ...grpc.CallOption) (*optimus.BackupResponse, error)
	ListBackups(ctx context.Context, in *optimus.ListBackupsRequest, opts ...grpc.CallOption) (*optimus.ListBackupsResponse, error)
	RunJob(ctx context.Context, in *optimus.RunJobRequest, opts ...grpc.CallOption) (*optimus.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, *optimus.VersionRequest) (*optimus.VersionResponse, error)
	DeployJobSpecification(*optimus.DeployJobSpecificationRequest, RuntimeService_DeployJobSpecificationServer) error
	CreateJobSpecification(context.Context, *optimus.CreateJobSpecificationRequest) (*optimus.CreateJobSpecificationResponse, error)
	ReadJobSpecification(context.Context, *optimus.ReadJobSpecificationRequest) (*optimus.ReadJobSpecificationResponse, error)
	DeleteJobSpecification(context.Context, *optimus.DeleteJobSpecificationRequest) (*optimus.DeleteJobSpecificationResponse, error)
	ListJobSpecification(context.Context, *optimus.ListJobSpecificationRequest) (*optimus.ListJobSpecificationResponse, error)
	GetJobTask(context.Context, *optimus.GetJobTaskRequest) (*optimus.GetJobTaskResponse, error)
	CheckJobSpecification(context.Context, *optimus.CheckJobSpecificationRequest) (*optimus.CheckJobSpecificationResponse, error)
	CheckJobSpecifications(*optimus.CheckJobSpecificationsRequest, RuntimeService_CheckJobSpecificationsServer) error
	RegisterProject(context.Context, *optimus.RegisterProjectRequest) (*optimus.RegisterProjectResponse, error)
	RegisterProjectNamespace(context.Context, *optimus.RegisterProjectNamespaceRequest) (*optimus.RegisterProjectNamespaceResponse, error)
	RegisterSecret(context.Context, *optimus.RegisterSecretRequest) (*optimus.RegisterSecretResponse, error)
	ListProjects(context.Context, *optimus.ListProjectsRequest) (*optimus.ListProjectsResponse, error)
	ListProjectNamespaces(context.Context, *optimus.ListProjectNamespacesRequest) (*optimus.ListProjectNamespacesResponse, error)
	RegisterInstance(context.Context, *optimus.RegisterInstanceRequest) (*optimus.RegisterInstanceResponse, error)
	JobStatus(context.Context, *optimus.JobStatusRequest) (*optimus.JobStatusResponse, error)
	RegisterJobEvent(context.Context, *optimus.RegisterJobEventRequest) (*optimus.RegisterJobEventResponse, error)
	GetWindow(context.Context, *optimus.GetWindowRequest) (*optimus.GetWindowResponse, error)
	DeployResourceSpecification(*optimus.DeployResourceSpecificationRequest, RuntimeService_DeployResourceSpecificationServer) error
	ListResourceSpecification(context.Context, *optimus.ListResourceSpecificationRequest) (*optimus.ListResourceSpecificationResponse, error)
	CreateResource(context.Context, *optimus.CreateResourceRequest) (*optimus.CreateResourceResponse, error)
	ReadResource(context.Context, *optimus.ReadResourceRequest) (*optimus.ReadResourceResponse, error)
	UpdateResource(context.Context, *optimus.UpdateResourceRequest) (*optimus.UpdateResourceResponse, error)
	ReplayDryRun(context.Context, *optimus.ReplayDryRunRequest) (*optimus.ReplayDryRunResponse, error)
	Replay(context.Context, *optimus.ReplayRequest) (*optimus.ReplayResponse, error)
	GetReplayStatus(context.Context, *optimus.GetReplayStatusRequest) (*optimus.GetReplayStatusResponse, error)
	ListReplays(context.Context, *optimus.ListReplaysRequest) (*optimus.ListReplaysResponse, error)
	BackupDryRun(context.Context, *optimus.BackupDryRunRequest) (*optimus.BackupDryRunResponse, error)
	Backup(context.Context, *optimus.BackupRequest) (*optimus.BackupResponse, error)
	ListBackups(context.Context, *optimus.ListBackupsRequest) (*optimus.ListBackupsResponse, error)
	RunJob(context.Context, *optimus.RunJobRequest) (*optimus.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() (*optimus.CheckJobSpecificationsResponse, error)
	grpc.ClientStream
}

type RuntimeService_CheckJobSpecificationsServer 

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

type RuntimeService_DeployJobSpecificationClient 

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

type RuntimeService_DeployJobSpecificationServer 

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

type RuntimeService_DeployResourceSpecificationClient 

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

type RuntimeService_DeployResourceSpecificationServer 

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

type UnimplementedRuntimeServiceServer 

type UnimplementedRuntimeServiceServer struct {
}

UnimplementedRuntimeServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServiceServer) Backup 

func (UnimplementedRuntimeServiceServer) Backup(context.Context, *optimus.BackupRequest) (*optimus.BackupResponse, error)

func (UnimplementedRuntimeServiceServer) BackupDryRun 

func (UnimplementedRuntimeServiceServer) BackupDryRun(context.Context, *optimus.BackupDryRunRequest) (*optimus.BackupDryRunResponse, error)

func (UnimplementedRuntimeServiceServer) CheckJobSpecification 

func (UnimplementedRuntimeServiceServer) CheckJobSpecification(context.Context, *optimus.CheckJobSpecificationRequest) (*optimus.CheckJobSpecificationResponse, error)

func (UnimplementedRuntimeServiceServer) CheckJobSpecifications 

func (UnimplementedRuntimeServiceServer) CheckJobSpecifications(*optimus.CheckJobSpecificationsRequest, RuntimeService_CheckJobSpecificationsServer) error

func (UnimplementedRuntimeServiceServer) CreateJobSpecification 

func (UnimplementedRuntimeServiceServer) CreateJobSpecification(context.Context, *optimus.CreateJobSpecificationRequest) (*optimus.CreateJobSpecificationResponse, error)

func (UnimplementedRuntimeServiceServer) CreateResource 

func (UnimplementedRuntimeServiceServer) CreateResource(context.Context, *optimus.CreateResourceRequest) (*optimus.CreateResourceResponse, error)

func (UnimplementedRuntimeServiceServer) DeleteJobSpecification 

func (UnimplementedRuntimeServiceServer) DeleteJobSpecification(context.Context, *optimus.DeleteJobSpecificationRequest) (*optimus.DeleteJobSpecificationResponse, error)

func (UnimplementedRuntimeServiceServer) DeployJobSpecification 

func (UnimplementedRuntimeServiceServer) DeployJobSpecification(*optimus.DeployJobSpecificationRequest, RuntimeService_DeployJobSpecificationServer) error

func (UnimplementedRuntimeServiceServer) DeployResourceSpecification 

func (UnimplementedRuntimeServiceServer) DeployResourceSpecification(*optimus.DeployResourceSpecificationRequest, RuntimeService_DeployResourceSpecificationServer) error

func (UnimplementedRuntimeServiceServer) GetJobTask 

func (UnimplementedRuntimeServiceServer) GetJobTask(context.Context, *optimus.GetJobTaskRequest) (*optimus.GetJobTaskResponse, error)

func (UnimplementedRuntimeServiceServer) GetReplayStatus 

func (UnimplementedRuntimeServiceServer) GetReplayStatus(context.Context, *optimus.GetReplayStatusRequest) (*optimus.GetReplayStatusResponse, error)

func (UnimplementedRuntimeServiceServer) GetWindow 

func (UnimplementedRuntimeServiceServer) GetWindow(context.Context, *optimus.GetWindowRequest) (*optimus.GetWindowResponse, error)

func (UnimplementedRuntimeServiceServer) JobStatus 

func (UnimplementedRuntimeServiceServer) JobStatus(context.Context, *optimus.JobStatusRequest) (*optimus.JobStatusResponse, error)

func (UnimplementedRuntimeServiceServer) ListBackups 

func (UnimplementedRuntimeServiceServer) ListBackups(context.Context, *optimus.ListBackupsRequest) (*optimus.ListBackupsResponse, error)

func (UnimplementedRuntimeServiceServer) ListJobSpecification 

func (UnimplementedRuntimeServiceServer) ListJobSpecification(context.Context, *optimus.ListJobSpecificationRequest) (*optimus.ListJobSpecificationResponse, error)

func (UnimplementedRuntimeServiceServer) ListProjectNamespaces 

func (UnimplementedRuntimeServiceServer) ListProjectNamespaces(context.Context, *optimus.ListProjectNamespacesRequest) (*optimus.ListProjectNamespacesResponse, error)

func (UnimplementedRuntimeServiceServer) ListProjects 

func (UnimplementedRuntimeServiceServer) ListProjects(context.Context, *optimus.ListProjectsRequest) (*optimus.ListProjectsResponse, error)

func (UnimplementedRuntimeServiceServer) ListReplays 

func (UnimplementedRuntimeServiceServer) ListReplays(context.Context, *optimus.ListReplaysRequest) (*optimus.ListReplaysResponse, error)

func (UnimplementedRuntimeServiceServer) ListResourceSpecification 

func (UnimplementedRuntimeServiceServer) ListResourceSpecification(context.Context, *optimus.ListResourceSpecificationRequest) (*optimus.ListResourceSpecificationResponse, error)

func (UnimplementedRuntimeServiceServer) ReadJobSpecification 

func (UnimplementedRuntimeServiceServer) ReadJobSpecification(context.Context, *optimus.ReadJobSpecificationRequest) (*optimus.ReadJobSpecificationResponse, error)

func (UnimplementedRuntimeServiceServer) ReadResource 

func (UnimplementedRuntimeServiceServer) ReadResource(context.Context, *optimus.ReadResourceRequest) (*optimus.ReadResourceResponse, error)

func (UnimplementedRuntimeServiceServer) RegisterInstance 

func (UnimplementedRuntimeServiceServer) RegisterInstance(context.Context, *optimus.RegisterInstanceRequest) (*optimus.RegisterInstanceResponse, error)

func (UnimplementedRuntimeServiceServer) RegisterJobEvent 

func (UnimplementedRuntimeServiceServer) RegisterJobEvent(context.Context, *optimus.RegisterJobEventRequest) (*optimus.RegisterJobEventResponse, error)

func (UnimplementedRuntimeServiceServer) RegisterProject 

func (UnimplementedRuntimeServiceServer) RegisterProject(context.Context, *optimus.RegisterProjectRequest) (*optimus.RegisterProjectResponse, error)

func (UnimplementedRuntimeServiceServer) RegisterProjectNamespace 

func (UnimplementedRuntimeServiceServer) RegisterProjectNamespace(context.Context, *optimus.RegisterProjectNamespaceRequest) (*optimus.RegisterProjectNamespaceResponse, error)

func (UnimplementedRuntimeServiceServer) RegisterSecret 

func (UnimplementedRuntimeServiceServer) RegisterSecret(context.Context, *optimus.RegisterSecretRequest) (*optimus.RegisterSecretResponse, error)

func (UnimplementedRuntimeServiceServer) Replay 

func (UnimplementedRuntimeServiceServer) Replay(context.Context, *optimus.ReplayRequest) (*optimus.ReplayResponse, error)

func (UnimplementedRuntimeServiceServer) ReplayDryRun 

func (UnimplementedRuntimeServiceServer) ReplayDryRun(context.Context, *optimus.ReplayDryRunRequest) (*optimus.ReplayDryRunResponse, error)

func (UnimplementedRuntimeServiceServer) RunJob 

func (UnimplementedRuntimeServiceServer) RunJob(context.Context, *optimus.RunJobRequest) (*optimus.RunJobResponse, error)

func (UnimplementedRuntimeServiceServer) UpdateResource 

func (UnimplementedRuntimeServiceServer) UpdateResource(context.Context, *optimus.UpdateResourceRequest) (*optimus.UpdateResourceResponse, error)

func (UnimplementedRuntimeServiceServer) Version 

func (UnimplementedRuntimeServiceServer) Version(context.Context, *optimus.VersionRequest) (*optimus.VersionResponse, error)

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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