service

package
v0.0.0-...-f839e32 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ControlPlane_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.service.ControlPlane",
	HandlerType: (*ControlPlaneServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Tasks",
			Handler:       _ControlPlane_Tasks_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Metrics",
			Handler:       _ControlPlane_Metrics_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "api/service/base_control_plane.proto",
}

ControlPlane_ServiceDesc is the grpc.ServiceDesc for ControlPlane 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 DataPlane_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.service.DataPlane",
	HandlerType: (*DataPlaneServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DataChunks",
			Handler:       _DataPlane_DataChunks_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "UploadObject",
			Handler:       _DataPlane_UploadObject_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "UploadObjects",
			Handler:       _DataPlane_UploadObjects_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "DownloadObject",
			Handler:       _DataPlane_DownloadObject_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/service/base_data_plane.proto",
}

DataPlane_ServiceDesc is the grpc.ServiceDesc for DataPlane 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 File_api_service_base_control_plane_proto protoreflect.FileDescriptor
View Source 
var File_api_service_base_data_plane_proto protoreflect.FileDescriptor
View Source 
var File_api_service_base_health_plane_proto protoreflect.FileDescriptor
View Source 
var File_api_service_base_reports_plane_proto protoreflect.FileDescriptor
View Source 
var Health_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.service.Health",
	HandlerType: (*HealthServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Check",
			Handler:    _Health_Check_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _Health_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/service/base_health_plane.proto",
}

Health_ServiceDesc is the grpc.ServiceDesc for Health 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 ReportsPlane_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.service.ReportsPlane",
	HandlerType: (*ReportsPlaneServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ObjectsReport",
			Handler:    _ReportsPlane_ObjectsReport_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/service/base_reports_plane.proto",
}

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

Functions

func RegisterControlPlaneServer 

func RegisterControlPlaneServer(s grpc.ServiceRegistrar, srv ControlPlaneServer)

func RegisterDataPlaneServer 

func RegisterDataPlaneServer(s grpc.ServiceRegistrar, srv DataPlaneServer)

func RegisterHealthServer 

func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer)

func RegisterReportsPlaneServer 

func RegisterReportsPlaneServer(s grpc.ServiceRegistrar, srv ReportsPlaneServer)

Types

type ControlPlaneClient 

type ControlPlaneClient interface {
	// Bi-directional Commands stream.
	// Commands are sent from service to client and from client to server
	Tasks(ctx context.Context, opts ...grpc.CallOption) (ControlPlane_TasksClient, error)
	// Uni-directional Metrics stream from client to server.
	Metrics(ctx context.Context, opts ...grpc.CallOption) (ControlPlane_MetricsClient, error)
}

ControlPlaneClient is the client API for ControlPlane 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 NewControlPlaneClient 

func NewControlPlaneClient(cc grpc.ClientConnInterface) ControlPlaneClient

type ControlPlaneServer 

type ControlPlaneServer interface {
	// Bi-directional Commands stream.
	// Commands are sent from service to client and from client to server
	Tasks(ControlPlane_TasksServer) error
	// Uni-directional Metrics stream from client to server.
	Metrics(ControlPlane_MetricsServer) error
	// contains filtered or unexported methods
}

ControlPlaneServer is the server API for ControlPlane service. All implementations must embed UnimplementedControlPlaneServer for forward compatibility

type ControlPlane_MetricsClient 

type ControlPlane_MetricsClient interface {
	Send(*common.Metric) error
	CloseAndRecv() (*common.Metric, error)
	grpc.ClientStream
}

type ControlPlane_MetricsServer 

type ControlPlane_MetricsServer interface {
	SendAndClose(*common.Metric) error
	Recv() (*common.Metric, error)
	grpc.ServerStream
}

type ControlPlane_TasksClient 

type ControlPlane_TasksClient interface {
	Send(*common.Task) error
	Recv() (*common.Task, error)
	grpc.ClientStream
}

type ControlPlane_TasksServer 

type ControlPlane_TasksServer interface {
	Send(*common.Task) error
	Recv() (*common.Task, error)
	grpc.ServerStream
}

type DataPlaneClient 

type DataPlaneClient interface {
	// Bi-directional Data stream.
	// Some commands may be followed by data load. Be it logs, dumps, etc.
	DataChunks(ctx context.Context, opts ...grpc.CallOption) (DataPlane_DataChunksClient, error)
	// Uni-directional Data stream. One object is uploaded from the client to the server.
	// Returns status of the uploaded object.
	UploadObject(ctx context.Context, opts ...grpc.CallOption) (DataPlane_UploadObjectClient, error)
	// Uni-directional Data stream. Multiple objects are uploaded from the client to the server.
	// Returns list of statuses of the uploaded objects.
	UploadObjects(ctx context.Context, opts ...grpc.CallOption) (DataPlane_UploadObjectsClient, error)
	// Uni-directional Data stream. One object is uploaded from the client to the server.
	// Returns status of the uploaded object.
	DownloadObject(ctx context.Context, in *common.ObjectRequest, opts ...grpc.CallOption) (DataPlane_DownloadObjectClient, error)
}

DataPlaneClient is the client API for DataPlane 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 NewDataPlaneClient 

func NewDataPlaneClient(cc grpc.ClientConnInterface) DataPlaneClient

type DataPlaneServer 

type DataPlaneServer interface {
	// Bi-directional Data stream.
	// Some commands may be followed by data load. Be it logs, dumps, etc.
	DataChunks(DataPlane_DataChunksServer) error
	// Uni-directional Data stream. One object is uploaded from the client to the server.
	// Returns status of the uploaded object.
	UploadObject(DataPlane_UploadObjectServer) error
	// Uni-directional Data stream. Multiple objects are uploaded from the client to the server.
	// Returns list of statuses of the uploaded objects.
	UploadObjects(DataPlane_UploadObjectsServer) error
	// Uni-directional Data stream. One object is uploaded from the client to the server.
	// Returns status of the uploaded object.
	DownloadObject(*common.ObjectRequest, DataPlane_DownloadObjectServer) error
	// contains filtered or unexported methods
}

DataPlaneServer is the server API for DataPlane service. All implementations must embed UnimplementedDataPlaneServer for forward compatibility

type DataPlane_DataChunksClient 

type DataPlane_DataChunksClient interface {
	Send(*common.DataPacket) error
	Recv() (*common.DataPacket, error)
	grpc.ClientStream
}

type DataPlane_DataChunksServer 

type DataPlane_DataChunksServer interface {
	Send(*common.DataPacket) error
	Recv() (*common.DataPacket, error)
	grpc.ServerStream
}

type DataPlane_DownloadObjectClient 

type DataPlane_DownloadObjectClient interface {
	Recv() (*common.DataPacket, error)
	grpc.ClientStream
}

type DataPlane_DownloadObjectServer 

type DataPlane_DownloadObjectServer interface {
	Send(*common.DataPacket) error
	grpc.ServerStream
}

type DataPlane_UploadObjectClient 

type DataPlane_UploadObjectClient interface {
	Send(*common.DataPacket) error
	CloseAndRecv() (*common.ObjectStatus, error)
	grpc.ClientStream
}

type DataPlane_UploadObjectServer 

type DataPlane_UploadObjectServer interface {
	SendAndClose(*common.ObjectStatus) error
	Recv() (*common.DataPacket, error)
	grpc.ServerStream
}

type DataPlane_UploadObjectsClient 

type DataPlane_UploadObjectsClient interface {
	Send(*common.DataPacket) error
	CloseAndRecv() (*common.ObjectsList, error)
	grpc.ClientStream
}

type DataPlane_UploadObjectsServer 

type DataPlane_UploadObjectsServer interface {
	SendAndClose(*common.ObjectsList) error
	Recv() (*common.DataPacket, error)
	grpc.ServerStream
}

type HealthClient 

type HealthClient interface {
	// Checks specified service with one-time check and returns one response
	Check(ctx context.Context, in *common.HealthCheckRequest, opts ...grpc.CallOption) (*common.HealthCheckResponse, error)
	// Repeatedly checks specified service and returns multiple responses
	Watch(ctx context.Context, in *common.HealthCheckRequest, opts ...grpc.CallOption) (Health_WatchClient, error)
}

HealthClient is the client API for Health 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 NewHealthClient 

func NewHealthClient(cc grpc.ClientConnInterface) HealthClient

type HealthServer 

type HealthServer interface {
	// Checks specified service with one-time check and returns one response
	Check(context.Context, *common.HealthCheckRequest) (*common.HealthCheckResponse, error)
	// Repeatedly checks specified service and returns multiple responses
	Watch(*common.HealthCheckRequest, Health_WatchServer) error
	// contains filtered or unexported methods
}

HealthServer is the server API for Health service. All implementations must embed UnimplementedHealthServer for forward compatibility

type Health_WatchClient 

type Health_WatchClient interface {
	Recv() (*common.HealthCheckResponse, error)
	grpc.ClientStream
}

type Health_WatchServer 

type Health_WatchServer interface {
	Send(*common.HealthCheckResponse) error
	grpc.ServerStream
}

type ReportsPlaneClient 

type ReportsPlaneClient interface {
	// Get report about multiple objects as a one item.
	ObjectsReport(ctx context.Context, in *common.ObjectsRequest, opts ...grpc.CallOption) (*common.ObjectsList, error)
}

ReportsPlaneClient is the client API for ReportsPlane 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 NewReportsPlaneClient 

func NewReportsPlaneClient(cc grpc.ClientConnInterface) ReportsPlaneClient

type ReportsPlaneServer 

type ReportsPlaneServer interface {
	// Get report about multiple objects as a one item.
	ObjectsReport(context.Context, *common.ObjectsRequest) (*common.ObjectsList, error)
	// contains filtered or unexported methods
}

ReportsPlaneServer is the server API for ReportsPlane service. All implementations must embed UnimplementedReportsPlaneServer for forward compatibility

type UnimplementedControlPlaneServer 

type UnimplementedControlPlaneServer struct {
}

UnimplementedControlPlaneServer must be embedded to have forward compatible implementations.

func (UnimplementedControlPlaneServer) Metrics 

func (UnimplementedControlPlaneServer) Metrics(ControlPlane_MetricsServer) error

func (UnimplementedControlPlaneServer) Tasks 

func (UnimplementedControlPlaneServer) Tasks(ControlPlane_TasksServer) error

type UnimplementedDataPlaneServer 

type UnimplementedDataPlaneServer struct {
}

UnimplementedDataPlaneServer must be embedded to have forward compatible implementations.

func (UnimplementedDataPlaneServer) DataChunks 

func (UnimplementedDataPlaneServer) DataChunks(DataPlane_DataChunksServer) error

func (UnimplementedDataPlaneServer) DownloadObject 

func (UnimplementedDataPlaneServer) DownloadObject(*common.ObjectRequest, DataPlane_DownloadObjectServer) error

func (UnimplementedDataPlaneServer) UploadObject 

func (UnimplementedDataPlaneServer) UploadObject(DataPlane_UploadObjectServer) error

func (UnimplementedDataPlaneServer) UploadObjects 

func (UnimplementedDataPlaneServer) UploadObjects(DataPlane_UploadObjectsServer) error

type UnimplementedHealthServer 

type UnimplementedHealthServer struct {
}

UnimplementedHealthServer must be embedded to have forward compatible implementations.

func (UnimplementedHealthServer) Check 

func (UnimplementedHealthServer) Check(context.Context, *common.HealthCheckRequest) (*common.HealthCheckResponse, error)

func (UnimplementedHealthServer) Watch 

func (UnimplementedHealthServer) Watch(*common.HealthCheckRequest, Health_WatchServer) error

type UnimplementedReportsPlaneServer 

type UnimplementedReportsPlaneServer struct {
}

UnimplementedReportsPlaneServer must be embedded to have forward compatible implementations.

func (UnimplementedReportsPlaneServer) ObjectsReport 

func (UnimplementedReportsPlaneServer) ObjectsReport(context.Context, *common.ObjectsRequest) (*common.ObjectsList, error)

type UnsafeControlPlaneServer 

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

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

type UnsafeDataPlaneServer 

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

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

type UnsafeHealthServer 

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

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

type UnsafeReportsPlaneServer 

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

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