corev1beta1grpc

package
v1.3.0-20230223111533-... 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

View Source 
const (
	BackupService_BackupDryRun_FullMethodName = "/odpf.optimus.core.v1beta1.BackupService/BackupDryRun"
	BackupService_CreateBackup_FullMethodName = "/odpf.optimus.core.v1beta1.BackupService/CreateBackup"
	BackupService_ListBackups_FullMethodName  = "/odpf.optimus.core.v1beta1.BackupService/ListBackups"
	BackupService_GetBackup_FullMethodName    = "/odpf.optimus.core.v1beta1.BackupService/GetBackup"
)
View Source 
const (
	JobRunService_GetJobTask_FullMethodName       = "/odpf.optimus.core.v1beta1.JobRunService/GetJobTask"
	JobRunService_RegisterInstance_FullMethodName = "/odpf.optimus.core.v1beta1.JobRunService/RegisterInstance"
	JobRunService_JobStatus_FullMethodName        = "/odpf.optimus.core.v1beta1.JobRunService/JobStatus"
	JobRunService_JobRun_FullMethodName           = "/odpf.optimus.core.v1beta1.JobRunService/JobRun"
	JobRunService_GetWindow_FullMethodName        = "/odpf.optimus.core.v1beta1.JobRunService/GetWindow"
	JobRunService_RunJob_FullMethodName           = "/odpf.optimus.core.v1beta1.JobRunService/RunJob"
)
View Source 
const (
	JobSpecificationService_DeployJobSpecification_FullMethodName = "/odpf.optimus.core.v1beta1.JobSpecificationService/DeployJobSpecification"
	JobSpecificationService_CreateJobSpecification_FullMethodName = "/odpf.optimus.core.v1beta1.JobSpecificationService/CreateJobSpecification"
	JobSpecificationService_GetJobSpecification_FullMethodName    = "/odpf.optimus.core.v1beta1.JobSpecificationService/GetJobSpecification"
	JobSpecificationService_DeleteJobSpecification_FullMethodName = "/odpf.optimus.core.v1beta1.JobSpecificationService/DeleteJobSpecification"
	JobSpecificationService_ListJobSpecification_FullMethodName   = "/odpf.optimus.core.v1beta1.JobSpecificationService/ListJobSpecification"
	JobSpecificationService_CheckJobSpecification_FullMethodName  = "/odpf.optimus.core.v1beta1.JobSpecificationService/CheckJobSpecification"
	JobSpecificationService_CheckJobSpecifications_FullMethodName = "/odpf.optimus.core.v1beta1.JobSpecificationService/CheckJobSpecifications"
	JobSpecificationService_RefreshJobs_FullMethodName            = "/odpf.optimus.core.v1beta1.JobSpecificationService/RefreshJobs"
)
View Source 
const (
	NamespaceService_RegisterProjectNamespace_FullMethodName = "/odpf.optimus.core.v1beta1.NamespaceService/RegisterProjectNamespace"
	NamespaceService_ListProjectNamespaces_FullMethodName    = "/odpf.optimus.core.v1beta1.NamespaceService/ListProjectNamespaces"
)
View Source 
const (
	ProjectService_RegisterProject_FullMethodName = "/odpf.optimus.core.v1beta1.ProjectService/RegisterProject"
	ProjectService_ListProjects_FullMethodName    = "/odpf.optimus.core.v1beta1.ProjectService/ListProjects"
)
View Source 
const (
	ReplayService_ReplayDryRun_FullMethodName    = "/odpf.optimus.core.v1beta1.ReplayService/ReplayDryRun"
	ReplayService_Replay_FullMethodName          = "/odpf.optimus.core.v1beta1.ReplayService/Replay"
	ReplayService_GetReplayStatus_FullMethodName = "/odpf.optimus.core.v1beta1.ReplayService/GetReplayStatus"
	ReplayService_ListReplays_FullMethodName     = "/odpf.optimus.core.v1beta1.ReplayService/ListReplays"
)
View Source 
const (
	ResourceService_DeployResourceSpecification_FullMethodName = "/odpf.optimus.core.v1beta1.ResourceService/DeployResourceSpecification"
	ResourceService_ListResourceSpecification_FullMethodName   = "/odpf.optimus.core.v1beta1.ResourceService/ListResourceSpecification"
	ResourceService_CreateResource_FullMethodName              = "/odpf.optimus.core.v1beta1.ResourceService/CreateResource"
	ResourceService_ReadResource_FullMethodName                = "/odpf.optimus.core.v1beta1.ResourceService/ReadResource"
	ResourceService_UpdateResource_FullMethodName              = "/odpf.optimus.core.v1beta1.ResourceService/UpdateResource"
)
View Source 
const (
	RuntimeService_Version_FullMethodName          = "/odpf.optimus.core.v1beta1.RuntimeService/Version"
	RuntimeService_RegisterJobEvent_FullMethodName = "/odpf.optimus.core.v1beta1.RuntimeService/RegisterJobEvent"
)
View Source 
const (
	SecretService_RegisterSecret_FullMethodName = "/odpf.optimus.core.v1beta1.SecretService/RegisterSecret"
	SecretService_UpdateSecret_FullMethodName   = "/odpf.optimus.core.v1beta1.SecretService/UpdateSecret"
	SecretService_ListSecrets_FullMethodName    = "/odpf.optimus.core.v1beta1.SecretService/ListSecrets"
	SecretService_DeleteSecret_FullMethodName   = "/odpf.optimus.core.v1beta1.SecretService/DeleteSecret"
)

Variables

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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)

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: "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)

View Source 
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 

func (UnimplementedJobSpecificationServiceServer) RefreshJobs(*v1beta1.RefreshJobsRequest, JobSpecificationService_RefreshJobsServer) error

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.

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.