v1

package
v0.0.0-...-075ee23 Latest Latest
Warning

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

 Go to latest Published: Jun 29, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DeleteResponse_ResultType_name = map[int32]string{
		0: "DELETE_SUCCESS",
		1: "DELETE_ERROR",
		2: "DELETE_DENIED",
		3: "DELETE_NO_EXISTS",
	}
	DeleteResponse_ResultType_value = map[string]int32{
		"DELETE_SUCCESS":   0,
		"DELETE_ERROR":     1,
		"DELETE_DENIED":    2,
		"DELETE_NO_EXISTS": 3,
	}
)

Enum value maps for DeleteResponse_ResultType.

View Source 
var (
	UpdateStateResponse_ResultType_name = map[int32]string{
		0: "UPDATE_STATE_UNSPECIFIED",
		1: "UPDATE_STATE_PARTIAL",
		2: "UPDATE_STATE_SUCCESS",
		3: "UPDATE_STATE_ERROR",
	}
	UpdateStateResponse_ResultType_value = map[string]int32{
		"UPDATE_STATE_UNSPECIFIED": 0,
		"UPDATE_STATE_PARTIAL":     1,
		"UPDATE_STATE_SUCCESS":     2,
		"UPDATE_STATE_ERROR":       3,
	}
)

Enum value maps for UpdateStateResponse_ResultType.

View Source 
var (
	RegisterResponse_ResultType_name = map[int32]string{
		0: "REGISTER_UNSPECIFIED",
		1: "REGISTER_SUCCESS",
		2: "REGISTER_ERROR",
		3: "REGISTER_DENIED",
		4: "REGISTER_EXISTS",
	}
	RegisterResponse_ResultType_value = map[string]int32{
		"REGISTER_UNSPECIFIED": 0,
		"REGISTER_SUCCESS":     1,
		"REGISTER_ERROR":       2,
		"REGISTER_DENIED":      3,
		"REGISTER_EXISTS":      4,
	}
)

Enum value maps for RegisterResponse_ResultType.

View Source 
var (
	SubmitJobResponse_ResultType_name = map[int32]string{
		0: "SUBMIT_UNSPECIFIED",
		1: "SUBMIT_SUCCESS",
		2: "SUBMIT_ERROR",
		3: "SUBMIT_DENIED",
	}
	SubmitJobResponse_ResultType_value = map[string]int32{
		"SUBMIT_UNSPECIFIED": 0,
		"SUBMIT_SUCCESS":     1,
		"SUBMIT_ERROR":       2,
		"SUBMIT_DENIED":      3,
	}
)

Enum value maps for SubmitJobResponse_ResultType.

View Source 
var (
	ReceiveJobsResponse_ResultType_name = map[int32]string{
		0: "REQUEST_JOBS_NORESULTS",
		1: "REQUEST_JOBS_SUCCESS",
		2: "REQUEST_JOBS_ERROR",
		3: "REQUEST_JOBS_DENIED",
	}
	ReceiveJobsResponse_ResultType_value = map[string]int32{
		"REQUEST_JOBS_NORESULTS": 0,
		"REQUEST_JOBS_SUCCESS":   1,
		"REQUEST_JOBS_ERROR":     2,
		"REQUEST_JOBS_DENIED":    3,
	}
)

Enum value maps for ReceiveJobsResponse_ResultType.

View Source 
var (
	AcceptJobsResponse_ResultType_name = map[int32]string{
		0: "RESULT_TYPE_UNSPECIFIED",
		1: "RESULT_TYPE_PARTIAL",
		2: "RESULT_TYPE_SUCCESS",
		3: "RESULT_TYPE_ERROR",
	}
	AcceptJobsResponse_ResultType_value = map[string]int32{
		"RESULT_TYPE_UNSPECIFIED": 0,
		"RESULT_TYPE_PARTIAL":     1,
		"RESULT_TYPE_SUCCESS":     2,
		"RESULT_TYPE_ERROR":       3,
	}
)

Enum value maps for AcceptJobsResponse_ResultType.

View Source 
var File_rainbow_proto protoreflect.FileDescriptor
View Source 
var RainbowScheduler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "convergedcomputing.org.grpc.v1.RainbowScheduler",
	HandlerType: (*RainbowSchedulerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _RainbowScheduler_Register_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _RainbowScheduler_Delete_Handler,
		},
		{
			MethodName: "RegisterSubsystem",
			Handler:    _RainbowScheduler_RegisterSubsystem_Handler,
		},
		{
			MethodName: "DeleteSubsystem",
			Handler:    _RainbowScheduler_DeleteSubsystem_Handler,
		},
		{
			MethodName: "SubmitJob",
			Handler:    _RainbowScheduler_SubmitJob_Handler,
		},
		{
			MethodName: "UpdateState",
			Handler:    _RainbowScheduler_UpdateState_Handler,
		},
		{
			MethodName: "ReceiveJobs",
			Handler:    _RainbowScheduler_ReceiveJobs_Handler,
		},
		{
			MethodName: "AcceptJobs",
			Handler:    _RainbowScheduler_AcceptJobs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rainbow.proto",
}

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

Functions

func RegisterRainbowSchedulerServer 

func RegisterRainbowSchedulerServer(s grpc.ServiceRegistrar, srv RainbowSchedulerServer)

Types

type AcceptJobsRequest 

type AcceptJobsRequest struct {
	Cluster string                 `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Secret  string                 `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	Jobids  []int32                `protobuf:"varint,3,rep,packed,name=jobids,proto3" json:"jobids,omitempty"`
	Sent    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=sent,proto3" json:"sent,omitempty"`
	// contains filtered or unexported fields
}

N from a query. The response includes the ids that are accepted

func (*AcceptJobsRequest) Descriptor deprecated 

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

Deprecated: Use AcceptJobsRequest.ProtoReflect.Descriptor instead.

func (*AcceptJobsRequest) GetCluster 

func (x *AcceptJobsRequest) GetCluster() string

func (*AcceptJobsRequest) GetJobids 

func (x *AcceptJobsRequest) GetJobids() []int32

func (*AcceptJobsRequest) GetSecret 

func (x *AcceptJobsRequest) GetSecret() string

func (*AcceptJobsRequest) GetSent 

func (x *AcceptJobsRequest) GetSent() *timestamppb.Timestamp

func (*AcceptJobsRequest) ProtoMessage 

func (*AcceptJobsRequest) ProtoMessage()

func (*AcceptJobsRequest) ProtoReflect 

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

func (*AcceptJobsRequest) Reset 

func (x *AcceptJobsRequest) Reset()

func (*AcceptJobsRequest) String 

func (x *AcceptJobsRequest) String() string

type AcceptJobsResponse 

type AcceptJobsResponse struct {
	Status AcceptJobsResponse_ResultType `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

Accept Jobs Response

func (*AcceptJobsResponse) Descriptor deprecated 

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

Deprecated: Use AcceptJobsResponse.ProtoReflect.Descriptor instead.

func (*AcceptJobsResponse) GetStatus 

func (x *AcceptJobsResponse) GetStatus() AcceptJobsResponse_ResultType

func (*AcceptJobsResponse) ProtoMessage 

func (*AcceptJobsResponse) ProtoMessage()

func (*AcceptJobsResponse) ProtoReflect 

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

func (*AcceptJobsResponse) Reset 

func (x *AcceptJobsResponse) Reset()

func (*AcceptJobsResponse) String 

func (x *AcceptJobsResponse) String() string

type AcceptJobsResponse_ResultType 

type AcceptJobsResponse_ResultType int32
const (
	AcceptJobsResponse_RESULT_TYPE_UNSPECIFIED AcceptJobsResponse_ResultType = 0
	AcceptJobsResponse_RESULT_TYPE_PARTIAL     AcceptJobsResponse_ResultType = 1
	AcceptJobsResponse_RESULT_TYPE_SUCCESS     AcceptJobsResponse_ResultType = 2
	AcceptJobsResponse_RESULT_TYPE_ERROR       AcceptJobsResponse_ResultType = 3
)

func (AcceptJobsResponse_ResultType) Descriptor 

func (AcceptJobsResponse_ResultType) Descriptor() protoreflect.EnumDescriptor

func (AcceptJobsResponse_ResultType) Enum 

func (x AcceptJobsResponse_ResultType) Enum() *AcceptJobsResponse_ResultType

func (AcceptJobsResponse_ResultType) EnumDescriptor deprecated 

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

Deprecated: Use AcceptJobsResponse_ResultType.Descriptor instead.

func (AcceptJobsResponse_ResultType) Number 

func (x AcceptJobsResponse_ResultType) Number() protoreflect.EnumNumber

func (AcceptJobsResponse_ResultType) String 

func (x AcceptJobsResponse_ResultType) String() string

func (AcceptJobsResponse_ResultType) Type 

func (AcceptJobsResponse_ResultType) Type() protoreflect.EnumType

type DeleteRequest 

type DeleteRequest struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Secret   string `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	Subsytem string `protobuf:"bytes,3,opt,name=subsytem,proto3" json:"subsytem,omitempty"`
	// contains filtered or unexported fields
}

DeleteRequest handles deleting a cluster or subsystem

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetName 

func (x *DeleteRequest) GetName() string

func (*DeleteRequest) GetSecret 

func (x *DeleteRequest) GetSecret() string

func (*DeleteRequest) GetSubsytem 

func (x *DeleteRequest) GetSubsytem() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	Status DeleteResponse_ResultType `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

Delete Response

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetStatus 

func (x *DeleteResponse) GetStatus() DeleteResponse_ResultType

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type DeleteResponse_ResultType 

type DeleteResponse_ResultType int32
const (
	DeleteResponse_DELETE_SUCCESS   DeleteResponse_ResultType = 0
	DeleteResponse_DELETE_ERROR     DeleteResponse_ResultType = 1
	DeleteResponse_DELETE_DENIED    DeleteResponse_ResultType = 2
	DeleteResponse_DELETE_NO_EXISTS DeleteResponse_ResultType = 3
)

func (DeleteResponse_ResultType) Descriptor 

func (DeleteResponse_ResultType) Descriptor() protoreflect.EnumDescriptor

func (DeleteResponse_ResultType) Enum 

func (x DeleteResponse_ResultType) Enum() *DeleteResponse_ResultType

func (DeleteResponse_ResultType) EnumDescriptor deprecated 

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

Deprecated: Use DeleteResponse_ResultType.Descriptor instead.

func (DeleteResponse_ResultType) Number 

func (x DeleteResponse_ResultType) Number() protoreflect.EnumNumber

func (DeleteResponse_ResultType) String 

func (x DeleteResponse_ResultType) String() string

func (DeleteResponse_ResultType) Type 

func (DeleteResponse_ResultType) Type() protoreflect.EnumType

type RainbowSchedulerClient 

type RainbowSchedulerClient interface {
	// Register cluster - request to register a new cluster
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	// Delete cluster - request to delete a cluster
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Register subsystem - request to register a new cluster
	RegisterSubsystem(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	// Delete Subsystems - request to delete subsystems
	DeleteSubsystem(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Job Submission - request for submitting a job to a named cluster
	SubmitJob(ctx context.Context, in *SubmitJobRequest, opts ...grpc.CallOption) (*SubmitJobResponse, error)
	// Update State - allow a cluster to provide state metadata
	// This is intended for use by a selection algorithm
	UpdateState(ctx context.Context, in *UpdateStateRequest, opts ...grpc.CallOption) (*UpdateStateResponse, error)
	// Request Job - ask the rainbow scheduler for up to max jobs
	ReceiveJobs(ctx context.Context, in *ReceiveJobsRequest, opts ...grpc.CallOption) (*ReceiveJobsResponse, error)
	// Accept Jobs - accept some number of jobs
	AcceptJobs(ctx context.Context, in *AcceptJobsRequest, opts ...grpc.CallOption) (*AcceptJobsResponse, error)
}

RainbowSchedulerClient is the client API for RainbowScheduler 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 NewRainbowSchedulerClient 

func NewRainbowSchedulerClient(cc grpc.ClientConnInterface) RainbowSchedulerClient

type RainbowSchedulerServer 

type RainbowSchedulerServer interface {
	// Register cluster - request to register a new cluster
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	// Delete cluster - request to delete a cluster
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Register subsystem - request to register a new cluster
	RegisterSubsystem(context.Context, *RegisterRequest) (*RegisterResponse, error)
	// Delete Subsystems - request to delete subsystems
	DeleteSubsystem(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Job Submission - request for submitting a job to a named cluster
	SubmitJob(context.Context, *SubmitJobRequest) (*SubmitJobResponse, error)
	// Update State - allow a cluster to provide state metadata
	// This is intended for use by a selection algorithm
	UpdateState(context.Context, *UpdateStateRequest) (*UpdateStateResponse, error)
	// Request Job - ask the rainbow scheduler for up to max jobs
	ReceiveJobs(context.Context, *ReceiveJobsRequest) (*ReceiveJobsResponse, error)
	// Accept Jobs - accept some number of jobs
	AcceptJobs(context.Context, *AcceptJobsRequest) (*AcceptJobsResponse, error)
	// contains filtered or unexported methods
}

RainbowSchedulerServer is the server API for RainbowScheduler service. All implementations must embed UnimplementedRainbowSchedulerServer for forward compatibility

type ReceiveJobsRequest 

type ReceiveJobsRequest struct {
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// cluster secret given on registration
	// No other cluster or user can take a cluster's jobs!
	Secret string `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	// Max jobs to request
	MaxJobs int32                  `protobuf:"varint,3,opt,name=maxJobs,proto3" json:"maxJobs,omitempty"`
	Sent    *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=sent,proto3" json:"sent,omitempty"`
	// contains filtered or unexported fields
}

RequestJobsRequest is used by a cluster (or other entity that can run jobs) to get back a maximum of N jobs. This will (and should) eventually support filters / sorting criteria, but now we just take the top N from a query. The response includes the ids that are accepted

func (*ReceiveJobsRequest) Descriptor deprecated 

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

Deprecated: Use ReceiveJobsRequest.ProtoReflect.Descriptor instead.

func (*ReceiveJobsRequest) GetCluster 

func (x *ReceiveJobsRequest) GetCluster() string

func (*ReceiveJobsRequest) GetMaxJobs 

func (x *ReceiveJobsRequest) GetMaxJobs() int32

func (*ReceiveJobsRequest) GetSecret 

func (x *ReceiveJobsRequest) GetSecret() string

func (*ReceiveJobsRequest) GetSent 

func (x *ReceiveJobsRequest) GetSent() *timestamppb.Timestamp

func (*ReceiveJobsRequest) ProtoMessage 

func (*ReceiveJobsRequest) ProtoMessage()

func (*ReceiveJobsRequest) ProtoReflect 

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

func (*ReceiveJobsRequest) Reset 

func (x *ReceiveJobsRequest) Reset()

func (*ReceiveJobsRequest) String 

func (x *ReceiveJobsRequest) String() string

type ReceiveJobsResponse 

type ReceiveJobsResponse struct {
	RequestId string           `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Jobs      map[int32]string `` /* 150-byte string literal not displayed */
	// repeated int32 accepted_jobids = 2;
	Status ReceiveJobsResponse_ResultType `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

RequestJobsResponse

func (*ReceiveJobsResponse) Descriptor deprecated 

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

Deprecated: Use ReceiveJobsResponse.ProtoReflect.Descriptor instead.

func (*ReceiveJobsResponse) GetJobs 

func (x *ReceiveJobsResponse) GetJobs() map[int32]string

func (*ReceiveJobsResponse) GetRequestId 

func (x *ReceiveJobsResponse) GetRequestId() string

func (*ReceiveJobsResponse) GetStatus 

func (x *ReceiveJobsResponse) GetStatus() ReceiveJobsResponse_ResultType

func (*ReceiveJobsResponse) ProtoMessage 

func (*ReceiveJobsResponse) ProtoMessage()

func (*ReceiveJobsResponse) ProtoReflect 

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

func (*ReceiveJobsResponse) Reset 

func (x *ReceiveJobsResponse) Reset()

func (*ReceiveJobsResponse) String 

func (x *ReceiveJobsResponse) String() string

type ReceiveJobsResponse_ResultType 

type ReceiveJobsResponse_ResultType int32

Enum to represent the result types of the operation. 

const (
	ReceiveJobsResponse_REQUEST_JOBS_NORESULTS ReceiveJobsResponse_ResultType = 0
	ReceiveJobsResponse_REQUEST_JOBS_SUCCESS   ReceiveJobsResponse_ResultType = 1
	ReceiveJobsResponse_REQUEST_JOBS_ERROR     ReceiveJobsResponse_ResultType = 2
	ReceiveJobsResponse_REQUEST_JOBS_DENIED    ReceiveJobsResponse_ResultType = 3
)

func (ReceiveJobsResponse_ResultType) Descriptor 

func (ReceiveJobsResponse_ResultType) Descriptor() protoreflect.EnumDescriptor

func (ReceiveJobsResponse_ResultType) Enum 

func (x ReceiveJobsResponse_ResultType) Enum() *ReceiveJobsResponse_ResultType

func (ReceiveJobsResponse_ResultType) EnumDescriptor deprecated 

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

Deprecated: Use ReceiveJobsResponse_ResultType.Descriptor instead.

func (ReceiveJobsResponse_ResultType) Number 

func (x ReceiveJobsResponse_ResultType) Number() protoreflect.EnumNumber

func (ReceiveJobsResponse_ResultType) String 

func (x ReceiveJobsResponse_ResultType) String() string

func (ReceiveJobsResponse_ResultType) Type 

func (ReceiveJobsResponse_ResultType) Type() protoreflect.EnumType

type RegisterRequest 

type RegisterRequest struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Secret string `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	// JGF json of nodes (needs to be read in with jsongraph-go)
	Nodes     string                 `protobuf:"bytes,3,opt,name=nodes,proto3" json:"nodes,omitempty"`
	Subsystem string                 `protobuf:"bytes,4,opt,name=subsystem,proto3" json:"subsystem,omitempty"`
	Sent      *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=sent,proto3" json:"sent,omitempty"`
	// contains filtered or unexported fields
}

RegisterRequest registers a cluster to the scheduler service The shared secret is required to validate the request

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetName 

func (x *RegisterRequest) GetName() string

func (*RegisterRequest) GetNodes 

func (x *RegisterRequest) GetNodes() string

func (*RegisterRequest) GetSecret 

func (x *RegisterRequest) GetSecret() string

func (*RegisterRequest) GetSent 

func (x *RegisterRequest) GetSent() *timestamppb.Timestamp

func (*RegisterRequest) GetSubsystem 

func (x *RegisterRequest) GetSubsystem() string

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type RegisterResponse 

type RegisterResponse struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// The "token" is given to clients (or this cluster) to submit jobs
	// In the future this should be able to be refreshed
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// The "secret" is for this cluster to receive them.
	Secret string                      `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	Status RegisterResponse_ResultType `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

Register Response

func (*RegisterResponse) Descriptor deprecated 

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetRequestId 

func (x *RegisterResponse) GetRequestId() string

func (*RegisterResponse) GetSecret 

func (x *RegisterResponse) GetSecret() string

func (*RegisterResponse) GetStatus 

func (x *RegisterResponse) GetStatus() RegisterResponse_ResultType

func (*RegisterResponse) GetToken 

func (x *RegisterResponse) GetToken() string

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect 

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

func (*RegisterResponse) Reset 

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (x *RegisterResponse) String() string

type RegisterResponse_ResultType 

type RegisterResponse_ResultType int32

Registration statuses 

const (
	RegisterResponse_REGISTER_UNSPECIFIED RegisterResponse_ResultType = 0
	RegisterResponse_REGISTER_SUCCESS     RegisterResponse_ResultType = 1
	RegisterResponse_REGISTER_ERROR       RegisterResponse_ResultType = 2
	RegisterResponse_REGISTER_DENIED      RegisterResponse_ResultType = 3
	RegisterResponse_REGISTER_EXISTS      RegisterResponse_ResultType = 4
)

func (RegisterResponse_ResultType) Descriptor 

func (RegisterResponse_ResultType) Descriptor() protoreflect.EnumDescriptor

func (RegisterResponse_ResultType) Enum 

func (x RegisterResponse_ResultType) Enum() *RegisterResponse_ResultType

func (RegisterResponse_ResultType) EnumDescriptor deprecated 

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

Deprecated: Use RegisterResponse_ResultType.Descriptor instead.

func (RegisterResponse_ResultType) Number 

func (x RegisterResponse_ResultType) Number() protoreflect.EnumNumber

func (RegisterResponse_ResultType) String 

func (x RegisterResponse_ResultType) String() string

func (RegisterResponse_ResultType) Type 

func (RegisterResponse_ResultType) Type() protoreflect.EnumType

type SubmitJobRequest 

type SubmitJobRequest struct {
	Name            string                      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Clusters        []*SubmitJobRequest_Cluster `protobuf:"bytes,2,rep,name=clusters,proto3" json:"clusters,omitempty"`
	Jobspec         string                      `protobuf:"bytes,3,opt,name=jobspec,proto3" json:"jobspec,omitempty"`
	SelectAlgorithm string                      `protobuf:"bytes,4,opt,name=select_algorithm,json=selectAlgorithm,proto3" json:"select_algorithm,omitempty"`
	SelectOptions   map[string]string           `` /* 188-byte string literal not displayed */
	SatisfyOnly     bool                        `protobuf:"varint,6,opt,name=satisfy_only,json=satisfyOnly,proto3" json:"satisfy_only,omitempty"`
	Sent            *timestamppb.Timestamp      `protobuf:"bytes,7,opt,name=sent,proto3" json:"sent,omitempty"`
	// contains filtered or unexported fields
}

SubmitJobRequest takes a job name, cluster name and requires the cluster token. Since we want to be generic, we currently accept nodes, tasks, and the command

func (*SubmitJobRequest) Descriptor deprecated 

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

Deprecated: Use SubmitJobRequest.ProtoReflect.Descriptor instead.

func (*SubmitJobRequest) GetClusters 

func (x *SubmitJobRequest) GetClusters() []*SubmitJobRequest_Cluster

func (*SubmitJobRequest) GetJobspec 

func (x *SubmitJobRequest) GetJobspec() string

func (*SubmitJobRequest) GetName 

func (x *SubmitJobRequest) GetName() string

func (*SubmitJobRequest) GetSatisfyOnly 

func (x *SubmitJobRequest) GetSatisfyOnly() bool

func (*SubmitJobRequest) GetSelectAlgorithm 

func (x *SubmitJobRequest) GetSelectAlgorithm() string

func (*SubmitJobRequest) GetSelectOptions 

func (x *SubmitJobRequest) GetSelectOptions() map[string]string

func (*SubmitJobRequest) GetSent 

func (x *SubmitJobRequest) GetSent() *timestamppb.Timestamp

func (*SubmitJobRequest) ProtoMessage 

func (*SubmitJobRequest) ProtoMessage()

func (*SubmitJobRequest) ProtoReflect 

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

func (*SubmitJobRequest) Reset 

func (x *SubmitJobRequest) Reset()

func (*SubmitJobRequest) String 

func (x *SubmitJobRequest) String() string

type SubmitJobRequest_Cluster 

type SubmitJobRequest_Cluster struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitJobRequest_Cluster) Descriptor deprecated 

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

Deprecated: Use SubmitJobRequest_Cluster.ProtoReflect.Descriptor instead.

func (*SubmitJobRequest_Cluster) GetName 

func (x *SubmitJobRequest_Cluster) GetName() string

func (*SubmitJobRequest_Cluster) GetToken 

func (x *SubmitJobRequest_Cluster) GetToken() string

func (*SubmitJobRequest_Cluster) ProtoMessage 

func (*SubmitJobRequest_Cluster) ProtoMessage()

func (*SubmitJobRequest_Cluster) ProtoReflect 

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

func (*SubmitJobRequest_Cluster) Reset 

func (x *SubmitJobRequest_Cluster) Reset()

func (*SubmitJobRequest_Cluster) String 

func (x *SubmitJobRequest_Cluster) String() string

type SubmitJobResponse 

type SubmitJobResponse struct {
	RequestId string                       `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Jobid     int32                        `protobuf:"varint,2,opt,name=jobid,proto3" json:"jobid,omitempty"`
	Cluster   string                       `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Status    SubmitJobResponse_ResultType `` /* 131-byte string literal not displayed */
	// A SatisfyOnly request can return the entire selected set
	Clusters []string `protobuf:"bytes,5,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

Submit Job Response

func (*SubmitJobResponse) Descriptor deprecated 

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

Deprecated: Use SubmitJobResponse.ProtoReflect.Descriptor instead.

func (*SubmitJobResponse) GetCluster 

func (x *SubmitJobResponse) GetCluster() string

func (*SubmitJobResponse) GetClusters 

func (x *SubmitJobResponse) GetClusters() []string

func (*SubmitJobResponse) GetJobid 

func (x *SubmitJobResponse) GetJobid() int32

func (*SubmitJobResponse) GetRequestId 

func (x *SubmitJobResponse) GetRequestId() string

func (*SubmitJobResponse) GetStatus 

func (x *SubmitJobResponse) GetStatus() SubmitJobResponse_ResultType

func (*SubmitJobResponse) ProtoMessage 

func (*SubmitJobResponse) ProtoMessage()

func (*SubmitJobResponse) ProtoReflect 

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

func (*SubmitJobResponse) Reset 

func (x *SubmitJobResponse) Reset()

func (*SubmitJobResponse) String 

func (x *SubmitJobResponse) String() string

type SubmitJobResponse_ResultType 

type SubmitJobResponse_ResultType int32

Enum to represent the result types of the operation. 

const (
	SubmitJobResponse_SUBMIT_UNSPECIFIED SubmitJobResponse_ResultType = 0
	SubmitJobResponse_SUBMIT_SUCCESS     SubmitJobResponse_ResultType = 1
	SubmitJobResponse_SUBMIT_ERROR       SubmitJobResponse_ResultType = 2
	SubmitJobResponse_SUBMIT_DENIED      SubmitJobResponse_ResultType = 3
)

func (SubmitJobResponse_ResultType) Descriptor 

func (SubmitJobResponse_ResultType) Descriptor() protoreflect.EnumDescriptor

func (SubmitJobResponse_ResultType) Enum 

func (x SubmitJobResponse_ResultType) Enum() *SubmitJobResponse_ResultType

func (SubmitJobResponse_ResultType) EnumDescriptor deprecated 

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

Deprecated: Use SubmitJobResponse_ResultType.Descriptor instead.

func (SubmitJobResponse_ResultType) Number 

func (x SubmitJobResponse_ResultType) Number() protoreflect.EnumNumber

func (SubmitJobResponse_ResultType) String 

func (x SubmitJobResponse_ResultType) String() string

func (SubmitJobResponse_ResultType) Type 

func (SubmitJobResponse_ResultType) Type() protoreflect.EnumType

type UnimplementedRainbowSchedulerServer 

type UnimplementedRainbowSchedulerServer struct {
}

UnimplementedRainbowSchedulerServer must be embedded to have forward compatible implementations.

func (UnimplementedRainbowSchedulerServer) AcceptJobs 

func (UnimplementedRainbowSchedulerServer) AcceptJobs(context.Context, *AcceptJobsRequest) (*AcceptJobsResponse, error)

func (UnimplementedRainbowSchedulerServer) Delete 

func (UnimplementedRainbowSchedulerServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedRainbowSchedulerServer) DeleteSubsystem 

func (UnimplementedRainbowSchedulerServer) DeleteSubsystem(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedRainbowSchedulerServer) ReceiveJobs 

func (UnimplementedRainbowSchedulerServer) ReceiveJobs(context.Context, *ReceiveJobsRequest) (*ReceiveJobsResponse, error)

func (UnimplementedRainbowSchedulerServer) Register 

func (UnimplementedRainbowSchedulerServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)

func (UnimplementedRainbowSchedulerServer) RegisterSubsystem 

func (UnimplementedRainbowSchedulerServer) RegisterSubsystem(context.Context, *RegisterRequest) (*RegisterResponse, error)

func (UnimplementedRainbowSchedulerServer) SubmitJob 

func (UnimplementedRainbowSchedulerServer) SubmitJob(context.Context, *SubmitJobRequest) (*SubmitJobResponse, error)

func (UnimplementedRainbowSchedulerServer) UpdateState 

func (UnimplementedRainbowSchedulerServer) UpdateState(context.Context, *UpdateStateRequest) (*UpdateStateResponse, error)

type UnsafeRainbowSchedulerServer 

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

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

type UpdateStateRequest 

type UpdateStateRequest struct {
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Secret  string `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	// We are generous that the payload can be a flat
	// set of key value pairs, and will be parsed into
	// types within the graph database
	Payload string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

UpdateStateRequests allows a cluster to set arbitrary metadata for its state. State metadata is used for selection algorithms

func (*UpdateStateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateStateRequest) GetCluster 

func (x *UpdateStateRequest) GetCluster() string

func (*UpdateStateRequest) GetPayload 

func (x *UpdateStateRequest) GetPayload() string

func (*UpdateStateRequest) GetSecret 

func (x *UpdateStateRequest) GetSecret() string

func (*UpdateStateRequest) ProtoMessage 

func (*UpdateStateRequest) ProtoMessage()

func (*UpdateStateRequest) ProtoReflect 

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

func (*UpdateStateRequest) Reset 

func (x *UpdateStateRequest) Reset()

func (*UpdateStateRequest) String 

func (x *UpdateStateRequest) String() string

type UpdateStateResponse 

type UpdateStateResponse struct {
	Status UpdateStateResponse_ResultType `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateStateResponse) Descriptor deprecated 

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

Deprecated: Use UpdateStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateStateResponse) GetStatus 

func (x *UpdateStateResponse) GetStatus() UpdateStateResponse_ResultType

func (*UpdateStateResponse) ProtoMessage 

func (*UpdateStateResponse) ProtoMessage()

func (*UpdateStateResponse) ProtoReflect 

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

func (*UpdateStateResponse) Reset 

func (x *UpdateStateResponse) Reset()

func (*UpdateStateResponse) String 

func (x *UpdateStateResponse) String() string

type UpdateStateResponse_ResultType 

type UpdateStateResponse_ResultType int32
const (
	UpdateStateResponse_UPDATE_STATE_UNSPECIFIED UpdateStateResponse_ResultType = 0
	UpdateStateResponse_UPDATE_STATE_PARTIAL     UpdateStateResponse_ResultType = 1
	UpdateStateResponse_UPDATE_STATE_SUCCESS     UpdateStateResponse_ResultType = 2
	UpdateStateResponse_UPDATE_STATE_ERROR       UpdateStateResponse_ResultType = 3
)

func (UpdateStateResponse_ResultType) Descriptor 

func (UpdateStateResponse_ResultType) Descriptor() protoreflect.EnumDescriptor

func (UpdateStateResponse_ResultType) Enum 

func (x UpdateStateResponse_ResultType) Enum() *UpdateStateResponse_ResultType

func (UpdateStateResponse_ResultType) EnumDescriptor deprecated 

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

Deprecated: Use UpdateStateResponse_ResultType.Descriptor instead.

func (UpdateStateResponse_ResultType) Number 

func (x UpdateStateResponse_ResultType) Number() protoreflect.EnumNumber

func (UpdateStateResponse_ResultType) String 

func (x UpdateStateResponse_ResultType) String() string

func (UpdateStateResponse_ResultType) Type 

func (UpdateStateResponse_ResultType) Type() protoreflect.EnumType

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.