Versions in this module Expand all Collapse all v1 v1.8.0 Apr 29, 2026 Changes in this version + type Streamer interface + Configure func(ctx context.Context, path string, chunkSize int64) error + Read func(ctx context.Context) ([]byte, error) + Write func(ctx context.Context, b []byte) error + type StreamerGRPCClient struct + func (g *StreamerGRPCClient) Configure(ctx context.Context, path string, chunkSize int64) error + func (g *StreamerGRPCClient) Read(ctx context.Context) ([]byte, error) + func (g *StreamerGRPCClient) Write(ctx context.Context, b []byte) error + type StreamerGRPCServer struct + Impl Streamer + func (s *StreamerGRPCServer) Configure(ctx context.Context, req *proto.Configure_Request) (*proto.Configure_Response, error) + func (s *StreamerGRPCServer) Read(req *proto.Read_Request, srv proto.StreamerService_ReadServer) error + func (s *StreamerGRPCServer) Write(srv proto.StreamerService_WriteServer) error + type StreamerPlugin struct + Impl Streamer + func (p *StreamerPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error) + func (p *StreamerPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error
Go to main page