v1

package
v0.0.0-...-6f25ba1 Latest Latest
Warning

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

 Go to latest Published: Mar 18, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_node_proto protoreflect.FileDescriptor
View Source 
var NodeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "convergedcomputing.org.grpc.v1.NodeService",
	HandlerType: (*NodeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReportStatus",
			Handler:    _NodeService_ReportStatus_Handler,
		},
		{
			MethodName: "ReportResult",
			Handler:    _NodeService_ReportResult_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AssignTask",
			Handler:       _NodeService_AssignTask_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "node.proto",
}

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

Functions

func RegisterNodeServiceServer 

func RegisterNodeServiceServer(s grpc.ServiceRegistrar, srv NodeServiceServer)

Types

type NodeServiceClient 

type NodeServiceClient interface {
	ReportStatus(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	ReportResult(ctx context.Context, in *WorkResponse, opts ...grpc.CallOption) (*Response, error)
	// We are streaming the work request to the workers
	AssignTask(ctx context.Context, in *Request, opts ...grpc.CallOption) (NodeService_AssignTaskClient, error)
}

NodeServiceClient is the client API for NodeService 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 NewNodeServiceClient 

func NewNodeServiceClient(cc grpc.ClientConnInterface) NodeServiceClient

type NodeServiceServer 

type NodeServiceServer interface {
	ReportStatus(context.Context, *Request) (*Response, error)
	ReportResult(context.Context, *WorkResponse) (*Response, error)
	// We are streaming the work request to the workers
	AssignTask(*Request, NodeService_AssignTaskServer) error
	// contains filtered or unexported methods
}

NodeServiceServer is the server API for NodeService service. All implementations must embed UnimplementedNodeServiceServer for forward compatibility

type NodeService_AssignTaskClient 

type NodeService_AssignTaskClient interface {
	Recv() (*WorkRequest, error)
	grpc.ClientStream
}

type NodeService_AssignTaskServer 

type NodeService_AssignTaskServer interface {
	Send(*WorkRequest) error
	grpc.ServerStream
}

type Request 

type Request struct {
	Action string `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetAction 

func (x *Request) GetAction() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Response 

type Response struct {
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetData 

func (x *Response) GetData() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type UnimplementedNodeServiceServer 

type UnimplementedNodeServiceServer struct {
}

UnimplementedNodeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeServiceServer) AssignTask 

func (UnimplementedNodeServiceServer) AssignTask(*Request, NodeService_AssignTaskServer) error

func (UnimplementedNodeServiceServer) ReportResult 

func (UnimplementedNodeServiceServer) ReportResult(context.Context, *WorkResponse) (*Response, error)

func (UnimplementedNodeServiceServer) ReportStatus 

func (UnimplementedNodeServiceServer) ReportStatus(context.Context, *Request) (*Response, error)

type UnsafeNodeServiceServer 

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

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

type WorkRequest 

type WorkRequest struct {
	Xmin  float64 `protobuf:"fixed64,1,opt,name=xmin,proto3" json:"xmin,omitempty"`
	Ymin  float64 `protobuf:"fixed64,2,opt,name=ymin,proto3" json:"ymin,omitempty"`
	Xmax  float64 `protobuf:"fixed64,3,opt,name=xmax,proto3" json:"xmax,omitempty"`
	Ymax  float64 `protobuf:"fixed64,4,opt,name=ymax,proto3" json:"ymax,omitempty"`
	Iy    int32   `protobuf:"varint,5,opt,name=iy,proto3" json:"iy,omitempty"`
	Iters int32   `protobuf:"varint,6,opt,name=iters,proto3" json:"iters,omitempty"`
	Width int32   `protobuf:"varint,7,opt,name=width,proto3" json:"width,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkRequest) Descriptor deprecated 

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

Deprecated: Use WorkRequest.ProtoReflect.Descriptor instead.

func (*WorkRequest) GetIters 

func (x *WorkRequest) GetIters() int32

func (*WorkRequest) GetIy 

func (x *WorkRequest) GetIy() int32

func (*WorkRequest) GetWidth 

func (x *WorkRequest) GetWidth() int32

func (*WorkRequest) GetXmax 

func (x *WorkRequest) GetXmax() float64

func (*WorkRequest) GetXmin 

func (x *WorkRequest) GetXmin() float64

func (*WorkRequest) GetYmax 

func (x *WorkRequest) GetYmax() float64

func (*WorkRequest) GetYmin 

func (x *WorkRequest) GetYmin() float64

func (*WorkRequest) ProtoMessage 

func (*WorkRequest) ProtoMessage()

func (*WorkRequest) ProtoReflect 

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

func (*WorkRequest) Reset 

func (x *WorkRequest) Reset()

func (*WorkRequest) String 

func (x *WorkRequest) String() string

type WorkResponse 

type WorkResponse struct {
	Norm  []float64 `protobuf:"fixed64,1,rep,packed,name=norm,proto3" json:"norm,omitempty"`
	It    []int32   `protobuf:"varint,2,rep,packed,name=it,proto3" json:"it,omitempty"`
	Iy    int32     `protobuf:"varint,3,opt,name=iy,proto3" json:"iy,omitempty"`
	Iters int32     `protobuf:"varint,4,opt,name=iters,proto3" json:"iters,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkResponse) Descriptor deprecated 

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

Deprecated: Use WorkResponse.ProtoReflect.Descriptor instead.

func (*WorkResponse) GetIt 

func (x *WorkResponse) GetIt() []int32

func (*WorkResponse) GetIters 

func (x *WorkResponse) GetIters() int32

func (*WorkResponse) GetIy 

func (x *WorkResponse) GetIy() int32

func (*WorkResponse) GetNorm 

func (x *WorkResponse) GetNorm() []float64

func (*WorkResponse) ProtoMessage 

func (*WorkResponse) ProtoMessage()

func (*WorkResponse) ProtoReflect 

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

func (*WorkResponse) Reset 

func (x *WorkResponse) Reset()

func (*WorkResponse) String 

func (x *WorkResponse) String() string

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.