shared

type Streamer interface {
	Configure(ctx context.Context, path string, chunkSize int64) error
	Read(ctx context.Context) ([]byte, error)
	Write(ctx context.Context, b []byte) error
}

type StreamerGRPCClient struct {
	// contains filtered or unexported fields
}

type StreamerGRPCServer struct {
	Impl Streamer

	proto.UnimplementedStreamerServiceServer
	// contains filtered or unexported fields
}

type StreamerPlugin struct {
	plugin.NetRPCUnsupportedPlugin
	Impl Streamer
}