grpcservices

package
v0.0.0-...-999fc6a Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2025 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FgrzlStream_CreatePartition_FullMethodName  = "/stream.FgrzlStream/CreatePartition"
	FgrzlStream_GetStatus_FullMethodName        = "/stream.FgrzlStream/GetStatus"
	FgrzlStream_GetSpaces_FullMethodName        = "/stream.FgrzlStream/GetSpaces"
	FgrzlStream_GetPartitions_FullMethodName    = "/stream.FgrzlStream/GetPartitions"
	FgrzlStream_Produce_FullMethodName          = "/stream.FgrzlStream/Produce"
	FgrzlStream_ConsumeSpace_FullMethodName     = "/stream.FgrzlStream/ConsumeSpace"
	FgrzlStream_ConsumePartition_FullMethodName = "/stream.FgrzlStream/ConsumePartition"
	FgrzlStream_Peek_FullMethodName             = "/stream.FgrzlStream/Peek"
	FgrzlStream_Merge_FullMethodName            = "/stream.FgrzlStream/Merge"
	FgrzlStream_Prune_FullMethodName            = "/stream.FgrzlStream/Prune"
	FgrzlStream_Rebuild_FullMethodName          = "/stream.FgrzlStream/Rebuild"
)

Variables

View Source 
var FgrzlStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stream.FgrzlStream",
	HandlerType: (*FgrzlStreamServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreatePartition",
			Handler:    _FgrzlStream_CreatePartition_Handler,
		},
		{
			MethodName: "GetStatus",
			Handler:    _FgrzlStream_GetStatus_Handler,
		},
		{
			MethodName: "Peek",
			Handler:    _FgrzlStream_Peek_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSpaces",
			Handler:       _FgrzlStream_GetSpaces_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetPartitions",
			Handler:       _FgrzlStream_GetPartitions_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Produce",
			Handler:       _FgrzlStream_Produce_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ConsumeSpace",
			Handler:       _FgrzlStream_ConsumeSpace_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ConsumePartition",
			Handler:       _FgrzlStream_ConsumePartition_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Merge",
			Handler:       _FgrzlStream_Merge_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Prune",
			Handler:       _FgrzlStream_Prune_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Rebuild",
			Handler:       _FgrzlStream_Rebuild_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "services.proto",
}

FgrzlStream_ServiceDesc is the grpc.ServiceDesc for FgrzlStream 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_services_proto protoreflect.FileDescriptor

Functions

func NewBidiStreamingServerEnumerator 

func NewBidiStreamingServerEnumerator[TReq any, TRes any](stream grpc.BidiStreamingServer[TReq, TRes]) enumerators.Enumerator[*TReq]

A new enumerator of the requests

func RegisterFgrzlStreamServer 

func RegisterFgrzlStreamServer(s grpc.ServiceRegistrar, srv FgrzlStreamServer)

func StartServer 

func StartServer(ctx context.Context, ready chan struct{}, hosts ...string)

StartServer starts the gRPC server.

Types

type FgrzlStreamClient 

type FgrzlStreamClient interface {
	CreatePartition(ctx context.Context, in *models.CreatePartitionRequest, opts ...grpc.CallOption) (*models.StatusResponse, error)
	GetStatus(ctx context.Context, in *models.GetStatusRequest, opts ...grpc.CallOption) (*models.StatusResponse, error)
	// Get the spaces
	GetSpaces(ctx context.Context, in *models.GetSpacesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.SpaceDescriptor], error)
	// Get the streams
	GetPartitions(ctx context.Context, in *models.GetPartitionsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.PartitionDescriptor], error)
	// Produce entries
	Produce(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[models.Entry, models.PageDescriptor], error)
	// Consume entries in a space.
	ConsumeSpace(ctx context.Context, in *models.ConsumeSpaceRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.EntryEnvelope], error)
	// Consume entries in a stream
	ConsumePartition(ctx context.Context, in *models.ConsumePartitionRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.EntryEnvelope], error)
	// Peek at the last entry in a stream
	Peek(ctx context.Context, in *models.PeekRequest, opts ...grpc.CallOption) (*models.EntryEnvelope, error)
	// Merge pages from a stream into the next tier
	Merge(ctx context.Context, in *models.MergeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.PageDescriptor], error)
	// Prune obsolete pages from a tier
	Prune(ctx context.Context, in *models.PruneRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.PageDescriptor], error)
	// Rebuild the manifest for a tier
	Rebuild(ctx context.Context, in *models.RebuildRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.RebuildResponse], error)
}

FgrzlStreamClient is the client API for FgrzlStream 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.

PartitionServices is the service definition for the stream-related operations.

func NewFgrzlStreamClient 

func NewFgrzlStreamClient(cc grpc.ClientConnInterface) FgrzlStreamClient

type FgrzlStreamGrpcServer 

type FgrzlStreamGrpcServer interface {
	util.Disposable
	FgrzlStreamServer
}

func NewWoolfServer 

func NewWoolfServer(options *services.ServiceOptions) FgrzlStreamGrpcServer

NewWoolfServer creates a new WoolfServerImpl instance.

type FgrzlStreamServer 

type FgrzlStreamServer interface {
	CreatePartition(context.Context, *models.CreatePartitionRequest) (*models.StatusResponse, error)
	GetStatus(context.Context, *models.GetStatusRequest) (*models.StatusResponse, error)
	// Get the spaces
	GetSpaces(*models.GetSpacesRequest, grpc.ServerStreamingServer[models.SpaceDescriptor]) error
	// Get the streams
	GetPartitions(*models.GetPartitionsRequest, grpc.ServerStreamingServer[models.PartitionDescriptor]) error
	// Produce entries
	Produce(grpc.BidiStreamingServer[models.Entry, models.PageDescriptor]) error
	// Consume entries in a space.
	ConsumeSpace(*models.ConsumeSpaceRequest, grpc.ServerStreamingServer[models.EntryEnvelope]) error
	// Consume entries in a stream
	ConsumePartition(*models.ConsumePartitionRequest, grpc.ServerStreamingServer[models.EntryEnvelope]) error
	// Peek at the last entry in a stream
	Peek(context.Context, *models.PeekRequest) (*models.EntryEnvelope, error)
	// Merge pages from a stream into the next tier
	Merge(*models.MergeRequest, grpc.ServerStreamingServer[models.PageDescriptor]) error
	// Prune obsolete pages from a tier
	Prune(*models.PruneRequest, grpc.ServerStreamingServer[models.PageDescriptor]) error
	// Rebuild the manifest for a tier
	Rebuild(*models.RebuildRequest, grpc.ServerStreamingServer[models.RebuildResponse]) error
	// contains filtered or unexported methods
}

FgrzlStreamServer is the server API for FgrzlStream service. All implementations must embed UnimplementedFgrzlStreamServer for forward compatibility.

PartitionServices is the service definition for the stream-related operations.

type FgrzlStream_ConsumePartitionClient 

type FgrzlStream_ConsumePartitionClient = grpc.ServerStreamingClient[models.EntryEnvelope]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_ConsumePartitionServer 

type FgrzlStream_ConsumePartitionServer = grpc.ServerStreamingServer[models.EntryEnvelope]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_ConsumeSpaceClient 

type FgrzlStream_ConsumeSpaceClient = grpc.ServerStreamingClient[models.EntryEnvelope]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_ConsumeSpaceServer 

type FgrzlStream_ConsumeSpaceServer = grpc.ServerStreamingServer[models.EntryEnvelope]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_GetPartitionsClient 

type FgrzlStream_GetPartitionsClient = grpc.ServerStreamingClient[models.PartitionDescriptor]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_GetPartitionsServer 

type FgrzlStream_GetPartitionsServer = grpc.ServerStreamingServer[models.PartitionDescriptor]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_GetSpacesClient 

type FgrzlStream_GetSpacesClient = grpc.ServerStreamingClient[models.SpaceDescriptor]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_GetSpacesServer 

type FgrzlStream_GetSpacesServer = grpc.ServerStreamingServer[models.SpaceDescriptor]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_MergeClient 

type FgrzlStream_MergeClient = grpc.ServerStreamingClient[models.PageDescriptor]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_MergeServer 

type FgrzlStream_MergeServer = grpc.ServerStreamingServer[models.PageDescriptor]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_ProduceClient 

type FgrzlStream_ProduceClient = grpc.BidiStreamingClient[models.Entry, models.PageDescriptor]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_ProduceServer 

type FgrzlStream_ProduceServer = grpc.BidiStreamingServer[models.Entry, models.PageDescriptor]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_PruneClient 

type FgrzlStream_PruneClient = grpc.ServerStreamingClient[models.PageDescriptor]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_PruneServer 

type FgrzlStream_PruneServer = grpc.ServerStreamingServer[models.PageDescriptor]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_RebuildClient 

type FgrzlStream_RebuildClient = grpc.ServerStreamingClient[models.RebuildResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type FgrzlStream_RebuildServer 

type FgrzlStream_RebuildServer = grpc.ServerStreamingServer[models.RebuildResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedFgrzlStreamServer 

type UnimplementedFgrzlStreamServer struct{}

UnimplementedFgrzlStreamServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedFgrzlStreamServer) ConsumePartition 

func (UnimplementedFgrzlStreamServer) ConsumePartition(*models.ConsumePartitionRequest, grpc.ServerStreamingServer[models.EntryEnvelope]) error

func (UnimplementedFgrzlStreamServer) ConsumeSpace 

func (UnimplementedFgrzlStreamServer) ConsumeSpace(*models.ConsumeSpaceRequest, grpc.ServerStreamingServer[models.EntryEnvelope]) error

func (UnimplementedFgrzlStreamServer) CreatePartition 

func (UnimplementedFgrzlStreamServer) CreatePartition(context.Context, *models.CreatePartitionRequest) (*models.StatusResponse, error)

func (UnimplementedFgrzlStreamServer) GetPartitions 

func (UnimplementedFgrzlStreamServer) GetPartitions(*models.GetPartitionsRequest, grpc.ServerStreamingServer[models.PartitionDescriptor]) error

func (UnimplementedFgrzlStreamServer) GetSpaces 

func (UnimplementedFgrzlStreamServer) GetSpaces(*models.GetSpacesRequest, grpc.ServerStreamingServer[models.SpaceDescriptor]) error

func (UnimplementedFgrzlStreamServer) GetStatus 

func (UnimplementedFgrzlStreamServer) GetStatus(context.Context, *models.GetStatusRequest) (*models.StatusResponse, error)

func (UnimplementedFgrzlStreamServer) Merge 

func (UnimplementedFgrzlStreamServer) Merge(*models.MergeRequest, grpc.ServerStreamingServer[models.PageDescriptor]) error

func (UnimplementedFgrzlStreamServer) Peek 

func (UnimplementedFgrzlStreamServer) Peek(context.Context, *models.PeekRequest) (*models.EntryEnvelope, error)

func (UnimplementedFgrzlStreamServer) Produce 

func (UnimplementedFgrzlStreamServer) Produce(grpc.BidiStreamingServer[models.Entry, models.PageDescriptor]) error

func (UnimplementedFgrzlStreamServer) Prune 

func (UnimplementedFgrzlStreamServer) Prune(*models.PruneRequest, grpc.ServerStreamingServer[models.PageDescriptor]) error

func (UnimplementedFgrzlStreamServer) Rebuild 

func (UnimplementedFgrzlStreamServer) Rebuild(*models.RebuildRequest, grpc.ServerStreamingServer[models.RebuildResponse]) error

type UnsafeFgrzlStreamServer 

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

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