Versions in this module Expand all Collapse all v1 v1.8.0 Apr 29, 2026 Changes in this version + const StreamerService_Configure_FullMethodName + const StreamerService_Read_FullMethodName + const StreamerService_Write_FullMethodName + var File_streamer_proto protoreflect.FileDescriptor + var StreamerService_ServiceDesc = grpc.ServiceDesc + func RegisterStreamerServiceServer(s grpc.ServiceRegistrar, srv StreamerServiceServer) + type Configure struct + func (*Configure) Descriptor() ([]byte, []int) + func (*Configure) ProtoMessage() + func (x *Configure) ProtoReflect() protoreflect.Message + func (x *Configure) Reset() + func (x *Configure) String() string + type Configure_Request struct + ChunkSize int64 + Path string + func (*Configure_Request) Descriptor() ([]byte, []int) + func (*Configure_Request) ProtoMessage() + func (x *Configure_Request) GetChunkSize() int64 + func (x *Configure_Request) GetPath() string + func (x *Configure_Request) ProtoReflect() protoreflect.Message + func (x *Configure_Request) Reset() + func (x *Configure_Request) String() string + type Configure_Response struct + func (*Configure_Response) Descriptor() ([]byte, []int) + func (*Configure_Response) ProtoMessage() + func (x *Configure_Response) ProtoReflect() protoreflect.Message + func (x *Configure_Response) Reset() + func (x *Configure_Response) String() string + type Read struct + func (*Read) Descriptor() ([]byte, []int) + func (*Read) ProtoMessage() + func (x *Read) ProtoReflect() protoreflect.Message + func (x *Read) Reset() + func (x *Read) String() string + type Read_Request struct + func (*Read_Request) Descriptor() ([]byte, []int) + func (*Read_Request) ProtoMessage() + func (x *Read_Request) ProtoReflect() protoreflect.Message + func (x *Read_Request) Reset() + func (x *Read_Request) String() string + type Read_ResponseChunk struct + ReadBytes []byte + func (*Read_ResponseChunk) Descriptor() ([]byte, []int) + func (*Read_ResponseChunk) ProtoMessage() + func (x *Read_ResponseChunk) GetReadBytes() []byte + func (x *Read_ResponseChunk) ProtoReflect() protoreflect.Message + func (x *Read_ResponseChunk) Reset() + func (x *Read_ResponseChunk) String() string + type StreamerServiceClient interface + Configure func(ctx context.Context, in *Configure_Request, opts ...grpc.CallOption) (*Configure_Response, error) + Read func(ctx context.Context, in *Read_Request, opts ...grpc.CallOption) (StreamerService_ReadClient, error) + Write func(ctx context.Context, opts ...grpc.CallOption) (StreamerService_WriteClient, error) + func NewStreamerServiceClient(cc grpc.ClientConnInterface) StreamerServiceClient + type StreamerServiceServer interface + Configure func(context.Context, *Configure_Request) (*Configure_Response, error) + Read func(*Read_Request, StreamerService_ReadServer) error + Write func(StreamerService_WriteServer) error + type StreamerService_ReadClient interface + Recv func() (*Read_ResponseChunk, error) + type StreamerService_ReadServer interface + Send func(*Read_ResponseChunk) error + type StreamerService_WriteClient interface + CloseAndRecv func() (*Write_Response, error) + Send func(*Write_RequestChunk) error + type StreamerService_WriteServer interface + Recv func() (*Write_RequestChunk, error) + SendAndClose func(*Write_Response) error + type UnimplementedStreamerServiceServer struct + func (UnimplementedStreamerServiceServer) Configure(context.Context, *Configure_Request) (*Configure_Response, error) + func (UnimplementedStreamerServiceServer) Read(*Read_Request, StreamerService_ReadServer) error + func (UnimplementedStreamerServiceServer) Write(StreamerService_WriteServer) error + type UnsafeStreamerServiceServer interface + type Write struct + func (*Write) Descriptor() ([]byte, []int) + func (*Write) ProtoMessage() + func (x *Write) ProtoReflect() protoreflect.Message + func (x *Write) Reset() + func (x *Write) String() string + type Write_RequestChunk struct + BytesToWrite []byte + func (*Write_RequestChunk) Descriptor() ([]byte, []int) + func (*Write_RequestChunk) ProtoMessage() + func (x *Write_RequestChunk) GetBytesToWrite() []byte + func (x *Write_RequestChunk) ProtoReflect() protoreflect.Message + func (x *Write_RequestChunk) Reset() + func (x *Write_RequestChunk) String() string + type Write_Response struct + func (*Write_Response) Descriptor() ([]byte, []int) + func (*Write_Response) ProtoMessage() + func (x *Write_Response) ProtoReflect() protoreflect.Message + func (x *Write_Response) Reset() + func (x *Write_Response) String() string
Go to main page