supervisorv1alpha1

package
v0.16.2 Latest Latest
Warning

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

 Go to latest Published: Dec 1, 2023 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	JobStatus_name = map[int32]string{
		0:  "JOB_STATUS_UNSPECIFIED",
		1:  "JOB_STATUS_PENDING",
		2:  "JOB_STATUS_META_SCHEDULED",
		3:  "JOB_STATUS_SCHEDULED",
		4:  "JOB_STATUS_RUNNING",
		5:  "JOB_STATUS_CANCELLING",
		6:  "JOB_STATUS_CANCELLED",
		7:  "JOB_STATUS_FINISHED",
		8:  "JOB_STATUS_FAILED",
		9:  "JOB_STATUS_OUT_OF_CREDITS",
		10: "JOB_STATUS_PANICKED",
	}
	JobStatus_value = map[string]int32{
		"JOB_STATUS_UNSPECIFIED":    0,
		"JOB_STATUS_PENDING":        1,
		"JOB_STATUS_META_SCHEDULED": 2,
		"JOB_STATUS_SCHEDULED":      3,
		"JOB_STATUS_RUNNING":        4,
		"JOB_STATUS_CANCELLING":     5,
		"JOB_STATUS_CANCELLED":      6,
		"JOB_STATUS_FINISHED":       7,
		"JOB_STATUS_FAILED":         8,
		"JOB_STATUS_OUT_OF_CREDITS": 9,
		"JOB_STATUS_PANICKED":       10,
	}
)

Enum value maps for JobStatus.

View Source 
var File_supervisor_v1alpha1_job_proto protoreflect.FileDescriptor
View Source 
var File_supervisor_v1alpha1_ssh_proto protoreflect.FileDescriptor
View Source 
var JobAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "supervisor.v1alpha1.JobAPI",
	HandlerType: (*JobAPIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SetJobStatus",
			Handler:    _JobAPI_SetJobStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "supervisor/v1alpha1/job.proto",
}

JobAPI_ServiceDesc is the grpc.ServiceDesc for JobAPI 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 SshAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "supervisor.v1alpha1.SshAPI",
	HandlerType: (*SshAPIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FetchAuthorizedKeys",
			Handler:    _SshAPI_FetchAuthorizedKeys_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "supervisor/v1alpha1/ssh.proto",
}

SshAPI_ServiceDesc is the grpc.ServiceDesc for SshAPI service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterJobAPIServer 

func RegisterJobAPIServer(s grpc.ServiceRegistrar, srv JobAPIServer)

func RegisterSshAPIServer 

func RegisterSshAPIServer(s grpc.ServiceRegistrar, srv SshAPIServer)

Types

type FetchAuthorizedKeysRequest 

type FetchAuthorizedKeysRequest struct {
	// contains filtered or unexported fields
}

func (*FetchAuthorizedKeysRequest) Descriptor deprecated 

func (*FetchAuthorizedKeysRequest) Descriptor() ([]byte, []int)

Deprecated: Use FetchAuthorizedKeysRequest.ProtoReflect.Descriptor instead.

func (*FetchAuthorizedKeysRequest) ProtoMessage 

func (*FetchAuthorizedKeysRequest) ProtoMessage()

func (*FetchAuthorizedKeysRequest) ProtoReflect 

func (x *FetchAuthorizedKeysRequest) ProtoReflect() protoreflect.Message

func (*FetchAuthorizedKeysRequest) Reset 

func (x *FetchAuthorizedKeysRequest) Reset()

func (*FetchAuthorizedKeysRequest) String 

func (x *FetchAuthorizedKeysRequest) String() string

type FetchAuthorizedKeysResponse 

type FetchAuthorizedKeysResponse struct {
	AuthorizedKeys string `protobuf:"bytes,1,opt,name=authorized_keys,json=authorizedKeys,proto3" json:"authorized_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchAuthorizedKeysResponse) Descriptor deprecated 

func (*FetchAuthorizedKeysResponse) Descriptor() ([]byte, []int)

Deprecated: Use FetchAuthorizedKeysResponse.ProtoReflect.Descriptor instead.

func (*FetchAuthorizedKeysResponse) GetAuthorizedKeys 

func (x *FetchAuthorizedKeysResponse) GetAuthorizedKeys() string

func (*FetchAuthorizedKeysResponse) ProtoMessage 

func (*FetchAuthorizedKeysResponse) ProtoMessage()

func (*FetchAuthorizedKeysResponse) ProtoReflect 

func (x *FetchAuthorizedKeysResponse) ProtoReflect() protoreflect.Message

func (*FetchAuthorizedKeysResponse) Reset 

func (x *FetchAuthorizedKeysResponse) Reset()

func (*FetchAuthorizedKeysResponse) String 

func (x *FetchAuthorizedKeysResponse) String() string

type JobAPIClient 

type JobAPIClient interface {
	SetJobStatus(ctx context.Context, in *SetJobStatusRequest, opts ...grpc.CallOption) (*SetJobStatusResponse, error)
}

JobAPIClient is the client API for JobAPI 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 NewJobAPIClient 

func NewJobAPIClient(cc grpc.ClientConnInterface) JobAPIClient

type JobAPIServer 

type JobAPIServer interface {
	SetJobStatus(context.Context, *SetJobStatusRequest) (*SetJobStatusResponse, error)
	// contains filtered or unexported methods
}

JobAPIServer is the server API for JobAPI service. All implementations must embed UnimplementedJobAPIServer for forward compatibility

type JobStatus 

type JobStatus int32
const (
	JobStatus_JOB_STATUS_UNSPECIFIED    JobStatus = 0
	JobStatus_JOB_STATUS_PENDING        JobStatus = 1
	JobStatus_JOB_STATUS_META_SCHEDULED JobStatus = 2
	JobStatus_JOB_STATUS_SCHEDULED      JobStatus = 3
	JobStatus_JOB_STATUS_RUNNING        JobStatus = 4
	JobStatus_JOB_STATUS_CANCELLING     JobStatus = 5
	JobStatus_JOB_STATUS_CANCELLED      JobStatus = 6
	JobStatus_JOB_STATUS_FINISHED       JobStatus = 7
	JobStatus_JOB_STATUS_FAILED         JobStatus = 8
	JobStatus_JOB_STATUS_OUT_OF_CREDITS JobStatus = 9
	JobStatus_JOB_STATUS_PANICKED       JobStatus = 10
)

func (JobStatus) Descriptor 

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum 

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor deprecated 

func (JobStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number 

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String 

func (x JobStatus) String() string

func (JobStatus) Type 

func (JobStatus) Type() protoreflect.EnumType

type SetJobStatusRequest 

type SetJobStatusRequest struct {
	Name     string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id       uint64    `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Duration uint64    `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"`
	Status   JobStatus `protobuf:"varint,4,opt,name=status,proto3,enum=supervisor.v1alpha1.JobStatus" json:"status,omitempty"`
	ExitCode int64     `protobuf:"varint,5,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

func (*SetJobStatusRequest) Descriptor deprecated 

func (*SetJobStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetJobStatusRequest.ProtoReflect.Descriptor instead.

func (*SetJobStatusRequest) GetDuration 

func (x *SetJobStatusRequest) GetDuration() uint64

func (*SetJobStatusRequest) GetExitCode added in v0.14.0 

func (x *SetJobStatusRequest) GetExitCode() int64

func (*SetJobStatusRequest) GetId 

func (x *SetJobStatusRequest) GetId() uint64

func (*SetJobStatusRequest) GetName 

func (x *SetJobStatusRequest) GetName() string

func (*SetJobStatusRequest) GetStatus 

func (x *SetJobStatusRequest) GetStatus() JobStatus

func (*SetJobStatusRequest) ProtoMessage 

func (*SetJobStatusRequest) ProtoMessage()

func (*SetJobStatusRequest) ProtoReflect 

func (x *SetJobStatusRequest) ProtoReflect() protoreflect.Message

func (*SetJobStatusRequest) Reset 

func (x *SetJobStatusRequest) Reset()

func (*SetJobStatusRequest) String 

func (x *SetJobStatusRequest) String() string

type SetJobStatusResponse 

type SetJobStatusResponse struct {
	// contains filtered or unexported fields
}

func (*SetJobStatusResponse) Descriptor deprecated 

func (*SetJobStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetJobStatusResponse.ProtoReflect.Descriptor instead.

func (*SetJobStatusResponse) ProtoMessage 

func (*SetJobStatusResponse) ProtoMessage()

func (*SetJobStatusResponse) ProtoReflect 

func (x *SetJobStatusResponse) ProtoReflect() protoreflect.Message

func (*SetJobStatusResponse) Reset 

func (x *SetJobStatusResponse) Reset()

func (*SetJobStatusResponse) String 

func (x *SetJobStatusResponse) String() string

type SshAPIClient 

type SshAPIClient interface {
	FetchAuthorizedKeys(ctx context.Context, in *FetchAuthorizedKeysRequest, opts ...grpc.CallOption) (*FetchAuthorizedKeysResponse, error)
}

SshAPIClient is the client API for SshAPI 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 NewSshAPIClient 

func NewSshAPIClient(cc grpc.ClientConnInterface) SshAPIClient

type SshAPIServer 

type SshAPIServer interface {
	FetchAuthorizedKeys(context.Context, *FetchAuthorizedKeysRequest) (*FetchAuthorizedKeysResponse, error)
	// contains filtered or unexported methods
}

SshAPIServer is the server API for SshAPI service. All implementations must embed UnimplementedSshAPIServer for forward compatibility

type UnimplementedJobAPIServer 

type UnimplementedJobAPIServer struct {
}

UnimplementedJobAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedJobAPIServer) SetJobStatus 

func (UnimplementedJobAPIServer) SetJobStatus(context.Context, *SetJobStatusRequest) (*SetJobStatusResponse, error)

type UnimplementedSshAPIServer 

type UnimplementedSshAPIServer struct {
}

UnimplementedSshAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedSshAPIServer) FetchAuthorizedKeys 

func (UnimplementedSshAPIServer) FetchAuthorizedKeys(context.Context, *FetchAuthorizedKeysRequest) (*FetchAuthorizedKeysResponse, error)

type UnsafeJobAPIServer 

type UnsafeJobAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeJobAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobAPIServer will result in compilation errors.

type UnsafeSshAPIServer 

type UnsafeSshAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeSshAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SshAPIServer 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.