Versions in this module Expand all Collapse all v0 v0.0.11 Feb 4, 2025retracted Changes in this version + const Woolf_ConsumePartition_FullMethodName + const Woolf_ConsumeSpace_FullMethodName + const Woolf_CreatePartition_FullMethodName + const Woolf_GetPartitions_FullMethodName + const Woolf_GetSpaces_FullMethodName + const Woolf_GetStatus_FullMethodName + const Woolf_Merge_FullMethodName + const Woolf_Peek_FullMethodName + const Woolf_Produce_FullMethodName + const Woolf_Prune_FullMethodName + const Woolf_Rebuild_FullMethodName + var File_services_proto protoreflect.FileDescriptor + var Woolf_ServiceDesc = grpc.ServiceDesc + func NewBidiStreamingServerEnumerator[TReq any, TRes any](stream grpc.BidiStreamingServer[TReq, TRes]) enumerators.Enumerator[*TReq] + func RegisterWoolfServer(s grpc.ServiceRegistrar, srv WoolfServer) + func StartServer(ctx context.Context, ready chan struct{}, hosts ...string) + type UnimplementedWoolfServer struct + func (UnimplementedWoolfServer) ConsumePartition(*models.ConsumePartitionRequest, ...) error + func (UnimplementedWoolfServer) ConsumeSpace(*models.ConsumeSpaceRequest, grpc.ServerStreamingServer[models.EntryEnvelope]) error + func (UnimplementedWoolfServer) CreatePartition(context.Context, *models.CreatePartitionRequest) (*models.StatusResponse, error) + func (UnimplementedWoolfServer) GetPartitions(*models.GetPartitionsRequest, ...) error + func (UnimplementedWoolfServer) GetSpaces(*models.GetSpacesRequest, grpc.ServerStreamingServer[models.SpaceDescriptor]) error + func (UnimplementedWoolfServer) GetStatus(context.Context, *models.GetStatusRequest) (*models.StatusResponse, error) + func (UnimplementedWoolfServer) Merge(*models.MergeRequest, grpc.ServerStreamingServer[models.PageDescriptor]) error + func (UnimplementedWoolfServer) Peek(context.Context, *models.PeekRequest) (*models.EntryEnvelope, error) + func (UnimplementedWoolfServer) Produce(grpc.BidiStreamingServer[models.Entry, models.PageDescriptor]) error + func (UnimplementedWoolfServer) Prune(*models.PruneRequest, grpc.ServerStreamingServer[models.PageDescriptor]) error + func (UnimplementedWoolfServer) Rebuild(*models.RebuildRequest, grpc.ServerStreamingServer[models.RebuildResponse]) error + type UnsafeWoolfServer interface + type WoolfClient interface + ConsumePartition func(ctx context.Context, in *models.ConsumePartitionRequest, ...) (grpc.ServerStreamingClient[models.EntryEnvelope], error) + ConsumeSpace func(ctx context.Context, in *models.ConsumeSpaceRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.EntryEnvelope], error) + CreatePartition func(ctx context.Context, in *models.CreatePartitionRequest, ...) (*models.StatusResponse, error) + GetPartitions func(ctx context.Context, in *models.GetPartitionsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.PartitionDescriptor], error) + GetSpaces func(ctx context.Context, in *models.GetSpacesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.SpaceDescriptor], error) + GetStatus func(ctx context.Context, in *models.GetStatusRequest, opts ...grpc.CallOption) (*models.StatusResponse, error) + Merge func(ctx context.Context, in *models.MergeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.PageDescriptor], error) + Peek func(ctx context.Context, in *models.PeekRequest, opts ...grpc.CallOption) (*models.EntryEnvelope, error) + Produce func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[models.Entry, models.PageDescriptor], error) + Prune func(ctx context.Context, in *models.PruneRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.PageDescriptor], error) + Rebuild func(ctx context.Context, in *models.RebuildRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[models.RebuildResponse], error) + func NewWoolfClient(cc grpc.ClientConnInterface) WoolfClient + type WoolfServer interface + ConsumePartition func(*models.ConsumePartitionRequest, ...) error + ConsumeSpace func(*models.ConsumeSpaceRequest, grpc.ServerStreamingServer[models.EntryEnvelope]) error + CreatePartition func(context.Context, *models.CreatePartitionRequest) (*models.StatusResponse, error) + GetPartitions func(*models.GetPartitionsRequest, ...) error + GetSpaces func(*models.GetSpacesRequest, grpc.ServerStreamingServer[models.SpaceDescriptor]) error + GetStatus func(context.Context, *models.GetStatusRequest) (*models.StatusResponse, error) + Merge func(*models.MergeRequest, grpc.ServerStreamingServer[models.PageDescriptor]) error + Peek func(context.Context, *models.PeekRequest) (*models.EntryEnvelope, error) + Produce func(grpc.BidiStreamingServer[models.Entry, models.PageDescriptor]) error + Prune func(*models.PruneRequest, grpc.ServerStreamingServer[models.PageDescriptor]) error + Rebuild func(*models.RebuildRequest, grpc.ServerStreamingServer[models.RebuildResponse]) error + type Woolf_ConsumePartitionClient = grpc.ServerStreamingClient[models.EntryEnvelope] + type Woolf_ConsumePartitionServer = grpc.ServerStreamingServer[models.EntryEnvelope] + type Woolf_ConsumeSpaceClient = grpc.ServerStreamingClient[models.EntryEnvelope] + type Woolf_ConsumeSpaceServer = grpc.ServerStreamingServer[models.EntryEnvelope] + type Woolf_GetPartitionsClient = grpc.ServerStreamingClient[models.PartitionDescriptor] + type Woolf_GetPartitionsServer = grpc.ServerStreamingServer[models.PartitionDescriptor] + type Woolf_GetSpacesClient = grpc.ServerStreamingClient[models.SpaceDescriptor] + type Woolf_GetSpacesServer = grpc.ServerStreamingServer[models.SpaceDescriptor] + type Woolf_MergeClient = grpc.ServerStreamingClient[models.PageDescriptor] + type Woolf_MergeServer = grpc.ServerStreamingServer[models.PageDescriptor] + type Woolf_ProduceClient = grpc.BidiStreamingClient[models.Entry, models.PageDescriptor] + type Woolf_ProduceServer = grpc.BidiStreamingServer[models.Entry, models.PageDescriptor] + type Woolf_PruneClient = grpc.ServerStreamingClient[models.PageDescriptor] + type Woolf_PruneServer = grpc.ServerStreamingServer[models.PageDescriptor] + type Woolf_RebuildClient = grpc.ServerStreamingClient[models.RebuildResponse] + type Woolf_RebuildServer = grpc.ServerStreamingServer[models.RebuildResponse] + type Woolfgrpcservices interface + func NewWoolfServer(options *services.ServiceOptions) Woolfgrpcservices
Go to main page