fluxion_grpc

package
v0.0.0-...-529ef22 Latest Latest
Warning

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

 Go to latest Published: May 3, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	InitResponse_ResultType_name = map[int32]string{
		0: "INIT_SUCCESS",
		1: "INIT_ERROR",
		2: "INIT_DENIED",
	}
	InitResponse_ResultType_value = map[string]int32{
		"INIT_SUCCESS": 0,
		"INIT_ERROR":   1,
		"INIT_DENIED":  2,
	}
)

Enum value maps for InitResponse_ResultType.

View Source 
var (
	MatchResponse_ResultType_name = map[int32]string{
		0: "MATCH_SUCCESS",
		1: "MATCH_ERROR",
		2: "MATCH_DENIED",
	}
	MatchResponse_ResultType_value = map[string]int32{
		"MATCH_SUCCESS": 0,
		"MATCH_ERROR":   1,
		"MATCH_DENIED":  2,
	}
)

Enum value maps for MatchResponse_ResultType.

View Source 
var (
	CancelResponse_ResultType_name = map[int32]string{
		0: "CANCEL_SUCCESS",
		1: "CANCEL_REQUEST_ERROR",
		2: "CANCEL_ERROR",
		3: "CANCEL_DENIED",
	}
	CancelResponse_ResultType_value = map[string]int32{
		"CANCEL_SUCCESS":       0,
		"CANCEL_REQUEST_ERROR": 1,
		"CANCEL_ERROR":         2,
		"CANCEL_DENIED":        3,
	}
)

Enum value maps for CancelResponse_ResultType.

View Source 
var File_pkg_fluxion_grpc_fluxion_proto protoreflect.FileDescriptor
View Source 
var FluxionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "fluxion.FluxionService",
	HandlerType: (*FluxionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Match",
			Handler:    _FluxionService_Match_Handler,
		},
		{
			MethodName: "Cancel",
			Handler:    _FluxionService_Cancel_Handler,
		},
		{
			MethodName: "Init",
			Handler:    _FluxionService_Init_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/fluxion-grpc/fluxion.proto",
}

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

Functions

func RegisterFluxionServiceServer 

func RegisterFluxionServiceServer(s grpc.ServiceRegistrar, srv FluxionServiceServer)

Types

type CancelRequest 

type CancelRequest struct {
	JobID int64 `protobuf:"varint,2,opt,name=jobID,proto3" json:"jobID,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelRequest) Descriptor deprecated 

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

Deprecated: Use CancelRequest.ProtoReflect.Descriptor instead.

func (*CancelRequest) GetJobID 

func (x *CancelRequest) GetJobID() int64

func (*CancelRequest) ProtoMessage 

func (*CancelRequest) ProtoMessage()

func (*CancelRequest) ProtoReflect 

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

func (*CancelRequest) Reset 

func (x *CancelRequest) Reset()

func (*CancelRequest) String 

func (x *CancelRequest) String() string

type CancelResponse 

type CancelResponse struct {
	JobID  int64                     `protobuf:"varint,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	Error  int32                     `protobuf:"varint,2,opt,name=error,proto3" json:"error,omitempty"`
	Status CancelResponse_ResultType `protobuf:"varint,3,opt,name=status,proto3,enum=fluxion.CancelResponse_ResultType" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The Match response message

func (*CancelResponse) Descriptor deprecated 

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

Deprecated: Use CancelResponse.ProtoReflect.Descriptor instead.

func (*CancelResponse) GetError 

func (x *CancelResponse) GetError() int32

func (*CancelResponse) GetJobID 

func (x *CancelResponse) GetJobID() int64

func (*CancelResponse) GetStatus 

func (x *CancelResponse) GetStatus() CancelResponse_ResultType

func (*CancelResponse) ProtoMessage 

func (*CancelResponse) ProtoMessage()

func (*CancelResponse) ProtoReflect 

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

func (*CancelResponse) Reset 

func (x *CancelResponse) Reset()

func (*CancelResponse) String 

func (x *CancelResponse) String() string

type CancelResponse_ResultType 

type CancelResponse_ResultType int32
const (
	CancelResponse_CANCEL_SUCCESS       CancelResponse_ResultType = 0
	CancelResponse_CANCEL_REQUEST_ERROR CancelResponse_ResultType = 1
	CancelResponse_CANCEL_ERROR         CancelResponse_ResultType = 2
	CancelResponse_CANCEL_DENIED        CancelResponse_ResultType = 3
)

func (CancelResponse_ResultType) Descriptor 

func (CancelResponse_ResultType) Descriptor() protoreflect.EnumDescriptor

func (CancelResponse_ResultType) Enum 

func (x CancelResponse_ResultType) Enum() *CancelResponse_ResultType

func (CancelResponse_ResultType) EnumDescriptor deprecated 

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

Deprecated: Use CancelResponse_ResultType.Descriptor instead.

func (CancelResponse_ResultType) Number 

func (x CancelResponse_ResultType) Number() protoreflect.EnumNumber

func (CancelResponse_ResultType) String 

func (x CancelResponse_ResultType) String() string

func (CancelResponse_ResultType) Type 

func (CancelResponse_ResultType) Type() protoreflect.EnumType

type FluxionServiceClient 

type FluxionServiceClient interface {
	// Sends a Match command
	Match(ctx context.Context, in *MatchRequest, opts ...grpc.CallOption) (*MatchResponse, error)
	Cancel(ctx context.Context, in *CancelRequest, opts ...grpc.CallOption) (*CancelResponse, error)
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)
}

FluxionServiceClient is the client API for FluxionService 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 NewFluxionServiceClient 

func NewFluxionServiceClient(cc grpc.ClientConnInterface) FluxionServiceClient

type FluxionServiceServer 

type FluxionServiceServer interface {
	// Sends a Match command
	Match(context.Context, *MatchRequest) (*MatchResponse, error)
	Cancel(context.Context, *CancelRequest) (*CancelResponse, error)
	Init(context.Context, *InitRequest) (*InitResponse, error)
	// contains filtered or unexported methods
}

FluxionServiceServer is the server API for FluxionService service. All implementations must embed UnimplementedFluxionServiceServer for forward compatibility

type InitRequest 

type InitRequest struct {
	Policy string `protobuf:"bytes,1,opt,name=policy,proto3" json:"policy,omitempty"`
	Jgf    string `protobuf:"bytes,2,opt,name=jgf,proto3" json:"jgf,omitempty"`
	// contains filtered or unexported fields
}

func (*InitRequest) Descriptor deprecated 

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetJgf 

func (x *InitRequest) GetJgf() string

func (*InitRequest) GetPolicy 

func (x *InitRequest) GetPolicy() string

func (*InitRequest) ProtoMessage 

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect 

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

func (*InitRequest) Reset 

func (x *InitRequest) Reset()

func (*InitRequest) String 

func (x *InitRequest) String() string

type InitResponse 

type InitResponse struct {
	Status InitResponse_ResultType `protobuf:"varint,1,opt,name=status,proto3,enum=fluxion.InitResponse_ResultType" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*InitResponse) Descriptor deprecated 

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

Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.

func (*InitResponse) GetStatus 

func (x *InitResponse) GetStatus() InitResponse_ResultType

func (*InitResponse) ProtoMessage 

func (*InitResponse) ProtoMessage()

func (*InitResponse) ProtoReflect 

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

func (*InitResponse) Reset 

func (x *InitResponse) Reset()

func (*InitResponse) String 

func (x *InitResponse) String() string

type InitResponse_ResultType 

type InitResponse_ResultType int32
const (
	InitResponse_INIT_SUCCESS InitResponse_ResultType = 0
	InitResponse_INIT_ERROR   InitResponse_ResultType = 1
	InitResponse_INIT_DENIED  InitResponse_ResultType = 2
)

func (InitResponse_ResultType) Descriptor 

func (InitResponse_ResultType) Descriptor() protoreflect.EnumDescriptor

func (InitResponse_ResultType) Enum 

func (x InitResponse_ResultType) Enum() *InitResponse_ResultType

func (InitResponse_ResultType) EnumDescriptor deprecated 

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

Deprecated: Use InitResponse_ResultType.Descriptor instead.

func (InitResponse_ResultType) Number 

func (x InitResponse_ResultType) Number() protoreflect.EnumNumber

func (InitResponse_ResultType) String 

func (x InitResponse_ResultType) String() string

func (InitResponse_ResultType) Type 

func (InitResponse_ResultType) Type() protoreflect.EnumType

type MatchRequest 

type MatchRequest struct {
	Jobspec string `protobuf:"bytes,1,opt,name=jobspec,proto3" json:"jobspec,omitempty"`
	Request string `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	Count   int32  `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

The Match request message (allocate, allocate_orelse_reserve)

func (*MatchRequest) Descriptor deprecated 

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

Deprecated: Use MatchRequest.ProtoReflect.Descriptor instead.

func (*MatchRequest) GetCount 

func (x *MatchRequest) GetCount() int32

func (*MatchRequest) GetJobspec 

func (x *MatchRequest) GetJobspec() string

func (*MatchRequest) GetRequest 

func (x *MatchRequest) GetRequest() string

func (*MatchRequest) ProtoMessage 

func (*MatchRequest) ProtoMessage()

func (*MatchRequest) ProtoReflect 

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

func (*MatchRequest) Reset 

func (x *MatchRequest) Reset()

func (*MatchRequest) String 

func (x *MatchRequest) String() string

type MatchResponse 

type MatchResponse struct {
	Allocation string                   `protobuf:"bytes,1,opt,name=allocation,proto3" json:"allocation,omitempty"`
	Jobid      int64                    `protobuf:"varint,2,opt,name=jobid,proto3" json:"jobid,omitempty"`
	Reserved   bool                     `protobuf:"varint,3,opt,name=reserved,proto3" json:"reserved,omitempty"`
	At         int64                    `protobuf:"varint,4,opt,name=at,proto3" json:"at,omitempty"`
	Overhead   float32                  `protobuf:"fixed32,5,opt,name=overhead,proto3" json:"overhead,omitempty"`
	Status     MatchResponse_ResultType `protobuf:"varint,6,opt,name=status,proto3,enum=fluxion.MatchResponse_ResultType" json:"status,omitempty"`
	// contains filtered or unexported fields
}

The Match response message

func (*MatchResponse) Descriptor deprecated 

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

Deprecated: Use MatchResponse.ProtoReflect.Descriptor instead.

func (*MatchResponse) GetAllocation 

func (x *MatchResponse) GetAllocation() string

func (*MatchResponse) GetAt 

func (x *MatchResponse) GetAt() int64

func (*MatchResponse) GetJobid 

func (x *MatchResponse) GetJobid() int64

func (*MatchResponse) GetOverhead 

func (x *MatchResponse) GetOverhead() float32

func (*MatchResponse) GetReserved 

func (x *MatchResponse) GetReserved() bool

func (*MatchResponse) GetStatus 

func (x *MatchResponse) GetStatus() MatchResponse_ResultType

func (*MatchResponse) ProtoMessage 

func (*MatchResponse) ProtoMessage()

func (*MatchResponse) ProtoReflect 

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

func (*MatchResponse) Reset 

func (x *MatchResponse) Reset()

func (*MatchResponse) String 

func (x *MatchResponse) String() string

type MatchResponse_ResultType 

type MatchResponse_ResultType int32
const (
	MatchResponse_MATCH_SUCCESS MatchResponse_ResultType = 0
	MatchResponse_MATCH_ERROR   MatchResponse_ResultType = 1
	MatchResponse_MATCH_DENIED  MatchResponse_ResultType = 2
)

func (MatchResponse_ResultType) Descriptor 

func (MatchResponse_ResultType) Descriptor() protoreflect.EnumDescriptor

func (MatchResponse_ResultType) Enum 

func (x MatchResponse_ResultType) Enum() *MatchResponse_ResultType

func (MatchResponse_ResultType) EnumDescriptor deprecated 

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

Deprecated: Use MatchResponse_ResultType.Descriptor instead.

func (MatchResponse_ResultType) Number 

func (x MatchResponse_ResultType) Number() protoreflect.EnumNumber

func (MatchResponse_ResultType) String 

func (x MatchResponse_ResultType) String() string

func (MatchResponse_ResultType) Type 

func (MatchResponse_ResultType) Type() protoreflect.EnumType

type UnimplementedFluxionServiceServer 

type UnimplementedFluxionServiceServer struct {
}

UnimplementedFluxionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFluxionServiceServer) Cancel 

func (UnimplementedFluxionServiceServer) Cancel(context.Context, *CancelRequest) (*CancelResponse, error)

func (UnimplementedFluxionServiceServer) Init 

func (UnimplementedFluxionServiceServer) Init(context.Context, *InitRequest) (*InitResponse, error)

func (UnimplementedFluxionServiceServer) Match 

func (UnimplementedFluxionServiceServer) Match(context.Context, *MatchRequest) (*MatchResponse, error)

type UnsafeFluxionServiceServer 

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

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